Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.TxSubmission.Inbound.V2

Contents

TxSubmision Inbound client
Supporting types and APIs

Synopsis

txSubmissionInboundV2 :: forall txid tx idx (m :: Type -> Type). (MonadDelay m, MonadThrow m, Ord txid) => Tracer m (TraceTxSubmissionInbound txid tx) -> TxSubmissionInitDelay -> TxSubmissionMempoolWriter txid tx idx m -> PeerTxAPI m txid tx -> TxSubmissionServerPipelined txid tx m ()
module Ouroboros.Network.TxSubmission.Inbound.V2.Registry
module Ouroboros.Network.TxSubmission.Inbound.V2.Types
data TxDecisionPolicy = TxDecisionPolicy {
- maxNumTxIdsToRequest :: !NumTxIdsToReq
- maxUnacknowledgedTxIds :: !NumTxIdsToReq
- txsSizeInflightPerPeer :: !SizeInBytes
- maxTxsSizeInflight :: !SizeInBytes
- txInflightMultiplicity :: !Int
- bufferedTxsMinLifetime :: !DiffTime
- scoreRate :: !Double
- scoreMax :: !Double
}
defaultTxDecisionPolicy :: TxDecisionPolicy

TxSubmision Inbound client

txSubmissionInboundV2 :: forall txid tx idx (m :: Type -> Type). (MonadDelay m, MonadThrow m, Ord txid) => Tracer m (TraceTxSubmissionInbound txid tx) -> TxSubmissionInitDelay -> TxSubmissionMempoolWriter txid tx idx m -> PeerTxAPI m txid tx -> TxSubmissionServerPipelined txid tx m () Source #

A tx-submission inbound side (server, sic!).

The server blocks on receiving TxDecision from the decision logic. If there are tx's to download it pipelines two requests: first for tx's second for txid's. If there are no tx's to download, it either sends a blocking or non-blocking request for txid's.

Supporting types and APIs

module Ouroboros.Network.TxSubmission.Inbound.V2.Registry

module Ouroboros.Network.TxSubmission.Inbound.V2.Types

data TxDecisionPolicy Source #

Policy for making decisions

Constructors

TxDecisionPolicy

Fields

maxNumTxIdsToRequest :: !NumTxIdsToReq
a maximal number of txids requested at once.
maxUnacknowledgedTxIds :: !NumTxIdsToReq
maximal number of unacknowledgedTxIds. Measured in NumTxIdsToReq since we enforce this policy by requesting not more txids than what this limit allows.
txsSizeInflightPerPeer :: !SizeInBytes
a limit of tx size in-flight from a single peer. It can be exceed by max tx size.
maxTxsSizeInflight :: !SizeInBytes
a limit of tx size in-flight from all peers. It can be exceed by max tx size.
txInflightMultiplicity :: !Int
from how many peers download the txid simultaneously
bufferedTxsMinLifetime :: !DiffTime
how long TXs that have been added to the mempool will be kept in the bufferedTxs cache.
scoreRate :: !Double
rate at which "rejected" TXs drain. Unit: TX/seconds.
scoreMax :: !Double
Maximum number of "rejections". Unit: seconds

Instances

Instances details

NFData TxDecisionPolicy Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Policy Methods rnf :: TxDecisionPolicy -> () #
Show TxDecisionPolicy Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Policy Methods showsPrec :: Int -> TxDecisionPolicy -> ShowS # show :: TxDecisionPolicy -> String # showList :: [TxDecisionPolicy] -> ShowS #

defaultTxDecisionPolicy :: TxDecisionPolicy Source #