Versions in this module Expand all Collapse all v1 v1.1.1 Feb 22, 2026 v1.1.0 Feb 19, 2026 Changes in this version + var ErrAlreadyKnown = errors.New("already known") + var ErrBlockLimitExceeded = errors.New("exceeds block gas limit") + var ErrDynamicTxNotAllowed = errors.New("dynamic tx not allowed currently") + var ErrExtractSignature = errors.New("cannot extract signature") + var ErrFeeCapVeryHigh = errors.New("max fee per gas higher than 2^256-1") + var ErrInsufficientFunds = errors.New("insufficient funds for gas * price + value") + var ErrIntrinsicGas = errors.New("intrinsic gas too low") + var ErrInvalidAccountState = errors.New("invalid account state") + var ErrInvalidSender = errors.New("invalid sender") + var ErrInvalidTxType = errors.New("invalid tx type") + var ErrMaxEnqueuedLimitReached = errors.New("maximum number of enqueued transactions reached") + var ErrMissingChainIDConfig = errors.New("missing txpool chain id configuration") + var ErrNegativeValue = errors.New("negative value") + var ErrNonceExistsInPool = errors.New("tx with the same nonce is already present") + var ErrNonceTooLow = errors.New("nonce too low") + var ErrOversizedData = errors.New("oversized data") + var ErrRejectFutureTx = errors.New("rejected future tx due to low slots") + var ErrReplacementUnderpriced = errors.New("replacement tx underpriced") + var ErrTipAboveFeeCap = errors.New("max priority fee per gas higher than max fee per gas") + var ErrTipVeryHigh = errors.New("max priority fee per gas higher than 2^256-1") + var ErrTxPoolOverflow = errors.New("txpool is full") + var ErrTxTypeNotSupported = types.ErrTxTypeNotSupported + var ErrUnderpriced = errors.New("transaction underpriced") + type Config struct + ChainID *big.Int + MaxAccountEnqueued uint64 + MaxSlots uint64 + PriceLimit uint64 + type TxPool struct + func NewTxPool(logger hclog.Logger, forks *chain.Forks, store store, grpcServer *grpc.Server, ...) (*TxPool, error) + func (p *TxPool) AddTx(tx *types.Transaction) error + func (p *TxPool) AddTxn(ctx context.Context, raw *proto.AddTxnReq) (*proto.AddTxnResp, error) + func (p *TxPool) Close() + func (p *TxPool) Demote(tx *types.Transaction) + func (p *TxPool) Drop(tx *types.Transaction) + func (p *TxPool) GetBaseFee() uint64 + func (p *TxPool) GetCapacity() (uint64, uint64) + func (p *TxPool) GetNonce(addr types.Address) uint64 + func (p *TxPool) GetPendingTx(txHash types.Hash) (*types.Transaction, bool) + func (p *TxPool) GetTxs(inclQueued bool) (allPromoted, allEnqueued map[types.Address][]*types.Transaction) + func (p *TxPool) Length() uint64 + func (p *TxPool) Peek() *types.Transaction + func (p *TxPool) Pop(tx *types.Transaction) + func (p *TxPool) Prepare() + func (p *TxPool) ResetWithHeaders(headers ...*types.Header) + func (p *TxPool) SetBaseFee(header *types.Header) + func (p *TxPool) SetSealing(sealing bool) + func (p *TxPool) SetSigner(s signer) + func (p *TxPool) Start() + func (p *TxPool) Status(ctx context.Context, req *empty.Empty) (*proto.TxnPoolStatusResp, error) + func (p *TxPool) Subscribe(request *proto.SubscribeRequest, stream proto.TxnPoolOperator_SubscribeServer) error + func (p *TxPool) TxPoolSubscribe(request *proto.SubscribeRequest) (<-chan *proto.TxPoolEvent, func(), error)
Go to main page