Versions in this module Expand all Collapse all v1 v1.0.0 Jul 21, 2022 Changes in this version + type Handler interface + Bootstrapper func() common.BootstrapableEngine + Consensus func() common.Engine + Context func() *snow.ConsensusContext + IsValidator func(nodeID ids.NodeID) bool + Push func(msg message.InboundMessage) + SetBootstrapper func(engine common.BootstrapableEngine) + SetConsensus func(engine common.Engine) + SetOnStopped func(onStopped func()) + SetStateSyncer func(engine common.StateSyncer) + Start func(recoverPanic bool) + StateSyncer func() common.StateSyncer + Stop func() + StopWithError func(err error) + Stopped func() chan struct{} + func New(mc message.Creator, ctx *snow.ConsensusContext, validators validators.Set, ...) (Handler, error) + type MessageQueue interface + Len func() int + Pop func() (message.InboundMessage, bool) + Push func(message.InboundMessage) + Shutdown func() + func NewMessageQueue(log logging.Logger, vdrs validators.Set, cpuTracker tracker.Tracker, ...) (MessageQueue, error) v1.0.0-alpha Nov 22, 2022
Go to main page