mempool

type BlockTimer interface {
	// ResetBlockTimer schedules a timer to notify the consensus engine once
	// there is a block ready to be built. If a block is ready to be built when
	// this function is called, the engine will be notified directly.
	ResetBlockTimer()
}

type Mempool interface {
	// we may want to be able to stop valid transactions
	// from entering the mempool, e.g. during blocks creation
	EnableAdding()
	DisableAdding()

	Add(tx *txs.Tx) error
	Has(txID ids.ID) bool
	Get(txID ids.ID) *txs.Tx
	Remove(txs []*txs.Tx)

	// Following Blueberry activation, all mempool transactions,
	// (both decision and staker) are included into Standard blocks.
	// HasTxs allow to check for availability of any mempool transaction.
	HasTxs() bool
	// PeekTxs returns the next txs for Blueberry blocks
	// up to maxTxsBytes without removing them from the mempool.
	// It returns nil if !HasTxs()
	PeekTxs(maxTxsBytes int) []*txs.Tx

	HasStakerTx() bool
	// PeekStakerTx returns the next stakerTx without removing it from mempool.
	// It returns nil if !HasStakerTx().
	// It's guaranteed that the returned tx, if not nil, is a StakerTx.
	PeekStakerTx() *txs.Tx

	// Note: dropped txs are added to droppedTxIDs but not
	// not evicted from unissued decision/staker txs.
	// This allows previously dropped txs to be possibly
	// reissued.
	MarkDropped(txID ids.ID, reason string)
	GetDropReason(txID ids.ID) (string, bool)

	// Pre Blueberry activation, decision transactions are included into
	// standard blocks.
	HasApricotDecisionTxs() bool
	// PeekApricotDecisionTxs returns the next decisionTxs, up to maxTxsBytes,
	// without removing them from the mempool.
	// It returns nil if !HasApricotDecisionTxs()
	PeekApricotDecisionTxs(maxTxsBytes int) []*txs.Tx
}

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

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