ouroboros-consensus

Safe Haskell	None
Language	Haskell2010

Ouroboros.Consensus.MiniProtocol.ChainSync.Server

Contents

Trace events
Low-level API

Synopsis

data Tip (b ∷ k)
chainSyncBlockServerFollower ∷ ChainDB m blk → ResourceRegistry m → m (Follower m blk (WithPoint blk (Serialised blk)))
chainSyncBlocksServer ∷ ∀ (m ∷ Type → Type) blk. (IOLike m, HasHeader (Header blk)) ⇒ Tracer m (TraceChainSyncServerEvent blk) → ChainDB m blk → Follower m blk (WithPoint blk (Serialised blk)) → ChainSyncServer (Serialised blk) (Point blk) (Tip blk) m ()
chainSyncHeaderServerFollower ∷ ChainDB m blk → ChainType → ResourceRegistry m → m (Follower m blk (WithPoint blk (SerialisedHeader blk)))
chainSyncHeadersServer ∷ ∀ (m ∷ Type → Type) blk. (IOLike m, HasHeader (Header blk)) ⇒ Tracer m (TraceChainSyncServerEvent blk) → ChainDB m blk → Follower m blk (WithPoint blk (SerialisedHeader blk)) → ChainSyncServer (SerialisedHeader blk) (Point blk) (Tip blk) m ()
data BlockingType
- = Blocking
- | NonBlocking
data TraceChainSyncServerEvent blk = TraceChainSyncServerUpdate (Tip blk) (ChainUpdate blk (Point blk)) BlockingType Enclosing
chainSyncServerForFollower ∷ ∀ (m ∷ Type → Type) blk b. IOLike m ⇒ Tracer m (TraceChainSyncServerEvent blk) → STM m (Tip blk) → Follower m blk (WithPoint blk b) → ChainSyncServer b (Point blk) (Tip blk) m ()

Documentation

data Tip (b ∷ k) #

Instances

Instances details

ConvertRawHash blk ⇒ SerialiseNodeToNode blk (Tip blk) Source #

Instance details

Defined in Ouroboros.Consensus.Node.Serialisation

Methods

encodeNodeToNode ∷ CodecConfig blk → BlockNodeToNodeVersion blk → Tip blk → Encoding Source #

decodeNodeToNode ∷ CodecConfig blk → BlockNodeToNodeVersion blk → ∀ s. Decoder s (Tip blk) Source #

ShowProxy b ⇒ ShowProxy (Tip b ∷ Type) #

Instance details

Defined in Ouroboros.Network.Block

Methods

showProxy ∷ Proxy (Tip b) → String #

StandardHash b ⇒ NFData (Tip b) #

Instance details

Defined in Ouroboros.Network.Block

Methods

rnf ∷ Tip b → () #

StandardHash b ⇒ Eq (Tip b) #

Instance details

Defined in Ouroboros.Network.Block

Methods

(==) ∷ Tip b → Tip b → Bool #

(/=) ∷ Tip b → Tip b → Bool #

Generic (Tip b) #

Instance details

Defined in Ouroboros.Network.Block

Associated Types

type Rep (Tip b)

Instance details

Defined in Ouroboros.Network.Block

type Rep (Tip b) = D1 ('MetaData "Tip" "Ouroboros.Network.Block" "ouroboros-network-1.2.0.0-l-api-af495335aa766cc933ee95df4ec7fdea2dd796e1efa726c7d4b40b7590fdf5d9" 'False) (C1 ('MetaCons "TipGenesis" 'PrefixI 'False) (U1 ∷ Type → Type) :+: C1 ('MetaCons "Tip" 'PrefixI 'False) (S1 ('MetaSel ('Nothing ∷ Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 SlotNo) :*: (S1 ('MetaSel ('Nothing ∷ Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (HeaderHash b)) :*: S1 ('MetaSel ('Nothing ∷ Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 BlockNo))))

Methods

from ∷ Tip b → Rep (Tip b) x #

to ∷ Rep (Tip b) x → Tip b #

StandardHash b ⇒ Show (Tip b) #

Instance details

Defined in Ouroboros.Network.Block

Methods

showsPrec ∷ Int → Tip b → ShowS #

show ∷ Tip b → String #

showList ∷ [Tip b] → ShowS #

StandardHash b ⇒ NoThunks (Tip b) #

Instance details

Defined in Ouroboros.Network.Block

Methods

noThunks ∷ Context → Tip b → IO (Maybe ThunkInfo) Source #

wNoThunks ∷ Context → Tip b → IO (Maybe ThunkInfo) Source #

showTypeOf ∷ Proxy (Tip b) → String Source #

Condense (HeaderHash b) ⇒ Condense (Tip b) Source #

Instance details

Defined in Ouroboros.Consensus.Util.Condense

Methods

condense ∷ Tip b → String Source #

type Rep (Tip b) #

Instance details

Defined in Ouroboros.Network.Block

type Rep (Tip b) = D1 ('MetaData "Tip" "Ouroboros.Network.Block" "ouroboros-network-1.2.0.0-l-api-af495335aa766cc933ee95df4ec7fdea2dd796e1efa726c7d4b40b7590fdf5d9" 'False) (C1 ('MetaCons "TipGenesis" 'PrefixI 'False) (U1 ∷ Type → Type) :+: C1 ('MetaCons "Tip" 'PrefixI 'False) (S1 ('MetaSel ('Nothing ∷ Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 SlotNo) :*: (S1 ('MetaSel ('Nothing ∷ Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (HeaderHash b)) :*: S1 ('MetaSel ('Nothing ∷ Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 BlockNo))))

chainSyncBlockServerFollower ∷ ChainDB m blk → ResourceRegistry m → m (Follower m blk (WithPoint blk (Serialised blk))) Source #

chainSyncBlocksServer ∷ ∀ (m ∷ Type → Type) blk. (IOLike m, HasHeader (Header blk)) ⇒ Tracer m (TraceChainSyncServerEvent blk) → ChainDB m blk → Follower m blk (WithPoint blk (Serialised blk)) → ChainSyncServer (Serialised blk) (Point blk) (Tip blk) m () Source #

Chain Sync Server for blocks for a given a ChainDB.

The local node-to-client protocol uses the chain sync mini-protocol with chains of full blocks (rather than a header / body split).

chainSyncHeaderServerFollower ∷ ChainDB m blk → ChainType → ResourceRegistry m → m (Follower m blk (WithPoint blk (SerialisedHeader blk))) Source #

chainSyncHeadersServer ∷ ∀ (m ∷ Type → Type) blk. (IOLike m, HasHeader (Header blk)) ⇒ Tracer m (TraceChainSyncServerEvent blk) → ChainDB m blk → Follower m blk (WithPoint blk (SerialisedHeader blk)) → ChainSyncServer (SerialisedHeader blk) (Point blk) (Tip blk) m () Source #

Chain Sync Server for block headers for a given a ChainDB.

The node-to-node protocol uses the chain sync mini-protocol with chain headers (and fetches blocks separately with the block fetch mini-protocol).

Trace events

data BlockingType Source #

Whether reading a ChainSync server update instruction was blocking or non-blocking.

Constructors

Blocking
NonBlocking

Instances

Instances details

Eq BlockingType Source #
Instance details Defined in Ouroboros.Consensus.MiniProtocol.ChainSync.Server Methods (==) ∷ BlockingType → BlockingType → Bool # (/=) ∷ BlockingType → BlockingType → Bool #
Ord BlockingType Source #
Instance details Defined in Ouroboros.Consensus.MiniProtocol.ChainSync.Server Methods compare ∷ BlockingType → BlockingType → Ordering # (<) ∷ BlockingType → BlockingType → Bool # (<=) ∷ BlockingType → BlockingType → Bool # (>) ∷ BlockingType → BlockingType → Bool # (>=) ∷ BlockingType → BlockingType → Bool # max ∷ BlockingType → BlockingType → BlockingType # min ∷ BlockingType → BlockingType → BlockingType #
Show BlockingType Source #
Instance details Defined in Ouroboros.Consensus.MiniProtocol.ChainSync.Server Methods showsPrec ∷ Int → BlockingType → ShowS # show ∷ BlockingType → String # showList ∷ [BlockingType] → ShowS #

data TraceChainSyncServerEvent blk Source #

Events traced by the Chain Sync Server.

Constructors

TraceChainSyncServerUpdate	Send a `ChainUpdate` message.
Fields (Tip blk) Tip of the currently selected chain. (ChainUpdate blk (Point blk)) The whole headers/blocks in the traced `ChainUpdate` are substituted with their corresponding `Point`. BlockingType Enclosing

Instances

Instances details

StandardHash blk ⇒ Eq (TraceChainSyncServerEvent blk) Source #
Instance details Defined in Ouroboros.Consensus.MiniProtocol.ChainSync.Server Methods (==) ∷ TraceChainSyncServerEvent blk → TraceChainSyncServerEvent blk → Bool # (/=) ∷ TraceChainSyncServerEvent blk → TraceChainSyncServerEvent blk → Bool #
StandardHash blk ⇒ Show (TraceChainSyncServerEvent blk) Source #
Instance details Defined in Ouroboros.Consensus.MiniProtocol.ChainSync.Server Methods showsPrec ∷ Int → TraceChainSyncServerEvent blk → ShowS # show ∷ TraceChainSyncServerEvent blk → String # showList ∷ [TraceChainSyncServerEvent blk] → ShowS #

Low-level API

chainSyncServerForFollower ∷ ∀ (m ∷ Type → Type) blk b. IOLike m ⇒ Tracer m (TraceChainSyncServerEvent blk) → STM m (Tip blk) → Follower m blk (WithPoint blk b) → ChainSyncServer b (Point blk) (Tip blk) m () Source #

A chain sync server.

This is a version of chainSyncServerExample that uses an action to get the current Tip and a Follower instead of ChainProducerState.

All the hard work is done by the Followers provided by the ChainDB.