listeners

Documentation

Index

• type ListenerManager
  • func NewListenerManager(config map[string]map[string]string, eventStore *voting.EventStore, ...) *ListenerManager
  • func (omgr *ListenerManager) Start() (err 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 *voting.EventStore,
	node *cometbft.CometBftNode, nodePubKey []byte, vstore ValidatorGetter, logger log.Logger) *ListenerManager

func (*ListenerManager) Start

func (omgr *ListenerManager) Start() (err error)

Start starts the listener manager. It will block until Stop is called. If any one listener stops, all listeners are stopped and a non-nil error is returned.

func (*ListenerManager) Stop

func (omgr *ListenerManager) Stop()

type ValidatorGetter

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

ValidatorGetter is able to read the current validator set.