mempool

Documentation

Overview

mempool implements a buffer of requests sent to the ISC chain, essentially a backlog of requests It contains both on-ledger and off-ledger requests. The mempool consists of 2 parts: the in-buffer and the pool All incoming requests are stored into the in-buffer first. Then they are asynchronously validated and moved to the pool itself.

Index

• type Mempool
  • func New(chainAddress iotago.Address, stateReader state.OptimisticStateReader, ...) Mempool
• type MempoolInfo

Types

type Mempool

type Mempool interface {
	ReceiveRequests(reqs ...isc.Request)
	ReceiveRequest(req isc.Request) bool
	RemoveRequests(reqs ...isc.RequestID)
	ReadyNow(currentTime time.Time) []isc.Request
	ReadyFromIDs(currentTime time.Time, reqIDs ...isc.RequestID) ([]isc.Request, []int, bool)
	HasRequest(id isc.RequestID) bool
	GetRequest(id isc.RequestID) isc.Request
	Info(currentTime time.Time) MempoolInfo
	WaitRequestInPool(reqid isc.RequestID, timeout ...time.Duration) bool // for testing
	WaitInBufferEmpty(timeout ...time.Duration) bool                      // for testing
	WaitPoolEmpty(timeout ...time.Duration) bool                          // for testing
	Close()
}

func New

func New(
	chainAddress iotago.Address,
	stateReader state.OptimisticStateReader,
	log *logger.Logger,
	mempoolMetrics metrics.MempoolMetrics,
) Mempool

type MempoolInfo

type MempoolInfo struct {
	TotalPool      int
	ReadyCounter   int
	InBufCounter   int
	OutBufCounter  int
	InPoolCounter  int
	OutPoolCounter int
}