type Rep NodeToNodeVersion
Instance details Defined in DMQ.NodeToNode type Rep NodeToNodeVersion = D1 ('MetaData "NodeToNodeVersion" "DMQ.NodeToNode" "decentralized-message-queue-0.1.0.0-inplace" 'False) (C1 ('MetaCons "NodeToNodeV_1" 'PrefixI 'False) (U1 :: Type -> Type))

Methods

from :: NodeToNodeVersion -> Rep NodeToNodeVersion x #

to :: Rep NodeToNodeVersion x -> NodeToNodeVersion #

Show NodeToNodeVersion Source #

Instance details

Defined in DMQ.NodeToNode

Methods

showsPrec :: Int -> NodeToNodeVersion -> ShowS #

show :: NodeToNodeVersion -> String #

showList :: [NodeToNodeVersion] -> ShowS #

Eq NodeToNodeVersion Source #

Instance details

Defined in DMQ.NodeToNode

Methods

(==) :: NodeToNodeVersion -> NodeToNodeVersion -> Bool #

(/=) :: NodeToNodeVersion -> NodeToNodeVersion -> Bool #

Ord NodeToNodeVersion Source #

Instance details

Defined in DMQ.NodeToNode

Methods

compare :: NodeToNodeVersion -> NodeToNodeVersion -> Ordering #

(<) :: NodeToNodeVersion -> NodeToNodeVersion -> Bool #

(<=) :: NodeToNodeVersion -> NodeToNodeVersion -> Bool #

(>) :: NodeToNodeVersion -> NodeToNodeVersion -> Bool #

(>=) :: NodeToNodeVersion -> NodeToNodeVersion -> Bool #

max :: NodeToNodeVersion -> NodeToNodeVersion -> NodeToNodeVersion #

min :: NodeToNodeVersion -> NodeToNodeVersion -> NodeToNodeVersion #

type Rep NodeToNodeVersion Source #

Instance details

Defined in DMQ.NodeToNode

type Rep NodeToNodeVersion = D1 ('MetaData "NodeToNodeVersion" "DMQ.NodeToNode" "decentralized-message-queue-0.1.0.0-inplace" 'False) (C1 ('MetaCons "NodeToNodeV_1" 'PrefixI 'False) (U1 :: Type -> Type))

nodeToNodeVersionCodec :: CodecCBORTerm (Text, Maybe Int) NodeToNodeVersion Source #

data NodeToNodeVersionData Source #

Version data for NodeToNode protocols

This data type is inpired by the one defined in 'ouroboros-network-api', however, it is redefined here to tie it to our custom NodeToNodeVersion and to avoid divergences.

Constructors

NodeToNodeVersionData
Fields networkMagic :: !NetworkMagic diffusionMode :: !DiffusionMode peerSharing :: !PeerSharing query :: !Bool

Instances

Instances details

Show NodeToNodeVersionData Source #
Instance details Defined in DMQ.NodeToNode Methods showsPrec :: Int -> NodeToNodeVersionData -> ShowS # show :: NodeToNodeVersionData -> String # showList :: [NodeToNodeVersionData] -> ShowS #
Eq NodeToNodeVersionData Source #
Instance details Defined in DMQ.NodeToNode Methods (==) :: NodeToNodeVersionData -> NodeToNodeVersionData -> Bool # (/=) :: NodeToNodeVersionData -> NodeToNodeVersionData -> Bool #
Acceptable NodeToNodeVersionData Source #
Instance details Defined in DMQ.NodeToNode Methods acceptableVersion :: NodeToNodeVersionData -> NodeToNodeVersionData -> Accept NodeToNodeVersionData #
Queryable NodeToNodeVersionData Source #
Instance details Defined in DMQ.NodeToNode Methods queryVersion :: NodeToNodeVersionData -> Bool #

nodeToNodeCodecCBORTerm :: NodeToNodeVersion -> CodecCBORTerm Text NodeToNodeVersionData Source #

ntnDataFlow :: NodeToNodeVersionData -> DataFlow Source #

mapNtNDMQtoOuroboros :: NodeToNodeVersion -> NodeToNodeVersion Source #

Map between DMQ NTNVersion and Ouroboros NTNVersion

Useful for reusing codecs and other functions

type ClientApp addr bytes (m :: Type -> Type) a = NodeToNodeVersion -> ExpandedInitiatorContext addr m -> Channel m bytes -> m (a, Maybe bytes) Source #

type ServerApp addr bytes (m :: Type -> Type) a = NodeToNodeVersion -> ResponderContext addr -> Channel m bytes -> m (a, Maybe bytes) Source #

data Apps addr bKA bPS (m :: Type -> Type) a b Source #

Constructors

Apps
Fields aKeepAliveClient :: ClientApp addr bKA m a Start a keep-alive client. aKeepAliveServer :: ServerApp addr bKA m b Start a keep-alive server. aPeerSharingClient :: ClientApp addr bPS m a Start a peer-sharing client. aPeerSharingServer :: ServerApp addr bPS m b Start a peer-sharing server.

ntnApps :: forall (m :: Type -> Type) addr. (Alternative (STM m), MonadAsync m, MonadFork m, MonadMask m, MonadMVar m, MonadST m, MonadThread m, MonadThrow (STM m), MonadTimer m, Ord addr, Hashable addr) => NodeKernel addr m -> Codecs addr m -> LimitsAndTimeouts addr -> Apps addr ByteString ByteString m () () Source #

data Protocols (appType :: Mode) initiatorCtx responderCtx bytes (m :: Type -> Type) a b Source #

Constructors

Protocols
Fields keepAliveProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b keep-alive mini-protocol peerSharingProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b peer sharing mini-protocol

nodeToNodeProtocols Source #

Arguments

:: forall addr (appType :: Mode) initiatorCtx responderCtx bytes (m :: Type -> Type) a b. LimitsAndTimeouts addr
-> Protocols appType initiatorCtx responderCtx bytes m a b
-> NodeToNodeVersion	negotiated version number
-> NodeToNodeVersionData	negotiated version data
-> OuroborosBundle appType initiatorCtx responderCtx bytes m a b

initiatorProtocols :: forall addr bytes (m :: Type -> Type) a b. LimitsAndTimeouts addr -> Apps addr bytes bytes m a b -> NodeToNodeVersion -> NodeToNodeVersionData -> OuroborosBundleWithExpandedCtx 'InitiatorMode addr bytes m a Void Source #

initiatorAndResponderProtocols :: forall addr bytes (m :: Type -> Type) a b. LimitsAndTimeouts addr -> Apps addr bytes bytes m a b -> NodeToNodeVersion -> NodeToNodeVersionData -> OuroborosBundleWithExpandedCtx 'InitiatorResponderMode addr bytes m a b Source #

data Codecs addr (m :: Type -> Type) Source #

Constructors

Codecs
Fields keepAliveCodec :: Codec KeepAlive DeserialiseFailure m ByteString peerSharingCodec :: Codec (PeerSharing addr) DeserialiseFailure m ByteString

dmqCodecs :: forall (m :: Type -> Type) addr. MonadST m => (addr -> Encoding) -> (forall s. Decoder s addr) -> Codecs addr m Source #

data LimitsAndTimeouts addr Source #

Constructors

LimitsAndTimeouts
Fields keepAliveLimits :: MiniProtocolLimits keepAliveSizeLimits :: ProtocolSizeLimits KeepAlive ByteString keepAliveTimeLimits :: ProtocolTimeLimits KeepAlive peerSharingLimits :: MiniProtocolLimits peerSharingTimeLimits :: ProtocolTimeLimits (PeerSharing addr) peerSharingSizeLimits :: ProtocolSizeLimits (PeerSharing addr) ByteString

dmqLimitsAndTimeouts :: LimitsAndTimeouts addr Source #

ntnHandshakeArguments :: forall (m :: Type -> Type) ntnAddr. MonadST m => Tracer m (HandshakeTr ntnAddr NodeToNodeVersion) -> HandshakeArguments (ConnectionId ntnAddr) NodeToNodeVersion NodeToNodeVersionData m Source #

stdVersionDataNTN :: NetworkMagic -> DiffusionMode -> PeerSharing -> NodeToNodeVersionData Source #