txpool

package

v0.0.0-...-75aef46 Latest Latest Go to latest Published: Aug 27, 2019 License: GPL-3.0 Imports: 19 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

This section is empty.

This section is empty.

func IsBadTx(err error) bool

IsBadTx returns whether the given error indicates that tx is bad.

func IsTxRejected(err error) bool

IsTxRejected returns whether the given error indicates tx is rejected.

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

Options options for tx pool.

type TxEvent struct {
	Tx         *tx.Transaction
	Executable *bool
}

TxEvent will be posted when tx is added or status changed.

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

TxPool maintains unprocessed transactions.

func New(chain *chain.Chain, stateCreator *state.Creator, options Options) *TxPool

New create a new TxPool instance. Shutdown is required to be called at end.

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 (p *TxPool) Close()

Close cleanup inner go routines.

func (p *TxPool) Dump() tx.Transactions

Dump dumps all txs in the pool.

func (p *TxPool) Executables() tx.Transactions

Executables returns executable txs.

func (p *TxPool) Fill(txs tx.Transactions)

Fill fills txs into pool.

func (p *TxPool) Remove(txID powerplay.Bytes32) bool

Remove removes tx from pool by its ID.

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 (p *TxPool) SubscribeTxEvent(ch chan *TxEvent) event.Subscription

SubscribeTxEvent receivers will receive a tx