txpool

package

v2.1.1 Latest Latest Go to latest Published: Apr 17, 2024 License: LGPL-3.0 Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vechain/thor

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

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 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) *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) 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) 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