solo

Documentation

Index

• Constants
• type Node
  • func NewNode(config *common.Config) (*Node, error)
  • func (n *Node) Commit() chan *common.CommitEvent
  • func (n *Node) GetLowWatermark() uint64
  • func (n *Node) Prepare(tx *types.Transaction) error
  • func (n *Node) Quorum() uint64
  • func (n *Node) Ready() error
  • func (n *Node) ReportState(height uint64, blockHash *types.Hash, txPointerList []*events.TxPointer, ...)
  • func (n *Node) Start() error
  • func (n *Node) Step([]byte) error
  • func (n *Node) Stop()
  • func (n *Node) SubmitTxsFromRemote(_ [][]byte) error
  • func (n *Node) SubscribeMockBlockEvent(ch chan<- events.ExecutedEvent) event.Subscription
  • func (n *Node) SubscribeTxEvent(events chan<- []*types.Transaction) event.Subscription

Constants

const (
	ErrPoolFull = "txpool is full"
)

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