txpool

Documentation

Index

• type TxPool
  • func NewTxPool(blockchain *ethchainadapter.EthChainAdapter, gasTip *big.Int, ...) (*TxPool, error)
  • func (t *TxPool) Add(transaction *common.L2Tx) error
  • func (t *TxPool) Close() error
  • func (t *TxPool) PendingTransactions() map[gethcommon.Address][]*gethtxpool.LazyTransaction
  • func (t *TxPool) Running() bool
  • func (t *TxPool) Start() error
  • func (t *TxPool) Validate(tx *common.L2Tx) error

Types

type TxPool

type TxPool struct {
	Chain *ethchainadapter.EthChainAdapter
	// contains filtered or unexported fields
}

TxPool is an obscuro wrapper around geths transaction pool

func NewTxPool

func NewTxPool(blockchain *ethchainadapter.EthChainAdapter, gasTip *big.Int, logger gethlog.Logger) (*TxPool, error)

NewTxPool returns a new instance of the tx pool

func (*TxPool) Add

func (t *TxPool) Add(transaction *common.L2Tx) error

Add adds a new transactions to the pool

func (*TxPool) Close

func (t *TxPool) Close() error

func (*TxPool) PendingTransactions

func (t *TxPool) PendingTransactions() map[gethcommon.Address][]*gethtxpool.LazyTransaction

PendingTransactions returns all pending transactions grouped per address and ordered per nonce

func (*TxPool) Running

func (t *TxPool) Running() bool

func (*TxPool) Start

func (t *TxPool) Start() error

Start starts the pool can only be started after t.blockchain has at least one block inside

func (*TxPool) Validate

func (t *TxPool) Validate(tx *common.L2Tx) error

Validate - run the underlying tx pool validation logic