Ouroboros.Network.TxSubmission.Inbound.V2 · ouroboros-network-1.2.0.0

:: (MonadMask m, MonadTimer m, Ord peeraddr, Show peeraddr, Ord txid, HasRawTxId txid)
=> TxDecisionPolicy
-> TxSubmissionMempoolReader txid tx idx m
-> SharedTxStateVar m peeraddr txid
-> PeerTxRegistry m peeraddr
-> TxSubmissionCountersVar m
-> peeraddr
-> PeerTxAPI m txid tx -> m a
-> m a

#

valueconst_MAX_TX_SIZE_DISCREPANCY :: SizeInBytes

#

valuedefaultTxSubmissionInitDelay :: TxSubmissionInitDelay

#

valuediffTimeToMilliseconds :: DiffTime -> Word64

#

valueemptyPeerScore :: Time -> PeerScore

#

valueemptyPeerTxInFlight :: PeerTxInFlight

#

valueemptyPeerTxLocalState :: PeerTxLocalState tx

#

valueemptySharedTxState :: SharedTxState peeraddr txid

#

valueinternTxId

:: HasRawTxId txid
=> txid
-> SharedTxState peeraddr txid
-> (RawTxId txid, TxKey, SharedTxState peeraddr txid)

#

valueinternTxIds

:: (Foldable f, HasRawTxId txid)
=> f txid
-> SharedTxState peeraddr txid
-> (Map (RawTxId txid) TxKey, SharedTxState peeraddr txid)

#

valuelookupTxKey

:: HasRawTxId txid
=> txid
-> SharedTxState peeraddr txid
-> Maybe TxKey

#

valueresolveTxKey :: HasCallStack => SharedTxState peeraddr txid -> TxKey -> txid

#

valueretainedDeleteKeys :: IntSet -> RetainedTxs -> RetainedTxs

#

valueretainedEmpty :: RetainedTxs

#

valueretainedExpiredKeys :: Time -> RetainedTxs -> IntSet

#

valueretainedFromList :: [(Int, Time)] -> RetainedTxs

#

valueretainedInsertMax :: Int -> Time -> RetainedTxs -> RetainedTxs

#

valueretainedKeysSet :: RetainedTxs -> IntSet

#

valueretainedLookup :: Int -> RetainedTxs -> Maybe Time

#

valueretainedMember :: Int -> RetainedTxs -> Bool

#

valueretainedRestrictKeys :: RetainedTxs -> IntSet -> RetainedTxs

#

valueretainedSingleton :: Int -> Time -> RetainedTxs

#

valueretainedSize :: RetainedTxs -> Int

#

valueretainedToList :: RetainedTxs -> [(Int, Time)]

#

newtypenewtype RegisteredDelay (m :: Type -> Type)

#

datadata TxDecisionPolicy

#

Constructors

TxDecisionPolicy
- maxNumTxIdsToRequest :: !NumTxIdsToReq
- maxUnacknowledgedTxIds :: !NumTxIdsToReq
- txsSizeInflightPerPeer :: !SizeInBytes
- maxOutstandingTxBatchesPerPeer :: !Int
- txInflightMultiplicity :: !Int
- bufferedTxsMinLifetime :: !DiffTime
- scoreRate :: !Double
- scoreMax :: !Double
- scoreAcceptDecrement :: !Double
- interTxSpace :: !DiffTime
- inflightTimeout :: !DiffTime
- maxPeerClaimDelay :: !DiffTime
- disablePipelinedTxIdRequests :: !Bool

Instances3Eq, Show, NFData

Eq TxDecisionPolicyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Policy
Show TxDecisionPolicyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Policy
NFData TxDecisionPolicyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Policy

datadata PeerTxAPI (m :: Type -> Type) txid tx

#

Constructors

PeerTxAPI
- awaitSharedChange :: Word64 -> Maybe (RegisteredDelay m) -> STM m ()
- runNextPeerAction :: Time -> PeerTxLocalState tx -> m (PeerAction, PeerTxLocalState tx)
- runNextPeerActionPipelined :: Time -> PeerTxLocalState tx -> m (PeerAction, PeerTxLocalState tx)
- applyReceivedTxIds :: Time -> NumTxIdsToReq -> [(txid, SizeInBytes)] -> PeerTxLocalState tx -> m (PeerTxLocalState tx)
- applyReceivedTxs :: Time -> [(txid, tx)] -> PeerTxLocalState tx -> m (Int, PeerTxLocalState tx)
- applySubmittedTxs :: Time -> [TxKey] -> [TxKey] -> PeerTxLocalState tx -> m (PeerTxLocalState tx)
- resolveTxRequest :: PeerTxLocalState tx -> [TxKey] -> m (Map txid SizeInBytes)
- resolveBufferedTxs :: PeerTxLocalState tx -> [TxKey] -> m [(TxKey, txid, tx)]
- addCounters :: TxSubmissionCounters -> m ()

type

type PeerTxRegistry (m :: Type -> Type) peeraddr = StrictTVar m (Map peeraddr (PeerTxInFlightVar m, TxSubmissionCountersVar m))

#

typetype SharedTxStateVar (m :: Type -> Type) peeraddr txid = StrictTVar m (SharedTxState peeraddr txid)

#

typetype TxSubmissionCountersVar (m :: Type -> Type) = StrictTVar m TxSubmissionCounters

#

datadata PeerAction

#

Constructors

PeerDoNothing !Word64 !(Maybe DiffTime)
PeerRequestTxIds !NumTxIdsToAck !NumTxIdsToReq
PeerRequestTxs ![TxKey]
PeerSubmitTxs ![TxKey]

Instances5Eq, Show, Generic, NFData, Rep

Eq PeerActionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show PeerActionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic PeerActionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData PeerActionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep PeerAction = D1 ('MetaData "PeerAction" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) ((C1 ('MetaCons "PeerDoNothing" 'PrefixI 'False) (S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (Maybe DiffTime))) :+: C1 ('MetaCons "PeerRequestTxIds" 'PrefixI 'False) (S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 NumTxIdsToAck) :*: S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 NumTxIdsToReq))) :+: (C1 ('MetaCons "PeerRequestTxs" 'PrefixI 'False) (S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 [TxKey])) :+: C1 ('MetaCons "PeerSubmitTxs" 'PrefixI 'False) (S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 [TxKey]))))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata PeerPhase

#

PeerIdle PeerWaitingTxIds PeerWaitingTxs PeerSubmittingToMempool

Instances7Eq, Ord, Show, Generic, NFData, NoThunks, …

Eq PeerPhaseDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Ord PeerPhaseDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show PeerPhaseDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic PeerPhaseDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData PeerPhaseDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks PeerPhaseDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep PeerPhase = D1 ('MetaData "PeerPhase" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) ((C1 ('MetaCons "PeerIdle" 'PrefixI 'False) U1 :+: C1 ('MetaCons "PeerWaitingTxIds" 'PrefixI 'False) U1) :+: (C1 ('MetaCons "PeerWaitingTxs" 'PrefixI 'False) U1 :+: C1 ('MetaCons "PeerSubmittingToMempool" 'PrefixI 'False) U1))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata PeerScore

#

Constructors

PeerScore
- peerScoreValue :: !Double
- peerScoreTs :: !Time

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

Eq PeerScoreDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show PeerScoreDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic PeerScoreDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData PeerScoreDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks PeerScoreDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep PeerScore = D1 ('MetaData "PeerScore" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "PeerScore" 'PrefixI 'True) (S1 ('MetaSel ('Just "peerScoreValue") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Double) :*: S1 ('MetaSel ('Just "peerScoreTs") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Time)))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata PeerTxInFlight

#

Constructors

PeerTxInFlight
- pifAdvertised :: !IntSet
- pifLeased :: !IntSet
- pifAttempting :: !IntSet
- pifSubmitting :: !IntSet
- pifAcksPending :: !IntSet

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

Eq PeerTxInFlightDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show PeerTxInFlightDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic PeerTxInFlightDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData PeerTxInFlightDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks PeerTxInFlightDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep PeerTxInFlight = D1 ('MetaData "PeerTxInFlight" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "PeerTxInFlight" 'PrefixI 'True) ((S1 ('MetaSel ('Just "pifAdvertised") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet) :*: S1 ('MetaSel ('Just "pifLeased") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet)) :*: (S1 ('MetaSel ('Just "pifAttempting") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet) :*: (S1 ('MetaSel ('Just "pifSubmitting") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet) :*: S1 ('MetaSel ('Just "pifAcksPending") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet)))))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata PeerTxLocalState tx

#

Constructors

PeerTxLocalState
- peerPhase :: !PeerPhase
- peerUnacknowledgedTxIds :: !StrictSeq TxKey
- peerAvailableTxIds :: !IntMap SizeInBytes
- peerRequestedTxs :: !IntSet
- peerRequestedTxBatches :: !StrictSeq RequestedTxBatch
- peerRequestedTxsSize :: !SizeInBytes
- peerRequestedTxIds :: !NumTxIdsToReq
- peerDownloadedTxs :: !IntMap tx
- peerDownloadStartTime :: !Maybe Time
- peerScore :: !PeerScore
- peerLastTxIdReplyWasEmpty :: !Bool

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

Eq tx => Eq (PeerTxLocalState tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show tx => Show (PeerTxLocalState tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic (PeerTxLocalState tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData tx => NFData (PeerTxLocalState tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks tx => NoThunks (PeerTxLocalState tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep (PeerTxLocalState tx) = D1 ('MetaData "PeerTxLocalState" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "PeerTxLocalState" 'PrefixI 'True) (((S1 ('MetaSel ('Just "peerPhase") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 PeerPhase) :*: S1 ('MetaSel ('Just "peerUnacknowledgedTxIds") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (StrictSeq TxKey))) :*: (S1 ('MetaSel ('Just "peerAvailableTxIds") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (IntMap SizeInBytes)) :*: (S1 ('MetaSel ('Just "peerRequestedTxs") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet) :*: S1 ('MetaSel ('Just "peerRequestedTxBatches") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (StrictSeq RequestedTxBatch))))) :*: ((S1 ('MetaSel ('Just "peerRequestedTxsSize") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 SizeInBytes) :*: (S1 ('MetaSel ('Just "peerRequestedTxIds") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 NumTxIdsToReq) :*: S1 ('MetaSel ('Just "peerDownloadedTxs") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (IntMap tx)))) :*: (S1 ('MetaSel ('Just "peerDownloadStartTime") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (Maybe Time)) :*: (S1 ('MetaSel ('Just "peerScore") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 PeerScore) :*: S1 ('MetaSel ('Just "peerLastTxIdReplyWasEmpty") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Bool))))))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata ProcessedTxCount

#

Constructors

ProcessedTxCount
- ptxcAccepted :: Int
- ptxcRejected :: Int
- ptxcScore :: Double

Instances2Eq, Show

Eq ProcessedTxCountDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show ProcessedTxCountDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata RequestedTxBatch

#

Constructors

RequestedTxBatch
- requestedTxBatchSet :: !IntSet
- requestedTxBatchSize :: !SizeInBytes

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

Eq RequestedTxBatchDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show RequestedTxBatchDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic RequestedTxBatchDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData RequestedTxBatchDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks RequestedTxBatchDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep RequestedTxBatch = D1 ('MetaData "RequestedTxBatch" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "RequestedTxBatch" 'PrefixI 'True) (S1 ('MetaSel ('Just "requestedTxBatchSet") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet) :*: S1 ('MetaSel ('Just "requestedTxBatchSize") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 SizeInBytes)))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata RetainedTxs

#

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

Eq RetainedTxsDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show RetainedTxsDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic RetainedTxsDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData RetainedTxsDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks RetainedTxsDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep RetainedTxs = D1 ('MetaData "RetainedTxs" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "RetainedTxs" 'PrefixI 'True) (S1 ('MetaSel ('Just "retainedQueue") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (IntPSQ Time ())) :*: S1 ('MetaSel ('Just "retainedSet") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 IntSet)))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata SharedTxState peeraddr txid

#

Constructors

SharedTxState
- sharedTxTable :: !IntMap (TxEntry peeraddr)
- sharedRetainedTxs :: !RetainedTxs
- sharedTxIdToKey :: !Map (RawTxId txid) TxKey
- sharedKeyToTxId :: !IntMap txid
- sharedNextTxKey :: !Int
- sharedGeneration :: !Word64
- sharedRevision :: !Word64

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

(Eq peeraddr, Eq txid, HasRawTxId txid) => Eq (SharedTxState peeraddr txid)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
(Show peeraddr, Show txid, HasRawTxId txid) => Show (SharedTxState peeraddr txid)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic (SharedTxState peeraddr txid)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
(NFData peeraddr, NFData txid, HasRawTxId txid) => NFData (SharedTxState peeraddr txid)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
(NoThunks peeraddr, NoThunks txid, HasRawTxId txid) => NoThunks (SharedTxState peeraddr txid)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep (SharedTxState peeraddr txid) = D1 ('MetaData "SharedTxState" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "SharedTxState" 'PrefixI 'True) ((S1 ('MetaSel ('Just "sharedTxTable") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (IntMap (TxEntry peeraddr))) :*: (S1 ('MetaSel ('Just "sharedRetainedTxs") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RetainedTxs) :*: S1 ('MetaSel ('Just "sharedTxIdToKey") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (Map (RawTxId txid) TxKey)))) :*: ((S1 ('MetaSel ('Just "sharedKeyToTxId") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (IntMap txid)) :*: S1 ('MetaSel ('Just "sharedNextTxKey") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Int)) :*: (S1 ('MetaSel ('Just "sharedGeneration") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "sharedRevision") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64)))))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TraceTxLogic peeraddr txid tx

#

Constructors

TraceSharedTxState (SharedTxState peeraddr txid)

Instances1Show

(HasRawTxId txid, Show peeraddr, Show txid) => Show (TraceTxLogic peeraddr txid tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TraceTxSubmissionInbound txid tx

#

Constructors

TraceTxSubmissionCollected [txid]
TraceTxSubmissionProcessed ProcessedTxCount
TraceTxInboundCanRequestMoreTxs Int
TraceTxInboundCannotRequestMoreTxs Int
TraceTxInboundAddedToMempool [txid] DiffTime
TraceTxInboundRejectedFromMempool [txid] DiffTime
TraceTxInboundError TxSubmissionProtocolError
TraceTxInboundRequestTxs [txid]
TraceTxInboundTerminated

Instances2Eq, Show

Eq txid => Eq (TraceTxSubmissionInbound txid tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show txid => Show (TraceTxSubmissionInbound txid tx)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TxEntry peeraddr

#

Constructors

TxEntry
- txLease :: !TxLease peeraddr
- txAttempt :: !Int
- txInSubmission :: !Bool
- currentMaxInflightMultiplicity :: !Int

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

Eq peeraddr => Eq (TxEntry peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show peeraddr => Show (TxEntry peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic (TxEntry peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData peeraddr => NFData (TxEntry peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks peeraddr => NoThunks (TxEntry peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep (TxEntry peeraddr) = D1 ('MetaData "TxEntry" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "TxEntry" 'PrefixI 'True) ((S1 ('MetaSel ('Just "txLease") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (TxLease peeraddr)) :*: S1 ('MetaSel ('Just "txAttempt") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Int)) :*: (S1 ('MetaSel ('Just "txInSubmission") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Bool) :*: S1 ('MetaSel ('Just "currentMaxInflightMultiplicity") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Int))))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

newtypenewtype TxKey

#

Constructors

TxKey
- unTxKey :: Int

Instances8Enum, Eq, Ord, Show, Generic, NFData, …

Enum TxKeyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Eq TxKeyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Ord TxKeyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show TxKeyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic TxKeyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData TxKeyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks TxKeyDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep TxKey = D1 ('MetaData "TxKey" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'True) (C1 ('MetaCons "TxKey" 'PrefixI 'True) (S1 ('MetaSel ('Just "unTxKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TxLease peeraddr

#

Constructors

TxLeased !peeraddr !Time
TxClaimable !Time

Instances6Eq, Show, Generic, NFData, NoThunks, Rep

Eq peeraddr => Eq (TxLease peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show peeraddr => Show (TxLease peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic (TxLease peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData peeraddr => NFData (TxLease peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NoThunks peeraddr => NoThunks (TxLease peeraddr)Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep (TxLease peeraddr) = D1 ('MetaData "TxLease" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "TxLeased" 'PrefixI 'False) (S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 peeraddr) :*: S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Time)) :+: C1 ('MetaCons "TxClaimable" 'PrefixI 'False) (S1 ('MetaSel 'Nothing 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Time)))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TxSubmissionCounters

#

Constructors

TxSubmissionCounters
- txIdMessagesSent :: !Word64
- txIdsRequested :: !Word64
- txIdRepliesReceived :: !Word64
- txIdsReceived :: !Word64
- txMessagesSent :: !Word64
- txsRequested :: !Word64
- txRepliesReceived :: !Word64
- txsReceived :: !Word64
- txsOmitted :: !Word64
- lateBodies :: !Word64
- txsAccepted :: !Word64
- txsRejected :: !Word64
- txIdBlockingReqsSent :: !Word64
- txIdPipelinedReqsSent :: !Word64
- txIdBlockingWaitMs :: !Word64
- txPipelineWaitMs :: !Word64
- txSubmissionWaitMs :: !Word64

Instances7Eq, Show, Generic, Semigroup, Monoid, NFData, …

Eq TxSubmissionCountersDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show TxSubmissionCountersDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Generic TxSubmissionCountersDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Semigroup TxSubmissionCountersDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Monoid TxSubmissionCountersDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
NFData TxSubmissionCountersDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
type Rep TxSubmissionCounters = D1 ('MetaData "TxSubmissionCounters" "Ouroboros.Network.TxSubmission.Inbound.V2.Types" "ouroboros-network-1.2.0.0-BKx8UGQx7KUA5sWrctWXNN" 'False) (C1 ('MetaCons "TxSubmissionCounters" 'PrefixI 'True) ((((S1 ('MetaSel ('Just "txIdMessagesSent") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "txIdsRequested") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64)) :*: (S1 ('MetaSel ('Just "txIdRepliesReceived") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "txIdsReceived") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64))) :*: ((S1 ('MetaSel ('Just "txMessagesSent") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "txsRequested") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64)) :*: (S1 ('MetaSel ('Just "txRepliesReceived") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "txsReceived") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64)))) :*: (((S1 ('MetaSel ('Just "txsOmitted") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "lateBodies") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64)) :*: (S1 ('MetaSel ('Just "txsAccepted") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "txsRejected") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64))) :*: ((S1 ('MetaSel ('Just "txIdBlockingReqsSent") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "txIdPipelinedReqsSent") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64)) :*: (S1 ('MetaSel ('Just "txIdBlockingWaitMs") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: (S1 ('MetaSel ('Just "txPipelineWaitMs") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64) :*: S1 ('MetaSel ('Just "txSubmissionWaitMs") 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Word64)))))))Defined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TxSubmissionInitDelay

#

Constructors

Instances2Eq, Show

Eq TxSubmissionInitDelayDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show TxSubmissionInitDelayDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TxSubmissionLogicVersion

#

TxSubmissionLogicV1 TxSubmissionLogicV2

Instances4Bounded, Enum, Eq, Show

Bounded TxSubmissionLogicVersionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Enum TxSubmissionLogicVersionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Eq TxSubmissionLogicVersionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show TxSubmissionLogicVersionDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types

datadata TxSubmissionMempoolWriter txid tx idx (m :: Type -> Type) err

#

Constructors

TxSubmissionMempoolWriter
- txId :: tx -> txid
- mempoolAddTxs :: [tx] -> m ([txid], [(txid, err)])

datadata TxSubmissionProtocolError

#

Constructors

ProtocolErrorTxNotRequested
ProtocolErrorTxIdsNotRequested
forall txid. (Typeable txid, Show txid, Eq txid) => ProtocolErrorTxSizeError [(txid, SizeInBytes, SizeInBytes)]

Instances3Eq, Show, Exception

Eq TxSubmissionProtocolErrorDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Show TxSubmissionProtocolErrorDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types
Exception TxSubmissionProtocolErrorDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.TxSubmission.Inbound.V2.Types