txpool

Documentation

Index

• Variables
• type Empty
• type TxPool
  • func NewTxPool(minFee *big.Int, db *dbstore.DB, txpoolCh chan *types.Transaction) *TxPool
  • func (tp *TxPool) AddTx(tx *types.Transaction)
  • func (tp *TxPool) AddTx_RPC(args *types.Transaction, reply *types.RPCResponse) error
  • func (tp *TxPool) AddTxs(txs []*types.Transaction)
  • func (tp *TxPool) GetTxs() []*types.Transaction
  • func (tp *TxPool) GetTxs_RPC(_ *Empty, reply *types.RPCResponse) error
  • func (txp *TxPool) IsValid(tx *types.Transaction) bool
  • func (tp *TxPool) RemoveTx(tx *types.Transaction) error

Variables

var (
	ErrInvalidTransaction = errors.New("invalid transaction")
)

Types

type Empty

type Empty struct{}

type TxPool

type TxPool struct {
	MinFee       *big.Int
	State        *dbstore.DB
	Transactions []*types.Transaction

	TxPoolCh chan *types.Transaction

	LatestIncludedTxs *lru.Cache
}

func NewTxPool

func NewTxPool(minFee *big.Int, db *dbstore.DB, txpoolCh chan *types.Transaction) *TxPool

func (*TxPool) AddTx

func (tp *TxPool) AddTx(tx *types.Transaction)

func (*TxPool) AddTx_RPC

func (tp *TxPool) AddTx_RPC(args *types.Transaction, reply *types.RPCResponse) error

func (*TxPool) AddTxs

func (tp *TxPool) AddTxs(txs []*types.Transaction)

func (*TxPool) GetTxs

func (tp *TxPool) GetTxs() []*types.Transaction

func (*TxPool) GetTxs_RPC

func (tp *TxPool) GetTxs_RPC(_ *Empty, reply *types.RPCResponse) error

func (*TxPool) IsValid

func (txp *TxPool) IsValid(tx *types.Transaction) bool

func (*TxPool) RemoveTx

func (tp *TxPool) RemoveTx(tx *types.Transaction) error

remove transaction from txpool