txpool

package

v2.4.0 Latest Latest Go to latest Published: Oct 27, 2025 License: LGPL-3.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/vechain/thor

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func IsBadTx(err error) bool
func IsTxRejected(err error) bool
type Options
type TxEvent
type TxObject
- func ResolveTx(tx *tx.Transaction, localSubmitted bool) (*TxObject, error)
type TxPool
- func New(repo *chain.Repository, stater *state.Stater, options Options, ...) *TxPool

Constants ¶

View Source

const (
	// max size of tx allowed
	MaxTxSize = 64 * 1024
)

Variables ¶

This section is empty.

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.

Types ¶

type Options ¶

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

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 TxObject ¶ added in v2.4.0

type TxObject struct {
	*tx.Transaction
	// contains filtered or unexported fields
}

func ResolveTx ¶ added in v2.4.0

func ResolveTx(tx *tx.Transaction, localSubmitted bool) (*TxObject, error)

func (*TxObject) Cost ¶ added in v2.4.0

func (o *TxObject) Cost() *big.Int

func (*TxObject) Delegator ¶ added in v2.4.0

func (o *TxObject) Delegator() *thor.Address

func (*TxObject) Executable ¶ added in v2.4.0

func (o *TxObject) Executable(chain *chain.Chain, state *state.State, headBlock *block.Header, forkConfig *thor.ForkConfig, baseFee *big.Int) (bool, error)

func (*TxObject) Origin ¶ added in v2.4.0

func (o *TxObject) Origin() thor.Address

func (*TxObject) Payer ¶ added in v2.4.0

func (o *TxObject) Payer() *thor.Address

type TxPool ¶

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

TxPool maintains unprocessed transactions.

func New ¶

func New(repo *chain.Repository, stater *state.Stater, options Options, forkConfig *thor.ForkConfig) *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 adds a new tx into pool. It's not assumed as an error if the tx to be added is already in the pool,

func (*TxPool) AddLocal ¶

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

AddLocal adds new locally submitted tx into 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) Get ¶

func (p *TxPool) Get(id thor.Bytes32) *tx.Transaction

Get get pooled tx by id.

func (*TxPool) Len ¶ added in v2.2.2

func (p *TxPool) Len() int

Get length of the `all` field

func (*TxPool) Remove ¶

func (p *TxPool) Remove(txHash thor.Bytes32, txID thor.Bytes32) bool

Remove removes tx from pool by its Hash.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL