Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Protocol.Handshake

Description

API for running Handshake protocol.

Synopsis

runHandshakeClient :: ( MonadAsync m, MonadFork m, MonadMonotonicTime m, MonadTimer m, MonadMask m, MonadThrow ( STM m), Ord vNumber) => MuxBearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m ( Either ( HandshakeException vNumber) (application, vNumber, vData))
runHandshakeServer :: ( MonadAsync m, MonadFork m, MonadMonotonicTime m, MonadTimer m, MonadMask m, MonadThrow ( STM m), Ord vNumber) => MuxBearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m ( Either ( HandshakeException vNumber) (application, vNumber, vData))
data HandshakeArguments connectionId vNumber vData m = HandshakeArguments {
- haHandshakeTracer :: Tracer m ( WithMuxBearer connectionId ( TraceSendRecv ( Handshake vNumber Term )))
- haHandshakeCodec :: Codec ( Handshake vNumber Term ) DeserialiseFailure m ByteString
- haVersionDataCodec :: VersionDataCodec Term vNumber vData
- haAcceptVersion :: vData -> vData -> Accept vData
- haTimeLimits :: ProtocolTimeLimits ( Handshake vNumber Term )
}
newtype Versions vNum vData r = Versions {
- getVersions :: Map vNum ( Version vData r)
}
data HandshakeException vNumber
- = HandshakeProtocolLimit ProtocolLimitFailure
- | HandshakeProtocolError ( HandshakeProtocolError vNumber)
data HandshakeProtocolError vNumber
- = HandshakeError ( RefuseReason vNumber)
- | NotRecognisedVersion vNumber
- | InvalidServerSelection vNumber Text
data RefuseReason vNumber
- = VersionMismatch [vNumber] [ Int ]
- | HandshakeDecodeError vNumber Text
- | Refused vNumber Text
data Accept vData
- = Accept vData
- | Refuse ! Text

Documentation

runHandshakeClient :: ( MonadAsync m, MonadFork m, MonadMonotonicTime m, MonadTimer m, MonadMask m, MonadThrow ( STM m), Ord vNumber) => MuxBearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m ( Either ( HandshakeException vNumber) (application, vNumber, vData)) Source #

Run client side of the Handshake protocol

runHandshakeServer :: ( MonadAsync m, MonadFork m, MonadMonotonicTime m, MonadTimer m, MonadMask m, MonadThrow ( STM m), Ord vNumber) => MuxBearer m -> connectionId -> HandshakeArguments connectionId vNumber vData m -> Versions vNumber vData application -> m ( Either ( HandshakeException vNumber) (application, vNumber, vData)) Source #

Run server side of the Handshake protocol.

data HandshakeArguments connectionId vNumber vData m Source #

Common arguments for both Handshake client & server.

Constructors

HandshakeArguments

Fields

haHandshakeTracer :: Tracer m ( WithMuxBearer connectionId ( TraceSendRecv ( Handshake vNumber Term )))

Handshake tracer
haHandshakeCodec :: Codec ( Handshake vNumber Term ) DeserialiseFailure m ByteString

Codec for protocol messages.
haVersionDataCodec :: VersionDataCodec Term vNumber vData

A codec for protocol parameters.
haAcceptVersion :: vData -> vData -> Accept vData

accept version, first argument is our version data the second argument is the remote version data.
haTimeLimits :: ProtocolTimeLimits ( Handshake vNumber Term )

Driver timeouts for Handshake protocol.

newtype Versions vNum vData r Source #

The version map supported by the local agent keyed on the version identifier.

Each Version contains a function which takes negotiated version data and returns negotiated application (the r type variable).

If one needs to combine multiple versions the simplest way is to use one of the combinators: foldMapVersions , combineVersions or the Semigroup instance directly:

fold $ (simpleSingletonVersions ...)
      :| [ (simpleSingletonVersions ...)
         , (simpleSingletonVersions ...)
         , ...
         ]

Constructors

Versions
Fields getVersions :: Map vNum ( Version vData r)

Instances

Instances details

Functor ( Versions vNum extra) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Version Methods fmap :: (a -> b) -> Versions vNum extra a -> Versions vNum extra b Source # (<$) :: a -> Versions vNum extra b -> Versions vNum extra a Source #
Ord vNum => Semigroup ( Versions vNum vData r) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Version Methods (<>) :: Versions vNum vData r -> Versions vNum vData r -> Versions vNum vData r Source # sconcat :: NonEmpty ( Versions vNum vData r) -> Versions vNum vData r Source # stimes :: Integral b => b -> Versions vNum vData r -> Versions vNum vData r Source #

data HandshakeException vNumber Source #

Wrapper around initiator and responder errors experienced by tryHandshake.

Constructors

HandshakeProtocolLimit ProtocolLimitFailure
HandshakeProtocolError ( HandshakeProtocolError vNumber)

Instances

Instances details

Show vNumber => Show ( HandshakeException vNumber) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake Methods showsPrec :: Int -> HandshakeException vNumber -> ShowS Source # show :: HandshakeException vNumber -> String Source # showList :: [ HandshakeException vNumber] -> ShowS Source #

data HandshakeProtocolError vNumber Source #

Extends handshake error RefuseReason type, by client specific errors.

Constructors

HandshakeError ( RefuseReason vNumber)
NotRecognisedVersion vNumber
InvalidServerSelection vNumber Text

Instances

Instances details

Eq vNumber => Eq ( HandshakeProtocolError vNumber) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Type Methods (==) :: HandshakeProtocolError vNumber -> HandshakeProtocolError vNumber -> Bool Source # (/=) :: HandshakeProtocolError vNumber -> HandshakeProtocolError vNumber -> Bool Source #
Show vNumber => Show ( HandshakeProtocolError vNumber) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Type Methods showsPrec :: Int -> HandshakeProtocolError vNumber -> ShowS Source # show :: HandshakeProtocolError vNumber -> String Source # showList :: [ HandshakeProtocolError vNumber] -> ShowS Source #
( Typeable vNumber, Show vNumber) => Exception ( HandshakeProtocolError vNumber) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Type Methods toException :: HandshakeProtocolError vNumber -> SomeException Source # fromException :: SomeException -> Maybe ( HandshakeProtocolError vNumber) Source # displayException :: HandshakeProtocolError vNumber -> String Source #

data RefuseReason vNumber Source #

Reasons by which a server can refuse proposed version.

Constructors

VersionMismatch [vNumber] [ Int ]	All of the prosed versions where not known to the server. Since the server sends all versions that it can knows about, some of them we might not be able to decode, so we include raw tags `[Int]` .
HandshakeDecodeError vNumber Text	The server failed to decode version parameters.
Refused vNumber Text	The server refused to run the proposed version parameters

Instances

Instances details

Eq vNumber => Eq ( RefuseReason vNumber) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Type Methods (==) :: RefuseReason vNumber -> RefuseReason vNumber -> Bool Source # (/=) :: RefuseReason vNumber -> RefuseReason vNumber -> Bool Source #
Show vNumber => Show ( RefuseReason vNumber) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Type Methods showsPrec :: Int -> RefuseReason vNumber -> ShowS Source # show :: RefuseReason vNumber -> String Source # showList :: [ RefuseReason vNumber] -> ShowS Source #
( Typeable vNumber, Show vNumber) => Exception ( RefuseReason vNumber) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Type Methods toException :: RefuseReason vNumber -> SomeException Source # fromException :: SomeException -> Maybe ( RefuseReason vNumber) Source # displayException :: RefuseReason vNumber -> String Source #

data Accept vData Source #

A Maybe like type which better explains its purpose.

Constructors

Accept vData
Refuse ! Text

Instances

Instances details

Eq vData => Eq ( Accept vData) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Version Methods (==) :: Accept vData -> Accept vData -> Bool Source # (/=) :: Accept vData -> Accept vData -> Bool Source #
Show vData => Show ( Accept vData) Source #
Instance details Defined in Ouroboros.Network.Protocol.Handshake.Version Methods showsPrec :: Int -> Accept vData -> ShowS Source # show :: Accept vData -> String Source # showList :: [ Accept vData] -> ShowS Source #