listeners

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(svc *common.Service, eventStore *voting.EventStore, vstore ValidatorGetter, node Node) *ListenerManager

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

func (omgr *ListenerManager) Stop()

type Node ¶

type Node interface {
	InCatchup() bool
}

type ValidatorGetter ¶

type ValidatorGetter interface {
	GetValidators() []*types.Validator
	SubscribeValidators() <-chan []*types.Validator
}

ValidatorGetter is able to read the current validator set.