Skip to content

HORIZON HASKELL Docs lts/ghc-9.14.x99ffbb82026-10-19Search packagesCtrl K

Theme: |

GHC 9.14.1 · lts/ghc-9.14.x · 99ffbb8 · 2026-10-19

Moduleouroboros-network-1.2.0.0

Ouroboros.Network.TxSubmission.Inbound.V2.Registry

Synopsis

value newPeerTxRegistry
value newSharedTxStateVar
value newTxSubmissionCountersVar
value txCountersThreadV2
value withPeer
newtype RegisteredDelay
data PeerTxAPI
type PeerTxRegistry
type SharedTxStateVar
type TxSubmissionCountersVar

Packageouroboros-network-1.2.0.0
Exports10
LicenceApache-2.0

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

newtypenewtype RegisteredDelay (m :: Type -> Type)

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