Versions in this module Expand all Collapse all v1 v1.0.0 Apr 12, 2019 Changes in this version + var DefaultTxPoolConfig = TxPoolConfig + type BlockChain interface + CurrentBlock func() model.AbstractBlock + GetBlockByNumber func(number uint64) model.AbstractBlock + StateAtByStateRoot func(root common.Hash) (*state_processor.AccountStateDB, error) + type TxByNonce []model.AbstractTransaction + func (t TxByNonce) Len() int + func (t TxByNonce) Less(i, j int) bool + func (t TxByNonce) Swap(i, j int) + type TxPool struct + func NewTxPool(config TxPoolConfig, chainConfig chain_config.ChainConfig, chain BlockChain) *TxPool + func (pool *TxPool) AbstractTxsCaching(txs []model.AbstractTransaction) + func (pool *TxPool) AddLocal(tx model.AbstractTransaction) error + func (pool *TxPool) AddLocals(txs []model.AbstractTransaction) []error + func (pool *TxPool) AddRemote(tx model.AbstractTransaction) error + func (pool *TxPool) AddRemotes(txs []model.AbstractTransaction) []error + func (pool *TxPool) ConvertPoolToMap() map[common.Hash]model.AbstractTransaction + func (pool *TxPool) Get(hash common.Hash) model.AbstractTransaction + func (pool *TxPool) GetTxsEstimator(broadcastBloom *iblt.Bloom) *iblt.HybridEstimator + func (pool *TxPool) Pending() (map[common.Address][]model.AbstractTransaction, error) + func (pool *TxPool) Queueing() (map[common.Address][]model.AbstractTransaction, error) + func (pool *TxPool) RemoveTxs(newBlock model.AbstractBlock) + func (pool *TxPool) RemoveTxsBatch(txIds []common.Hash) + func (pool *TxPool) Reset(oldHead, newHead *model.Header) + func (pool *TxPool) Start() error + func (pool *TxPool) Stats() (int, int) + func (pool *TxPool) Status(hashes []common.Hash) []TxStatus + func (pool *TxPool) Stop() + func (pool *TxPool) TxsCaching(txs []*model.Transaction) + type TxPoolConfig struct + AccountQueue uint64 + AccountSlots uint64 + FeeBump uint64 + GlobalQueue uint64 + GlobalSlots uint64 + Journal string + Lifetime time.Duration + MinFee *big.Int + NoLocals bool + Rejournal time.Duration + type TxStatus uint + const TxStatusPending + const TxStatusQueued + const TxStatusUnknown