Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Driver.Simple

Contents

Introduction
Pipelined peers
Connected peers

Description

Drivers for running Peer s with a Codec and a Channel .

Synopsis

runPeer :: forall ps (st :: ps) pr failure bytes m a. ( MonadThrow m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => Tracer m ( TraceSendRecv ps) -> Codec ps failure m bytes -> Channel m bytes -> Peer ps pr st m a -> m (a, Maybe bytes)
data TraceSendRecv ps where
- TraceSendMsg :: AnyMessageAndAgency ps -> TraceSendRecv ps
- TraceRecvMsg :: AnyMessageAndAgency ps -> TraceSendRecv ps
data DecoderFailure where
- DecoderFailure :: forall (pr :: PeerRole ) ps (st :: ps) failure. ( forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps, Show failure) => PeerHasAgency pr st -> failure -> DecoderFailure
runPipelinedPeer :: forall ps (st :: ps) pr failure bytes m a. ( MonadAsync m, MonadThrow m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => Tracer m ( TraceSendRecv ps) -> Codec ps failure m bytes -> Channel m bytes -> PeerPipelined ps pr st m a -> m (a, Maybe bytes)
data Role
- = Client
- | Server
runConnectedPeers :: ( MonadSTM m, MonadAsync m, MonadCatch m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => m ( Channel m bytes, Channel m bytes) -> Tracer m ( Role , TraceSendRecv ps) -> Codec ps failure m bytes -> Peer ps pr st m a -> Peer ps ( FlipAgency pr) st m b -> m (a, b)
runConnectedPeersAsymmetric :: ( MonadSTM m, MonadAsync m, MonadCatch m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => m ( Channel m bytes, Channel m bytes) -> Tracer m ( Role , TraceSendRecv ps) -> Codec ps failure m bytes -> Codec ps failure m bytes -> Peer ps pr st m a -> Peer ps ( FlipAgency pr) st m b -> m (a, b)
runConnectedPeersPipelined :: ( MonadSTM m, MonadAsync m, MonadCatch m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => m ( Channel m bytes, Channel m bytes) -> Tracer m ( Role , TraceSendRecv ps) -> Codec ps failure m bytes -> PeerPipelined ps pr st m a -> Peer ps ( FlipAgency pr) st m b -> m (a, b)

Introduction

A Peer is a particular implementation of an agent that engages in a typed protocol. To actualy run one we need a source and sink for the typed protocol messages. These are provided by a Channel and a Codec . The Channel represents one end of an untyped duplex message transport, and the Codec handles conversion between the typed protocol messages and the untyped channel.

So given the Peer and a compatible Codec and Channel we can run the peer in some appropriate monad. The peer and codec have to agree on the same protocol and role in that protocol. The codec and channel have to agree on the same untyped medium, e.g. text or bytes. All three have to agree on the same monad in which they will run.

This module provides drivers for normal and pipelined peers. There is very little policy involved here so typically it should be possible to use these drivers, and customise things by adjusting the peer, or codec or channel.

It is of course possible to write custom drivers and the code for these ones may provide a useful starting point. The runDecoder function may be a helpful utility for use in custom drives.

runPeer :: forall ps (st :: ps) pr failure bytes m a. ( MonadThrow m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => Tracer m ( TraceSendRecv ps) -> Codec ps failure m bytes -> Channel m bytes -> Peer ps pr st m a -> m (a, Maybe bytes) Source #

Run a peer with the given channel via the given codec.

This runs the peer to completion (if the protocol allows for termination).

data TraceSendRecv ps where Source #

Structured Tracer output for runPeer and derivitives.

Constructors

TraceSendMsg :: AnyMessageAndAgency ps -> TraceSendRecv ps
TraceRecvMsg :: AnyMessageAndAgency ps -> TraceSendRecv ps

Instances

Instances details

Show ( AnyMessageAndAgency ps) => Show ( TraceSendRecv ps) Source #
Instance details Defined in Ouroboros.Network.Driver.Simple Methods showsPrec :: Int -> TraceSendRecv ps -> ShowS Source # show :: TraceSendRecv ps -> String Source # showList :: [ TraceSendRecv ps] -> ShowS Source #

data DecoderFailure where Source #

Constructors

DecoderFailure :: forall (pr :: PeerRole ) ps (st :: ps) failure. ( forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps, Show failure) => PeerHasAgency pr st -> failure -> DecoderFailure

Instances

Instances details

Show DecoderFailure Source #
Instance details Defined in Ouroboros.Network.Driver.Simple Methods showsPrec :: Int -> DecoderFailure -> ShowS Source # show :: DecoderFailure -> String Source # showList :: [ DecoderFailure ] -> ShowS Source #
Exception DecoderFailure Source #
Instance details Defined in Ouroboros.Network.Driver.Simple Methods toException :: DecoderFailure -> SomeException Source # fromException :: SomeException -> Maybe DecoderFailure Source # displayException :: DecoderFailure -> String Source #

Pipelined peers

runPipelinedPeer :: forall ps (st :: ps) pr failure bytes m a. ( MonadAsync m, MonadThrow m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => Tracer m ( TraceSendRecv ps) -> Codec ps failure m bytes -> Channel m bytes -> PeerPipelined ps pr st m a -> m (a, Maybe bytes) Source #

Run a pipelined peer with the given channel via the given codec.

This runs the peer to completion (if the protocol allows for termination).

Unlike normal peers, running pipelined peers rely on concurrency, hence the MonadSTM constraint.

Connected peers

data Role Source #

Constructors

Client
Server

runConnectedPeers :: ( MonadSTM m, MonadAsync m, MonadCatch m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => m ( Channel m bytes, Channel m bytes) -> Tracer m ( Role , TraceSendRecv ps) -> Codec ps failure m bytes -> Peer ps pr st m a -> Peer ps ( FlipAgency pr) st m b -> m (a, b) Source #

Run two Peer s via a pair of connected Channel s and a common Codec .

This is useful for tests and quick experiments.

The first argument is expected to create two channels that are connected, for example createConnectedChannels .

runConnectedPeersAsymmetric :: ( MonadSTM m, MonadAsync m, MonadCatch m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => m ( Channel m bytes, Channel m bytes) -> Tracer m ( Role , TraceSendRecv ps) -> Codec ps failure m bytes -> Codec ps failure m bytes -> Peer ps pr st m a -> Peer ps ( FlipAgency pr) st m b -> m (a, b) Source #

runConnectedPeersPipelined :: ( MonadSTM m, MonadAsync m, MonadCatch m, Show failure, forall (st' :: ps). Show ( ClientHasAgency st'), forall (st' :: ps). Show ( ServerHasAgency st'), ShowProxy ps) => m ( Channel m bytes, Channel m bytes) -> Tracer m ( Role , TraceSendRecv ps) -> Codec ps failure m bytes -> PeerPipelined ps pr st m a -> Peer ps ( FlipAgency pr) st m b -> m (a, b) Source #