mempool

package

v0.10.0-beta-1 Latest Latest Go to latest Published: Jan 27, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CheckFn func(ctx context.Context, tx *ktypes.Transaction) error

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

func New() *Mempool

func (mp *Mempool) Get(txid types.Hash) *ktypes.Transaction

func (mp *Mempool) Have(txid types.Hash) bool

func (mp *Mempool) PeekN(n int) []types.NamedTx

func (mp *Mempool) PreFetch(txid types.Hash) bool

func (mp *Mempool) ReapN(n int) []types.NamedTx

ReapN extracts the first n transactions in the queue

func (mp *Mempool) RecheckTxs(ctx context.Context, fn CheckFn)

func (mp *Mempool) Remove(txid types.Hash)

func (mp *Mempool) Size() int

func (mp *Mempool) Store(txid types.Hash, tx *ktypes.Transaction)

func (mp *Mempool) TxsAvailable() bool