Skip to content

HORIZON HASKELL Docs lts/ghc-9.14.xd82dee82026-10-12Search names, modules, packages, or :: a typeCtrl K

GHC 9.14.1 · lts/ghc-9.14.x · d82dee8 · 2026-10-12

Moduleouroboros-network-1.2.0.0

Ouroboros.Network.BlockFetch.ClientRegistry

3 types
9 values

Packageouroboros-network-1.2.0.0
Exports12
LicenceApache-2.0

valuebracketFetchClient

:: (MonadFork m, MonadMask m, MonadTimer m, Ord peer)
=> FetchClientRegistry peer header block m
-> KeepAliveRegistry peer m
-> version
-> peer
-> FetchClientContext header block m -> m a
-> m a

valuebracketSyncWithFetchClient

:: (MonadSTM m, MonadFork m, MonadCatch m, Ord peer)
=> FetchClientRegistry peer header block m
-> peer
-> m a
-> m a

valuenewFetchClientRegistry :: MonadSTM m => m (FetchClientRegistry peer header block m)

valuereadFetchClientsStateVars

:: MonadSTM m
=> FetchClientRegistry peer header block m
-> STM m (Map peer (FetchClientStateVars m header))

valuereadFetchClientsStatus

:: MonadSTM m
=> FetchClientRegistry peer header block m
-> STM m (Map peer (PeerFetchStatus header))

valuesetFetchClientContext

:: MonadSTM m
=> FetchClientRegistry peer header block m
-> Tracer m (TraceLabelPeer peer (TraceFetchClientState header))
-> STM m (FetchClientPolicy header block m)
-> m ()

valuebracketKeepAliveClient

:: (MonadSTM m, MonadFork m, MonadMask m, Ord peer)
=> KeepAliveRegistry peer m
-> peer
-> StrictTVar m (Map peer PeerGSV) -> m a
-> m a

valuenewKeepAliveRegistry :: MonadSTM m => m (KeepAliveRegistry peer m)

valuereadPeerGSVs

:: (MonadSTM m, Ord peer)
=> KeepAliveRegistry peer m
-> STM m (Map peer PeerGSV)

datadata FetchClientRegistry peer header block (m :: Type -> Type)

Constructors

FetchClientRegistry
- ctxVar :: StrictTMVar m (Tracer m (TraceLabelPeer peer (TraceFetchClientState header)), STM m (FetchClientPolicy header block m))
- fetchRegistry :: StrictTVar m (Map peer (FetchClientStateVars m header))
- syncRegistry :: StrictTVar m (Map peer (ThreadId m, StrictTMVar m (), StrictTMVar m ()))

datadata FetchClientPolicy header block (m :: Type -> Type)

Constructors

FetchClientPolicy
- blockFetchSize :: header -> SizeInBytes
- blockMatchesHeader :: header -> block -> Bool
- addFetchedBlock :: Point block -> block -> m ()
- headerForgeUTCTime :: header -> UTCTime

datadata KeepAliveRegistry peer (m :: Type -> Type)

Constructors

KeepAliveRegistry
- dqRegistry :: StrictTVar m (Map peer PeerGSV)
- keepRegistry :: StrictTVar m (Map peer (ThreadId m, StrictTMVar m ()))
- dyingRegistry :: StrictTVar m (Set peer)