txpool

Documentation

Index

• func IsBadTx(err error) bool
• func IsTxRejected(err error) bool
• func SetGlobTxPoolInst(pool *TxPool) bool
• type Options
• type TxEvent
• type TxPool
  • func GetGlobTxPoolInst() *TxPool
  • func New(chain *chain.Chain, stateCreator *state.Creator, options Options) *TxPool
  • func (p *TxPool) Add(newTx *tx.Transaction) error
  • func (p *TxPool) Close()
  • func (p *TxPool) Dump() tx.Transactions
  • func (p *TxPool) Executables() tx.Transactions
  • func (p *TxPool) Fill(txs tx.Transactions)
  • func (p *TxPool) Remove(txID meter.Bytes32) bool
  • func (p *TxPool) StrictlyAdd(newTx *tx.Transaction) error
  • func (p *TxPool) SubscribeTxEvent(ch chan *TxEvent) event.Subscription

Functions

func IsBadTx

func IsBadTx(err error) bool

IsBadTx returns whether the given error indicates that tx is bad.

func IsTxRejected

func IsTxRejected(err error) bool

IsTxRejected returns whether the given error indicates tx is rejected.

func SetGlobTxPoolInst

func SetGlobTxPoolInst(pool *TxPool) bool

Types

type Options

type Options struct {
	Limit           int
	LimitPerAccount int
	MaxLifetime     time.Duration
}

Options options for tx pool.

type TxEvent

type TxEvent struct {
	Tx         *tx.Transaction
	Executable *bool
}

TxEvent will be posted when tx is added or status changed.

type TxPool

type TxPool struct {
	// contains filtered or unexported fields
}

TxPool maintains unprocessed transactions.

var (
	GlobTxPoolInst *TxPool
)

func GetGlobTxPoolInst

func GetGlobTxPoolInst() *TxPool

func New

func New(chain *chain.Chain, stateCreator *state.Creator, options Options) *TxPool

New create a new TxPool instance. Shutdown is required to be called at end.

func (*TxPool) Add

func (p *TxPool) Add(newTx *tx.Transaction) error

Add add new tx into pool. It's not assumed as an error if the tx to be added is already in the pool,

func (*TxPool) Close

func (p *TxPool) Close()

Close cleanup inner go routines.

func (*TxPool) Dump

func (p *TxPool) Dump() tx.Transactions

Dump dumps all txs in the pool.

func (*TxPool) Executables

func (p *TxPool) Executables() tx.Transactions

Executables returns executable txs.

func (*TxPool) Fill

func (p *TxPool) Fill(txs tx.Transactions)

Fill fills txs into pool.

func (*TxPool) Remove

func (p *TxPool) Remove(txID meter.Bytes32) bool

Remove removes tx from pool by its ID.

func (*TxPool) StrictlyAdd

func (p *TxPool) StrictlyAdd(newTx *tx.Transaction) error

StrictlyAdd add new tx into pool. A rejection error will be returned, if tx is not executable at this time.

func (*TxPool) SubscribeTxEvent

func (p *TxPool) SubscribeTxEvent(ch chan *TxEvent) event.Subscription

SubscribeTxEvent receivers will receive a tx