pool

Documentation

Index

• Constants
• type TxnPool
  • func NewTxnPool() *TxnPool
  • func (tp *TxnPool) AppendTxnPool(txn *Transaction) ErrCode
  • func (tp *TxnPool) CleanSubmittedTransactions(txns []*Transaction) error
  • func (tp *TxnPool) GetAllTransactions() map[common.Uint256]*Transaction
  • func (tp *TxnPool) GetTransaction(hash common.Uint256) *Transaction
  • func (tp *TxnPool) GetTransactionCount() int
  • func (tp *TxnPool) GetTxnByCount(num int, winningHash common.Uint256) (map[common.Uint256]*Transaction, error)

Constants

const (
	ExclusivedSigchainHeight = 3
)

Types

type TxnPool

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

func NewTxnPool

func NewTxnPool() *TxnPool

func (*TxnPool) AppendTxnPool

func (tp *TxnPool) AppendTxnPool(txn *Transaction) ErrCode

append transaction to txnpool when check ok. 1.check transaction. 2.check with ledger(db) 3.check with pool

func (*TxnPool) CleanSubmittedTransactions

func (tp *TxnPool) CleanSubmittedTransactions(txns []*Transaction) error

clean the trasaction Pool with committed block.

func (*TxnPool) GetAllTransactions

func (tp *TxnPool) GetAllTransactions() map[common.Uint256]*Transaction

func (*TxnPool) GetTransaction

func (tp *TxnPool) GetTransaction(hash common.Uint256) *Transaction

get the transaction by hash

func (*TxnPool) GetTransactionCount

func (tp *TxnPool) GetTransactionCount() int

func (*TxnPool) GetTxnByCount

func (tp *TxnPool) GetTxnByCount(num int, winningHash common.Uint256) (map[common.Uint256]*Transaction, error)