committee

Documentation

Index

• type Node
  • func NewNode(commonNode *committee.Node) (*Node, error)
  • func (n *Node) CheckTx(ctx context.Context, tx []byte) (*protocol.CheckTxResult, error)
  • func (n *Node) Cleanup()
  • func (n *Node) HandleEpochTransitionLocked(*committee.EpochSnapshot)
  • func (n *Node) HandleNewBlockEarlyLocked(*block.Block)
  • func (n *Node) HandleNewBlockLocked(blk *block.Block)
  • func (n *Node) HandleNewEventLocked(*roothash.Event)
  • func (n *Node) HandlePeerTx(ctx context.Context, tx []byte) error
  • func (n *Node) HandleRuntimeHostEvent(*host.Event)
  • func (n *Node) Initialized() <-chan struct{}
  • func (n *Node) Name() string
  • func (n *Node) Query(ctx context.Context, round uint64, method string, args []byte) ([]byte, error)
  • func (n *Node) Quit() <-chan struct{}
  • func (n *Node) Start() error
  • func (n *Node) Stop()
  • func (n *Node) SubmitTx(ctx context.Context, tx []byte) (<-chan *api.SubmitTxResult, *protocol.Error, error)

Types

type Node

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

Node is a client node.

func NewNode

func NewNode(commonNode *committee.Node) (*Node, error)

NewNode creates a new client node.

func (*Node) CheckTx

func (n *Node) CheckTx(ctx context.Context, tx []byte) (*protocol.CheckTxResult, error)

func (*Node) Cleanup

func (n *Node) Cleanup()

Cleanup performs the service specific post-termination cleanup.

func (*Node) HandleEpochTransitionLocked

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

Guarded by CrossNode.

func (*Node) HandleNewBlockEarlyLocked

func (n *Node) HandleNewBlockEarlyLocked(*block.Block)

Guarded by CrossNode.

func (*Node) HandleNewBlockLocked

func (n *Node) HandleNewBlockLocked(blk *block.Block)

Guarded by CrossNode.

func (*Node) HandleNewEventLocked

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

Guarded by CrossNode.

func (*Node) HandlePeerTx

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

func (*Node) HandleRuntimeHostEvent

func (n *Node) HandleRuntimeHostEvent(*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) Query

func (n *Node) Query(ctx context.Context, round uint64, method string, args []byte) ([]byte, error)

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

func (n *Node) SubmitTx(ctx context.Context, tx []byte) (<-chan *api.SubmitTxResult, *protocol.Error, error)