Safe Haskell	None
Language	Haskell2010

Ouroboros.Consensus.Mempool.Impl

Contents

For testing purposes

Synopsis

openMempool :: (IOLike m, LedgerSupportsMempool blk, HasTxId (GenTx blk), ValidateEnvelope blk) => ResourceRegistry m -> LedgerInterface m blk -> LedgerConfig blk -> MempoolCapacityBytesOverride -> Tracer m (TraceEventMempool blk) -> (GenTx blk -> TxSizeInBytes) -> m (Mempool m blk TicketNo)
data MempoolCapacityBytesOverride
- = NoMempoolCapacityBytesOverride
- | MempoolCapacityBytesOverride !MempoolCapacityBytes
data LedgerInterface m blk = LedgerInterface {
- getCurrentLedgerState :: STM m (LedgerState blk)
}
chainDBLedgerInterface :: IOLike m => ChainDB m blk -> LedgerInterface m blk
data TicketNo
openMempoolWithoutSyncThread :: (IOLike m, LedgerSupportsMempool blk, HasTxId (GenTx blk), ValidateEnvelope blk) => LedgerInterface m blk -> LedgerConfig blk -> MempoolCapacityBytesOverride -> Tracer m (TraceEventMempool blk) -> (GenTx blk -> TxSizeInBytes) -> m (Mempool m blk TicketNo)

Documentation

openMempool :: (IOLike m, LedgerSupportsMempool blk, HasTxId (GenTx blk), ValidateEnvelope blk) => ResourceRegistry m -> LedgerInterface m blk -> LedgerConfig blk -> MempoolCapacityBytesOverride -> Tracer m (TraceEventMempool blk) -> (GenTx blk -> TxSizeInBytes) -> m (Mempool m blk TicketNo) Source #

data MempoolCapacityBytesOverride Source #

An override for the default MempoolCapacityBytes which is 2x the maximum transaction capacity (see MaxTxCapacityOverride)

Constructors

NoMempoolCapacityBytesOverride	Use 2x the maximum transaction capacity of a block. This will change dynamically with the protocol parameters adopted in the current ledger.
MempoolCapacityBytesOverride !MempoolCapacityBytes	Use the following `MempoolCapacityBytes`.

Instances

Instances details

Eq MempoolCapacityBytesOverride Source #
Instance details Defined in Ouroboros.Consensus.Mempool.Impl Methods (==) :: MempoolCapacityBytesOverride -> MempoolCapacityBytesOverride -> Bool # (/=) :: MempoolCapacityBytesOverride -> MempoolCapacityBytesOverride -> Bool #
Show MempoolCapacityBytesOverride Source #
Instance details Defined in Ouroboros.Consensus.Mempool.Impl Methods showsPrec :: Int -> MempoolCapacityBytesOverride -> ShowS # show :: MempoolCapacityBytesOverride -> String # showList :: [MempoolCapacityBytesOverride] -> ShowS #

data LedgerInterface m blk Source #

Abstract interface needed to run a Mempool.

Constructors

LedgerInterface
Fields getCurrentLedgerState :: STM m (LedgerState blk)

chainDBLedgerInterface :: IOLike m => ChainDB m blk -> LedgerInterface m blk Source #

Create a LedgerInterface from a ChainDB.

data TicketNo Source #

We allocate each transaction a (monotonically increasing) ticket number as it enters the mempool.

Instances

Instances details

Bounded TicketNo Source #
Instance details Defined in Ouroboros.Consensus.Mempool.TxSeq Methods minBound :: TicketNo # maxBound :: TicketNo #
Enum TicketNo Source #
Instance details Defined in Ouroboros.Consensus.Mempool.TxSeq Methods succ :: TicketNo -> TicketNo # pred :: TicketNo -> TicketNo # toEnum :: Int -> TicketNo # fromEnum :: TicketNo -> Int # enumFrom :: TicketNo -> [TicketNo] # enumFromThen :: TicketNo -> TicketNo -> [TicketNo] # enumFromTo :: TicketNo -> TicketNo -> [TicketNo] # enumFromThenTo :: TicketNo -> TicketNo -> TicketNo -> [TicketNo] #
Eq TicketNo Source #
Instance details Defined in Ouroboros.Consensus.Mempool.TxSeq Methods (==) :: TicketNo -> TicketNo -> Bool # (/=) :: TicketNo -> TicketNo -> Bool #
Ord TicketNo Source #
Instance details Defined in Ouroboros.Consensus.Mempool.TxSeq Methods compare :: TicketNo -> TicketNo -> Ordering # (<) :: TicketNo -> TicketNo -> Bool # (<=) :: TicketNo -> TicketNo -> Bool # (>) :: TicketNo -> TicketNo -> Bool # (>=) :: TicketNo -> TicketNo -> Bool # max :: TicketNo -> TicketNo -> TicketNo # min :: TicketNo -> TicketNo -> TicketNo #
Show TicketNo Source #
Instance details Defined in Ouroboros.Consensus.Mempool.TxSeq Methods showsPrec :: Int -> TicketNo -> ShowS # show :: TicketNo -> String # showList :: [TicketNo] -> ShowS #
NoThunks TicketNo Source #
Instance details Defined in Ouroboros.Consensus.Mempool.TxSeq Methods noThunks :: Context -> TicketNo -> IO (Maybe ThunkInfo) Source # wNoThunks :: Context -> TicketNo -> IO (Maybe ThunkInfo) Source # showTypeOf :: Proxy TicketNo -> String Source #

For testing purposes

openMempoolWithoutSyncThread :: (IOLike m, LedgerSupportsMempool blk, HasTxId (GenTx blk), ValidateEnvelope blk) => LedgerInterface m blk -> LedgerConfig blk -> MempoolCapacityBytesOverride -> Tracer m (TraceEventMempool blk) -> (GenTx blk -> TxSizeInBytes) -> m (Mempool m blk TicketNo) Source #

Unlike openMempool, this function does not fork a background thread that synchronises with the ledger state whenever the later changes.

Intended for testing purposes.