events

package
v0.34.0-crescendo-prev... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2024 License: AGPL-3.0 Imports: 3 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL