Versions in this module Expand all Collapse all v1 v1.11.10 Jul 13, 2024 Changes in this version + const MaxTxSize + var ErrConflictsWithOtherTx = errors.New("tx conflicts with other tx") + var ErrDuplicateTx = errors.New("duplicate tx") + var ErrMempoolFull = errors.New("mempool is full") + var ErrTxTooLarge = errors.New("tx too large") + func NewMetrics(namespace string, registerer prometheus.Registerer) (*metrics, error) + func New[T Tx](metrics Metrics) *mempool[T] + type Mempool interface + Add func(tx T) error + Get func(txID ids.ID) (T, bool) + GetDropReason func(txID ids.ID) error + Iterate func(f func(tx T) bool) + Len func() int + MarkDropped func(txID ids.ID, reason error) + Peek func() (tx T, exists bool) + Remove func(txs ...T) + type Metrics interface + Update func(numTxs, bytesAvailable int) + type Tx interface + ID func() ids.ID + InputIDs func() set.Set[ids.ID] + Size func() int
Go to main page