solo

Documentation

Index

• func NewNode(opts ...agency.ConfigOption) (agency.Order, error)
• type MempoolConfig
• type Node
  • func (n *Node) Commit() chan *pb.CommitEvent
  • func (n *Node) DelNode(delID uint64) error
  • func (n *Node) GetPendingNonceByAccount(account string) uint64
  • func (n *Node) GetPendingTxByHash(hash *types.Hash) pb.Transaction
  • func (n *Node) Prepare(tx pb.Transaction) error
  • func (n *Node) Quorum() uint64
  • func (n *Node) Ready() error
  • func (n *Node) ReportState(height uint64, blockHash *types.Hash, txHashList []*types.Hash)
  • func (n *Node) Start() error
  • func (n *Node) Step(msg []byte) error
  • func (n *Node) Stop()
  • func (n *Node) SubscribeTxEvent(ch chan<- pb.Transactions) event.Subscription
• type SOLO
• type SOLOConfig

Functions

func NewNode

func NewNode(opts ...agency.ConfigOption) (agency.Order, error)

Types

type MempoolConfig

type MempoolConfig struct {
	BatchSize      uint64        `mapstructure:"batch_size"`
	PoolSize       uint64        `mapstructure:"pool_size"`
	TxSliceSize    uint64        `mapstructure:"tx_slice_size"`
	TxSliceTimeout time.Duration `mapstructure:"tx_slice_timeout"`
}

type Node

type Node struct {
	ID uint64

	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Node) Commit

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

func (*Node) DelNode

func (n *Node) DelNode(delID uint64) error

func (*Node) GetPendingNonceByAccount

func (n *Node) GetPendingNonceByAccount(account string) uint64

func (*Node) GetPendingTxByHash

func (n *Node) GetPendingTxByHash(hash *types.Hash) pb.Transaction

func (*Node) Prepare

func (n *Node) Prepare(tx pb.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, txHashList []*types.Hash)

func (*Node) Start

func (n *Node) Start() error

func (*Node) Step

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

func (*Node) Stop

func (n *Node) Stop()

func (*Node) SubscribeTxEvent

func (n *Node) SubscribeTxEvent(ch chan<- pb.Transactions) event.Subscription

type SOLO

type SOLO struct {
	BatchTimeout  time.Duration `mapstructure:"batch_timeout"`
	MempoolConfig MempoolConfig `mapstructure:"mempool"`
}

type SOLOConfig

type SOLOConfig struct {
	SOLO SOLO
}