events

Documentation

Index

• type ClusterEventsDistributor
  • func NewClusterEventsDistributor() *ClusterEventsDistributor
  • func (d *ClusterEventsDistributor) ActiveClustersChanged(list flow.ChainIDList)
  • func (d *ClusterEventsDistributor) AddConsumer(consumer collection.ClusterEvents)
• type CollectionEngineEventsDistributor
  • func NewDistributor() *CollectionEngineEventsDistributor
  • func (d *CollectionEngineEventsDistributor) AddConsumer(consumer collection.EngineEvents)

Types

type ClusterEventsDistributor

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

ClusterEventsDistributor distributes cluster events to a list of subscribers.

func NewClusterEventsDistributor

func NewClusterEventsDistributor() *ClusterEventsDistributor

NewClusterEventsDistributor returns a new events *ClusterEventsDistributor.

func (*ClusterEventsDistributor) ActiveClustersChanged

func (d *ClusterEventsDistributor) ActiveClustersChanged(list flow.ChainIDList)

ActiveClustersChanged distributes events to all subscribers.

func (*ClusterEventsDistributor) AddConsumer

func (d *ClusterEventsDistributor) AddConsumer(consumer collection.ClusterEvents)

type CollectionEngineEventsDistributor

type CollectionEngineEventsDistributor struct {
	*ClusterEventsDistributor
}

CollectionEngineEventsDistributor set of structs that implement all collection engine event interfaces.

func NewDistributor

func NewDistributor() *CollectionEngineEventsDistributor

NewDistributor returns a new *CollectionEngineEventsDistributor.

func (*CollectionEngineEventsDistributor) AddConsumer

func (d *CollectionEngineEventsDistributor) AddConsumer(consumer collection.EngineEvents)