committee

Documentation

Index

• Constants
• type Node
  • func NewNode(commonNode *committee.Node, commonCfg commonWorker.Config, ...) (*Node, error)
  • func (n *Node) Cleanup()
  • func (n *Node) GetStatus() (*api.Status, error)
  • func (n *Node) HandleEpochTransitionLocked(*committee.EpochSnapshot)
  • func (n *Node) HandleNewBlockEarlyLocked(*runtime.BlockInfo)
  • func (n *Node) HandleNewBlockLocked(bi *runtime.BlockInfo)
  • func (n *Node) HandleNewEventLocked(ev *roothash.Event)
  • func (n *Node) HandlePeerTx(context.Context, []byte) error
  • func (n *Node) HandleRuntimeHostEventLocked(ev *host.Event)
  • func (n *Node) Initialized() <-chan struct{}
  • func (n *Node) Name() string
  • func (n *Node) NotifyDiscrepancy(info *discrepancyEvent)
  • func (n *Node) NotifySchedulerCommitment(ec *commitment.ExecutorCommitment)
  • 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 RankTicker
  • func NewLinearRankTicker(timestamp uint64, d time.Duration, maxRank uint64) RankTicker
• type StateName
• type StateProcessingBatch
  • func (s *StateProcessingBatch) Cancel()
  • func (s StateProcessingBatch) Name() StateName
  • func (s StateProcessingBatch) String() string
• type StateWaitingForBatch
  • func (s StateWaitingForBatch) Name() StateName
  • func (s StateWaitingForBatch) String() string
• type StateWaitingForEvent
  • func (s StateWaitingForEvent) Name() StateName
  • func (s StateWaitingForEvent) String() string
• type StateWaitingForTxs
  • func (s StateWaitingForTxs) Cancel()
  • func (s StateWaitingForTxs) Name() StateName
  • func (s StateWaitingForTxs) String() string

Constants

const (
	// WaitingForBatch is the name of StateWaitingForBatch.
	WaitingForBatch = "WaitingForBatch"
	// WaitingForTxs is the name of the StateWaitingForTxs.
	WaitingForTxs = "WaitingForTxs"
	// WaitingForEvent is the name of StateWaitingForEvent.
	WaitingForEvent = "WaitingForEvent"
	// ProcessingBatch is the name of StateProcessingBatch.
	ProcessingBatch = "ProcessingBatch"
)

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) GetStatus

func (n *Node) GetStatus() (*api.Status, error)

GetStatus returns the executor committee node status.

func (*Node) HandleEpochTransitionLocked

func (n *Node) HandleEpochTransitionLocked(*committee.EpochSnapshot)

HandleEpochTransitionLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.

func (*Node) HandleNewBlockEarlyLocked

func (n *Node) HandleNewBlockEarlyLocked(*runtime.BlockInfo)

HandleNewBlockEarlyLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.

func (*Node) HandleNewBlockLocked

func (n *Node) HandleNewBlockLocked(bi *runtime.BlockInfo)

HandleNewBlockLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.

func (*Node) HandleNewEventLocked

func (n *Node) HandleNewEventLocked(ev *roothash.Event)

HandleNewEventLocked implements NodeHooks. Guarded by n.commonNode.CrossNode.

func (*Node) HandlePeerTx

func (n *Node) HandlePeerTx(context.Context, []byte) error

HandlePeerTx implements NodeHooks.

func (*Node) HandleRuntimeHostEventLocked

func (n *Node) HandleRuntimeHostEventLocked(ev *host.Event)

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) Name

func (n *Node) Name() string

Name returns the service name.

func (*Node) NotifyDiscrepancy

func (n *Node) NotifyDiscrepancy(info *discrepancyEvent)

func (*Node) NotifySchedulerCommitment

func (n *Node) NotifySchedulerCommitment(ec *commitment.ExecutorCommitment)

func (*Node) Quit

func (n *Node) Quit() <-chan struct{}

Quit returns a channel that will be closed when the service terminates.

func (*Node) Start

func (n *Node) Start() error

Start starts the service.

func (*Node) Stop

func (n *Node) Stop()

Stop halts the service.

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 RankTicker

type RankTicker interface {
	// Start starts the ticker.
	Start()

	// Stop stops the ticker.
	Stop()

	// C returns a channel on which ranks will be sent.
	C() <-chan uint64
}

RankTicker represents an interface for rank ticker functionality.

func NewLinearRankTicker

func NewLinearRankTicker(timestamp uint64, d time.Duration, maxRank uint64) RankTicker

NewLinearRankTicker returns a new linear rank ticker.

type StateName

type StateName string

StateName is a symbolic state without the attached values.

type StateProcessingBatch

type StateProcessingBatch struct {
	// contains filtered or unexported fields
}

StateProcessingBatch is the processing batch state.

func (*StateProcessingBatch) Cancel

func (s *StateProcessingBatch) Cancel()

Cancel invokes the cancellation function and waits for the processing to actually stop.

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{}

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 StateWaitingForTxs

type StateWaitingForTxs struct {
	// contains filtered or unexported fields
}

func (StateWaitingForTxs) Cancel

func (s StateWaitingForTxs) Cancel()

Cancel invokes the cancellation function and waits for the fetching to actually stop.

func (StateWaitingForTxs) Name

func (s StateWaitingForTxs) Name() StateName

Name returns the name of the state.

func (StateWaitingForTxs) String

func (s StateWaitingForTxs) String() string

String returns a string representation of the state.