txpool

Documentation

Index

• type TxPool
  • func New(config *order.Config, storage storage.Storage, packSize int, ...) (*TxPool, chan *raftproto.Ready)
  • func (tp *TxPool) AddPendingTx(tx *pb.Transaction) error
  • func (tp *TxPool) BatchDelete(hashes []types.Hash)
  • func (tp *TxPool) BatchStore(hashes []types.Hash)
  • func (tp *TxPool) Broadcast(tx *pb.Transaction) error
  • func (tp *TxPool) BuildReqLookUp()
  • func (tp *TxPool) CheckExecute(isLeader bool)
  • func (tp *TxPool) FetchBlock(height uint64) (*pb.Block, error)
  • func (tp *TxPool) FetchTx(hash types.Hash) *pb.Transaction
  • func (tp *TxPool) GetHeight() uint64
  • func (tp *TxPool) GetTx(hash types.Hash, findByStore bool) (*pb.Transaction, bool)
  • func (tp *TxPool) PoolSize() int
  • func (tp *TxPool) RemoveTxs(hashes []types.Hash, isLeader bool)
  • func (tp *TxPool) UpdateHeight() uint64

Types

type TxPool

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

func New

func New(config *order.Config, storage storage.Storage, packSize int, blockTick time.Duration) (*TxPool, chan *raftproto.Ready)

New txpool

func (*TxPool) AddPendingTx

func (tp *TxPool) AddPendingTx(tx *pb.Transaction) error

Add pending transaction into txpool

func (*TxPool) BatchDelete

func (tp *TxPool) BatchDelete(hashes []types.Hash)

batch delete txs

func (*TxPool) BatchStore

func (tp *TxPool) BatchStore(hashes []types.Hash)

batch store txs

func (*TxPool) Broadcast

func (tp *TxPool) Broadcast(tx *pb.Transaction) error

Broadcast the new transaction to other nodes

func (*TxPool) BuildReqLookUp

func (tp *TxPool) BuildReqLookUp()

Store the bloom filter

func (*TxPool) CheckExecute

func (tp *TxPool) CheckExecute(isLeader bool)

Check the txpool status, only leader node can run Execute()

func (*TxPool) FetchBlock

func (tp *TxPool) FetchBlock(height uint64) (*pb.Block, error)

Fetch tx by local txpool or network

func (*TxPool) FetchTx

func (tp *TxPool) FetchTx(hash types.Hash) *pb.Transaction

Fetch tx by local txpool or network

func (*TxPool) GetHeight

func (tp *TxPool) GetHeight() uint64

Get current block height

func (*TxPool) GetTx

func (tp *TxPool) GetTx(hash types.Hash, findByStore bool) (*pb.Transaction, bool)

Get the transaction by txpool or ledger

func (*TxPool) PoolSize

func (tp *TxPool) PoolSize() int

Current txpool's size

func (*TxPool) RemoveTxs

func (tp *TxPool) RemoveTxs(hashes []types.Hash, isLeader bool)

Remove stored transactions

func (*TxPool) UpdateHeight

func (tp *TxPool) UpdateHeight() uint64

Add the block height