mempool

type Config struct {
	// MaxTxs defines the maximum number of transactions that can be in the mempool.
	MaxTxs int `` /* 219-byte string literal not displayed */
}

type Iterator[T transaction.Tx] interface {
	// Next returns the next transaction from the mempool. If there are no more
	// transactions, it returns nil.
	Next() Iterator[T]

	// Tx returns the transaction at the current position of the iterator.
	Tx() T
}

type Mempool[T transaction.Tx] interface {
	// Insert attempts to insert a Tx into the app-side mempool returning
	// an error upon failure.
	Insert(context.Context, T) error

	// Select returns an Iterator over the app-side mempool. If txs are specified,
	// then they shall be incorporated into the Iterator. The Iterator is not thread-safe to use.
	Select(context.Context, []T) Iterator[T]

	// SelectBy use callback to iterate over the mempool, it's thread-safe to use.
	SelectBy(context.Context, []T, func(T) bool)

	// CountTx returns the number of transactions currently in the mempool.
	CountTx() int

	// Remove attempts to remove a transaction from the mempool, returning an error
	// upon failure.
	Remove(T) error
}

type NoOpMempool[T transaction.Tx] struct{}