solo

package
v0.4.2 Latest Latest
Warning

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

Go to latest
Published: Mar 6, 2024 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ErrPoolFull = "txpool is full"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Node

type Node struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNode

func NewNode(config *common.Config) (*Node, error)

func (*Node) Commit

func (n *Node) Commit() chan *common.CommitEvent

func (*Node) GetLowWatermark

func (n *Node) GetLowWatermark() uint64

func (*Node) Prepare

func (n *Node) Prepare(tx *types.Transaction) error

func (*Node) Quorum

func (n *Node) Quorum() uint64

func (*Node) Ready

func (n *Node) Ready() error

func (*Node) ReportState

func (n *Node) ReportState(height uint64, blockHash *types.Hash, txPointerList []*events.TxPointer, _ *consensus.Checkpoint, _ bool)

func (*Node) Start

func (n *Node) Start() error

func (*Node) Step

func (n *Node) Step([]byte) error

func (*Node) Stop

func (n *Node) Stop()

func (*Node) SubmitTxsFromRemote

func (n *Node) SubmitTxsFromRemote(_ [][]byte) error

func (*Node) SubscribeMockBlockEvent

func (n *Node) SubscribeMockBlockEvent(ch chan<- events.ExecutedEvent) event.Subscription

func (*Node) SubscribeTxEvent

func (n *Node) SubscribeTxEvent(events chan<- []*types.Transaction) event.Subscription

Jump to

Keyboard shortcuts

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