Documentation ¶
Index ¶
- Constants
- type Node
- func (n *Node) Cleanup()
- func (n *Node) GetStatus(ctx context.Context) (*api.Status, error)
- 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) HandlePeerTx(ctx context.Context, tx []byte) error
- func (n *Node) HandleRuntimeHostEventLocked(ev *host.Event)
- 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
- type StateName
- type StateNotReady
- type StateProcessingBatch
- type StateWaitingForBatch
- type StateWaitingForEvent
- type StateWaitingForFinalize
- type StateWaitingForTxs
Constants ¶
const ( // NotReady is the name of StateNotReady. NotReady StateName = "NotReady" // WaitingForBatch is the name of StateWaitingForBatch. WaitingForBatch = "WaitingForBatch" // WaitingForEvent is the name of StateWaitingForEvent. WaitingForEvent = "WaitingForEvent" // WaitingForTxs is the name of the StateWaitingForTxs. WaitingForTxs = "WaitingForTxs" // ProcessingBatch is the name of StateProcessingBatch. ProcessingBatch = "ProcessingBatch" // WaitingForFinalize is the name of StateWaitingForFinalize. WaitingForFinalize = "WaitingForFinalize" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Node ¶
type Node struct {
// contains filtered or unexported fields
}
Node is a committee node.
func NewNode ¶
func NewNode( commonNode *committee.Node, commonCfg commonWorker.Config, roleProvider registration.RoleProvider, ) (*Node, error)
NewNode initializes a new executor node.
func (*Node) Cleanup ¶
func (n *Node) Cleanup()
Cleanup performs the service specific post-termination cleanup.
func (*Node) HandleEpochTransitionLocked ¶
func (n *Node) HandleEpochTransitionLocked(epoch *committee.EpochSnapshot)
HandleEpochTransitionLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.
func (*Node) HandleNewBlockEarlyLocked ¶
HandleNewBlockEarlyLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.
func (*Node) HandleNewBlockLocked ¶
HandleNewBlockLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.
func (*Node) HandleNewEventLocked ¶
HandleNewEventLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.
func (*Node) HandlePeerTx ¶ added in v0.2200.0
HandlePeerTx implements NodeHooks.
func (*Node) HandleRuntimeHostEventLocked ¶ added in v0.2202.0
func (*Node) Initialized ¶
func (n *Node) Initialized() <-chan struct{}
Initialized returns a channel that will be closed when the node is initialized and ready to service requests.
func (*Node) Quit ¶
func (n *Node) Quit() <-chan struct{}
Quit returns a channel that will be closed when the service terminates.
func (*Node) WatchStateTransitions ¶
func (n *Node) WatchStateTransitions() (<-chan NodeState, *pubsub.Subscription)
WatchStateTransitions subscribes to the node's state transitions.
type NodeState ¶
type NodeState interface { // Name returns the name of the state. Name() StateName }
NodeState is a node's state.
type StateNotReady ¶
type StateNotReady struct{}
StateNotReady is the not ready state.
func (StateNotReady) Name ¶
func (s StateNotReady) Name() StateName
Name returns the name of the state.
func (StateNotReady) String ¶
func (s StateNotReady) String() string
String returns a string representation of the state.
type StateProcessingBatch ¶
type StateProcessingBatch struct {
// contains filtered or unexported fields
}
StateProcessingBatch is the processing batch state.
func (StateProcessingBatch) Name ¶
func (s StateProcessingBatch) Name() StateName
Name returns the name of the state.
func (StateProcessingBatch) String ¶
func (s StateProcessingBatch) String() string
String returns a string representation of the state.
type StateWaitingForBatch ¶
type StateWaitingForBatch struct {
// contains filtered or unexported fields
}
StateWaitingForBatch is the waiting for batch state.
func (StateWaitingForBatch) Name ¶
func (s StateWaitingForBatch) Name() StateName
Name returns the name of the state.
func (StateWaitingForBatch) String ¶
func (s StateWaitingForBatch) String() string
String returns a string representation of the state.
type StateWaitingForEvent ¶
type StateWaitingForEvent struct {
// contains filtered or unexported fields
}
StateWaitingForEvent is the waiting for event state.
func (StateWaitingForEvent) Name ¶
func (s StateWaitingForEvent) Name() StateName
Name returns the name of the state.
func (StateWaitingForEvent) String ¶
func (s StateWaitingForEvent) String() string
String returns a string representation of the state.
type StateWaitingForFinalize ¶
type StateWaitingForFinalize struct {
// contains filtered or unexported fields
}
StateWaitingForFinalize is the waiting for finalize state.
func (StateWaitingForFinalize) Name ¶
func (s StateWaitingForFinalize) Name() StateName
Name returns the name of the state.
func (StateWaitingForFinalize) String ¶
func (s StateWaitingForFinalize) String() string
String returns a string representation of the state.
type StateWaitingForTxs ¶ added in v0.2200.0
type StateWaitingForTxs struct {
// contains filtered or unexported fields
}
func (StateWaitingForTxs) Name ¶ added in v0.2200.0
func (s StateWaitingForTxs) Name() StateName
Name returns the name of the state.
func (StateWaitingForTxs) String ¶ added in v0.2200.0
func (s StateWaitingForTxs) String() string
String returns a string representation of the state.