Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.