mempool

Jan 18, 2024

Changes in this version

+ 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")

type Mempool

+ Iterate func(f func(tx *txs.Tx) bool)

+ Len func() int

type MockMempool

+ func (m *MockMempool) Iterate(arg0 func(*txs.Tx) bool)

+ func (m *MockMempool) Len() int

type MockMempoolMockRecorder

+ func (mr *MockMempoolMockRecorder) Iterate(arg0 any) *gomock.Call

+ func (mr *MockMempoolMockRecorder) Len() *gomock.Call

Mar 21, 2023

Changes in this version

type Mempool

+ RequestBuildBlock func()

+ type MockMempool struct

+ func NewMockMempool(ctrl *gomock.Controller) *MockMempool

+ func (m *MockMempool) Add(arg0 *txs.Tx) error

+ func (m *MockMempool) EXPECT() *MockMempoolMockRecorder

+ func (m *MockMempool) Get(arg0 ids.ID) *txs.Tx

+ func (m *MockMempool) GetDropReason(arg0 ids.ID) error

+ func (m *MockMempool) Has(arg0 ids.ID) bool

+ func (m *MockMempool) MarkDropped(arg0 ids.ID, arg1 error)

+ func (m *MockMempool) Peek(arg0 int) *txs.Tx

+ func (m *MockMempool) Remove(arg0 []*txs.Tx)

+ func (m *MockMempool) RequestBuildBlock()

+ type MockMempoolMockRecorder struct

+ func (mr *MockMempoolMockRecorder) Add(arg0 interface{}) *gomock.Call

+ func (mr *MockMempoolMockRecorder) Get(arg0 interface{}) *gomock.Call

+ func (mr *MockMempoolMockRecorder) GetDropReason(arg0 interface{}) *gomock.Call

+ func (mr *MockMempoolMockRecorder) Has(arg0 interface{}) *gomock.Call

+ func (mr *MockMempoolMockRecorder) MarkDropped(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockMempoolMockRecorder) Peek(arg0 interface{}) *gomock.Call

+ func (mr *MockMempoolMockRecorder) Remove(arg0 interface{}) *gomock.Call

+ func (mr *MockMempoolMockRecorder) RequestBuildBlock() *gomock.Call

Feb 21, 2023

Changes in this version

+ const MaxTxSize

+ type BlockTimer interface

+ ResetBlockTimer func()

+ type Mempool interface

+ Add func(tx *txs.Tx) error

+ Get func(txID ids.ID) *txs.Tx

+ GetDropReason func(txID ids.ID) (string, bool)

+ Has func(txID ids.ID) bool

+ HasTxs func() bool

+ MarkDropped func(txID ids.ID, reason string)

+ Peek func(maxTxSize int) *txs.Tx

+ Remove func(txs []*txs.Tx)

+ func New(namespace string, registerer prometheus.Registerer, blkTimer BlockTimer) (Mempool, error)