Cardano.Network.NodeToClient · cardano-diffusion-1.1.1.0

valuewithIOManager :: WithIOManager

withIOManager allows to do asynchronous io on Windows hiding the differences between posix and Win32.

It starts an io manger thread, which should be only one running at a time, so the best place to call it is very close to the main function and last for duration of the application.

Async IO operations which are using the iocp port should not leak out-side of withIOManager. They will be silently cancelled when withIOManager exists. In particular one should not return IOManager from withIOManager.

valuenodeToClientHandshakeCodec :: MonadST m => Codec (Handshake NodeToClientVersion Term) DeserialiseFailure m ByteString

#

valuechainSyncPeerNull :: MonadDelay m => Client (ChainSync header point tip) 'NonPipelined 'StIdle m a

#

valueconnectTo

:: NFData a
=> LocalSnocket
-> NetworkConnectTracers IO LocalAddress NodeToClientVersion
-> Versions NodeToClientVersion NodeToClientVersionData (OuroborosApplicationWithMinimalCtx 'InitiatorMode LocalAddress ByteString IO a Void)
-> FilePath
-> IO (Either SomeException a)

#

valueconnectToWithMux

:: LocalSnocket
-> NetworkConnectTracers IO LocalAddress NodeToClientVersion
-> Versions NodeToClientVersion NodeToClientVersionData (OuroborosApplicationWithMinimalCtx 'InitiatorMode LocalAddress ByteString IO a b)
-> FilePath
-> ConnectionId LocalAddress -> NodeToClientVersion -> NodeToClientVersionData -> OuroborosApplicationWithMinimalCtx 'InitiatorMode LocalAddress ByteString IO a b -> Mux 'InitiatorMode IO -> Async IO () -> IO x
-> IO x

#

valuelocalChainSyncMiniProtocolNum :: MiniProtocolNum

#

valuelocalStateQueryMiniProtocolNum :: MiniProtocolNum

#

valuelocalStateQueryPeerNull :: MonadDelay m => Client (LocalStateQuery block point query) 'StIdle State m a

#

valuelocalTxMonitorMiniProtocolNum :: MiniProtocolNum

#

valuelocalTxMonitorPeerNull :: MonadDelay m => Client (LocalTxMonitor txid tx slot) 'NonPipelined 'StIdle m a

#

valuelocalTxSubmissionMiniProtocolNum :: MiniProtocolNum

#

valuelocalTxSubmissionPeerNull :: MonadDelay m => Client (LocalTxSubmission tx reject) 'NonPipelined 'StIdle m a

#

valuemaximumMiniProtocolLimits :: MiniProtocolLimits

#

valuenodeToClientProtocols

:: NodeToClientProtocols appType addr bytes m a b
-> NodeToClientVersion
-> NodeToClientVersionData
-> OuroborosApplicationWithMinimalCtx appType addr bytes m a b

#

valueversionedNodeToClientProtocols

:: NodeToClientVersion
-> NodeToClientVersionData
-> NodeToClientProtocols appType LocalAddress bytes m a b
-> Versions NodeToClientVersion NodeToClientVersionData (OuroborosApplicationWithMinimalCtx appType LocalAddress bytes m a b)

#

valuenodeToClientVersionCodec :: CodecCBORTerm (Text, Maybe Int) NodeToClientVersion

#

valuenodeToClientVersionDataCodec :: VersionDataCodec NodeToClientVersion NodeToClientVersionData

#

valuecombineVersions

:: (Ord vNum, Foldable f, HasCallStack)
=> f (Versions vNum extra r)
-> Versions vNum extra r

#

valuefoldMapVersions

:: (Ord vNum, Foldable f, HasCallStack)
=> x -> Versions vNum extra r
-> f x
-> Versions vNum extra r

#

valuesimpleSingletonVersions

:: vNum
-> vData
-> vData -> r
-> Versions vNum vData r

#

valuelocalSnocket :: IOManager -> LocalSnocket

#

valuenullNetworkConnectTracers :: Monad m => NetworkConnectTracers m addr vNumber

#

typetype AssociateWithIOCP = IOManager

#

Deprecated. Usage of type alias AssociateWithIOCP is deprecated, use IOManager instead

newtypenewtype IOManager

#

This is public api to interact with the io manager; On Windows IOManager holds System.Win32.Async.IOManager.associateWithIOCompletionPort; on other platforms IOManager can run over any type, and thus is guaranteed to be no-op.

Constructors

IOManager
- associateWithIOManager :: forall hole. hole -> IO ()

datadata NodeToClientProtocols (appType :: Mode) ntcAddr bytes (m :: Type -> Type) a b

#

Constructors

NodeToClientProtocols
- localChainSyncProtocol :: RunMiniProtocolWithMinimalCtx appType ntcAddr bytes m a b
- localTxSubmissionProtocol :: RunMiniProtocolWithMinimalCtx appType ntcAddr bytes m a b
- localStateQueryProtocol :: RunMiniProtocolWithMinimalCtx appType ntcAddr bytes m a b
- localTxMonitorProtocol :: RunMiniProtocolWithMinimalCtx appType ntcAddr bytes m a b