Versions in this module Expand all Collapse all v0 v0.20.9 Aug 5, 2020 Changes in this version + const NotReady + const ProcessingMerge + const WaitingForEvent + const WaitingForFinalize + const WaitingForResults + type Node struct + func NewNode(commonNode *committee.Node, commonCfg workerCommon.Config, ...) (*Node, error) + func (n *Node) Cleanup() + func (n *Node) HandleEpochTransitionLocked(epoch *committee.EpochSnapshot) + func (n *Node) HandleNewBlockEarlyLocked(blk *block.Block) + func (n *Node) HandleNewBlockLocked(blk *block.Block) + func (n *Node) HandleNewEventLocked(ev *roothash.Event) + func (n *Node) HandleNodeUpdateLocked(update *runtimeCommittee.NodeUpdate, snapshot *committee.EpochSnapshot) + func (n *Node) HandlePeerMessage(ctx context.Context, message *p2p.Message) (bool, error) + func (n *Node) HandleResultsFromExecutorWorkerLocked(spanCtx opentracing.SpanContext, commit *commitment.ExecutorCommitment) + func (n *Node) Initialized() <-chan struct{} + func (n *Node) Name() string + func (n *Node) Quit() <-chan struct{} + func (n *Node) Start() error + func (n *Node) Stop() + func (n *Node) WatchStateTransitions() (<-chan NodeState, *pubsub.Subscription) + type NodeState interface + Name func() StateName + type StateName string + type StateNotReady struct + func (s StateNotReady) Name() StateName + func (s StateNotReady) String() string + type StateProcessingMerge struct + func (s StateProcessingMerge) Name() StateName + func (s StateProcessingMerge) String() string + type StateWaitingForEvent struct + func (s StateWaitingForEvent) Name() StateName + func (s StateWaitingForEvent) String() string + type StateWaitingForFinalize struct + func (s StateWaitingForFinalize) Name() StateName + func (s StateWaitingForFinalize) String() string + type StateWaitingForResults struct + func (s StateWaitingForResults) Name() StateName + func (s StateWaitingForResults) String() string