committee

package
v0.2201.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 28, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL