dispatcher

Documentation

Index

• type Dispatcher
  • func (s *Dispatcher) Dispatch(msg protoext.ReceivedMessage) bool
• type Provider
  • func NewProvider() *Provider
  • func (p *Provider) ForChannel(channelID string, dataStore storeapi.Store) *Dispatcher
  • func (p *Provider) Initialize(gossipProvider collcommon.GossipProvider, ...) *Provider

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

type Provider struct {
	// contains filtered or unexported fields
}

Provider is a gossip dispatcher provider

func NewProvider

func NewProvider() *Provider

NewProvider returns a new gossip message dispatcher provider

func (*Provider) ForChannel

func (p *Provider) ForChannel(channelID string, dataStore storeapi.Store) *Dispatcher

ForChannel returns a new dispatcher for the given channel

func (*Provider) Initialize

func (p *Provider) Initialize(gossipProvider collcommon.GossipProvider, ccProvider collcommon.CollectionConfigProvider, handlerProvider appDataHandlerProvider) *Provider

Initialize is called at startup by the resource manager