Safe Haskell	None
Language	Haskell2010

DMQ.Diffusion.NodeKernel

Documentation

data NodeKernel crypto ntnAddr (m :: Type -> Type) Source #

Constructors

Fields

fetchClientRegistry :: !(FetchClientRegistry (ConnectionId ntnAddr) () () m)
The fetch client registry, used for the keep alive clients.
peerSharingRegistry :: !(PeerSharingRegistry ntnAddr m)
Read the current peer sharing registry, used for interacting with the PeerSharing protocol
peerSharingAPI :: !(PeerSharingAPI ntnAddr StdGen m)
mempool :: !(Mempool m (Sig crypto))
sigChannelVar :: !(TxChannelsVar m ntnAddr SigId (Sig crypto))
sigMempoolSem :: !(TxMempoolSem m)
sigSharedTxStateVar :: !(SharedTxStateVar m ntnAddr SigId (Sig crypto))

Arguments

:: forall crypto ntnAddr m a. (Crypto crypto, MonadAsync m, MonadFork m, MonadDelay m, MonadLabelledSTM m, MonadMask m, MonadMVar m, MonadTime m, Ord ntnAddr, Show ntnAddr, Hashable ntnAddr)
=> (forall ev. ToJSON ev => Tracer m (WithEventType ev))
-> Configuration
-> StdGen
-> (NodeKernel crypto ntnAddr m -> m a)	as soon as the callback exits the `mempoolWorker` and all decision logic threads will be killed
-> m a