Versions in this module Expand all Collapse all v0 v0.47.3 Aug 22, 2024 Changes in this version + var DefaultMaxTx = 0 + var ErrMempoolTxMaxCapacity = errors.New("pool reached max tx capacity") + var ErrTxNotFound = errors.New("tx not found in mempool") + func IsEmpty(mempool Mempool) error + type Iterator interface + Next func() Iterator + Tx func() sdk.Tx + type Mempool interface + CountTx func() int + Insert func(context.Context, sdk.Tx) error + Remove func(sdk.Tx) error + Select func(context.Context, [][]byte) Iterator + func DefaultPriorityMempool() Mempool + type NoOpMempool struct + func (NoOpMempool) CountTx() int + func (NoOpMempool) Insert(context.Context, sdk.Tx) error + func (NoOpMempool) Remove(sdk.Tx) error + func (NoOpMempool) Select(context.Context, [][]byte) Iterator + type PriorityNonceIterator struct + func (i *PriorityNonceIterator) Next() Iterator + func (i *PriorityNonceIterator) Tx() sdk.Tx + type PriorityNonceMempool struct + func NewPriorityMempool(opts ...PriorityNonceMempoolOption) *PriorityNonceMempool + func (mp *PriorityNonceMempool) CountTx() int + func (mp *PriorityNonceMempool) Insert(ctx context.Context, tx sdk.Tx) error + func (mp *PriorityNonceMempool) NextSenderTx(sender string) sdk.Tx + func (mp *PriorityNonceMempool) Remove(tx sdk.Tx) error + func (mp *PriorityNonceMempool) Select(_ context.Context, _ [][]byte) Iterator + type PriorityNonceMempoolOption func(*PriorityNonceMempool) + func PriorityNonceWithMaxTx(maxTx int) PriorityNonceMempoolOption + func PriorityNonceWithOnRead(onRead func(tx sdk.Tx)) PriorityNonceMempoolOption + func PriorityNonceWithTxReplacement(txReplacementRule func(op, np int64, oTx, nTx sdk.Tx) bool) PriorityNonceMempoolOption + type SenderNonceMempool struct + func NewSenderNonceMempool(opts ...SenderNonceOptions) *SenderNonceMempool + func (mp *SenderNonceMempool) NextSenderTx(sender string) sdk.Tx + func (snm *SenderNonceMempool) CountTx() int + func (snm *SenderNonceMempool) Insert(_ context.Context, tx sdk.Tx) error + func (snm *SenderNonceMempool) Remove(tx sdk.Tx) error + func (snm *SenderNonceMempool) Select(_ context.Context, _ [][]byte) Iterator + type SenderNonceOptions func(mp *SenderNonceMempool) + func SenderNonceMaxTxOpt(maxTx int) SenderNonceOptions + func SenderNonceSeedOpt(seed int64) SenderNonceOptions
Go to main page