listeners

Documentation

Index

• type ListenerManager
  • func NewListenerManager(config map[string]map[string]string, eventStore *events.EventStore, ...) *ListenerManager
  • func (omgr *ListenerManager) Start() error
  • func (omgr *ListenerManager) Stop()
• type ValidatorGetter

Types

type ListenerManager

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

ListenerManager listens for any Validator state changes and node catch up status and starts or stops the listeners accordingly It starts the listeners only when the node is a validator and is caught up It stops the running listeners when the node loses its validator status

func NewListenerManager

func NewListenerManager(config map[string]map[string]string, eventStore *events.EventStore, node *cometbft.CometBftNode, nodePubKey []byte, vstore ValidatorGetter, logger log.Logger) *ListenerManager

func (*ListenerManager) Start

func (omgr *ListenerManager) Start() error

Start starts the listener manager. It will block until Stop is called.

func (*ListenerManager) Stop

func (omgr *ListenerManager) Stop()

type ValidatorGetter

type ValidatorGetter interface {
	GetValidators(ctx context.Context) ([]*types.Validator, error)
}

ValidatorGetter is able to read the current validator set.