Moduleouroboros-network-1.2.0.0

Ouroboros.Network.TxSubmission.Inbound.V2

Synopsis

value txSubmissionInboundV2
value defaultTxDecisionPolicy
value newPeerTxRegistry
value newSharedTxStateVar
value newTxSubmissionCountersVar
value txCountersThreadV2
value withPeer
value const_MAX_TX_SIZE_DISCREPANCY
value defaultTxSubmissionInitDelay
value diffTimeToMilliseconds
value emptyPeerScore
value emptyPeerTxInFlight
value emptyPeerTxLocalState
value emptySharedTxState
value internTxId
value internTxIds
value lookupTxKey
value resolveTxKey
value retainedDeleteKeys
value retainedEmpty
value retainedExpiredKeys
value retainedFromList
value retainedInsertMax
value retainedKeysSet
value retainedLookup
value retainedMember
value retainedRestrictKeys
value retainedSingleton
value retainedSize
value retainedToList
newtype RegisteredDelay
data TxDecisionPolicy
data PeerTxAPI
type PeerTxRegistry
type SharedTxStateVar
type TxSubmissionCountersVar
data PeerAction
data PeerPhase
data PeerScore
data PeerTxInFlight
data PeerTxLocalState
data ProcessedTxCount
data RequestedTxBatch
data RetainedTxs
data SharedTxState
data TraceTxLogic
data TraceTxSubmissionInbound
data TxEntry
newtype TxKey
data TxLease
data TxSubmissionCounters
data TxSubmissionInitDelay
data TxSubmissionLogicVersion
data TxSubmissionMempoolWriter
data TxSubmissionProtocolError

Packageouroboros-network-1.2.0.0
Exports55
LicenceApache-2.0

valuetxSubmissionInboundV2

:: (MonadDelay m, MonadTimer m, MonadThrow m, Ord txid, Show txid, Typeable txid)
=> Tracer m (TraceTxSubmissionInbound txid tx)
-> TxSubmissionInitDelay
-> TxDecisionPolicy
-> TxSubmissionMempoolWriter txid tx idx m err
-> tx -> SizeInBytes
-> PeerTxAPI m txid tx
-> TxSubmissionServerPipelined txid tx m ()

valuedefaultTxDecisionPolicy :: TxDecisionPolicy

valuenewPeerTxRegistry :: MonadSTM m => m (PeerTxRegistry m peeraddr)

valuenewSharedTxStateVar

:: MonadSTM m
=> SharedTxState peeraddr txid
-> m (SharedTxStateVar m peeraddr txid)

valuenewTxSubmissionCountersVar

valuetxCountersThreadV2

:: (MonadDelay m, MonadSTM m, HasRawTxId txid)
=> TxDecisionPolicy
-> Tracer m TxSubmissionCounters
-> Tracer m (TraceTxLogic peeraddr txid tx)
-> TxSubmissionCountersVar m
-> SharedTxStateVar m peeraddr txid
-> PeerTxRegistry m peeraddr
-> m Void

valuewithPeer

:: (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