Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher is a Gossip message dispatcher
func (*Dispatcher) Dispatch ¶
func (s *Dispatcher) Dispatch(msg protoext.ReceivedMessage) bool
Dispatch handles the message and returns true if the message was handled; false if the message is unrecognized
type Provider ¶ added in v0.1.1
type Provider struct {
// contains filtered or unexported fields
}
Provider is a gossip dispatcher provider
func NewProvider ¶ added in v0.1.1
func NewProvider() *Provider
NewProvider returns a new gossip message dispatcher provider
func (*Provider) ForChannel ¶ added in v0.1.1
func (p *Provider) ForChannel(channelID string, dataStore storeapi.Store) *Dispatcher
ForChannel returns a new dispatcher for the given channel
func (*Provider) Initialize ¶ added in v0.1.1
func (p *Provider) Initialize(gossipProvider collcommon.GossipProvider, ccProvider collcommon.CollectionConfigProvider, handlerProvider appDataHandlerProvider) *Provider
Initialize is called at startup by the resource manager
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.