Safe Haskell	None
Language	Haskell2010

Cardano.Streaming

Synopsis

withChainSyncEventStream :: FilePath -> NetworkId -> [ChainPoint] -> (Stream (Of (ChainSyncEvent (BlockInMode CardanoMode))) IO r -> IO b) -> IO b
data ChainSyncEvent a
- = RollForward a ChainTip
- | RollBackward ChainPoint ChainTip
data ChainSyncEventException = NoIntersectionFound

Documentation

withChainSyncEventStream Source #

Arguments

:: FilePath	Path to the node socket
-> NetworkId
-> [ChainPoint]	The point on the chain to start streaming from
-> (Stream (Of (ChainSyncEvent (BlockInMode CardanoMode))) IO r -> IO b)	The stream consumer
-> IO b

withChainSyncEventStream uses the chain-sync mini-protocol to connect to a locally running node and fetch blocks from the given starting point.

data ChainSyncEvent a Source #

Constructors

RollForward a ChainTip
RollBackward ChainPoint ChainTip

Instances

Instances details

Functor ChainSyncEvent Source #
Instance details Defined in Cardano.Streaming Methods fmap :: (a -> b) -> ChainSyncEvent a -> ChainSyncEvent b Source # (<$) :: a -> ChainSyncEvent b -> ChainSyncEvent a Source #
Show a => Show (ChainSyncEvent a) Source #
Instance details Defined in Cardano.Streaming Methods showsPrec :: Int -> ChainSyncEvent a -> ShowS Source # show :: ChainSyncEvent a -> String Source # showList :: [ChainSyncEvent a] -> ShowS Source #
Generic (ChainSyncEvent a) Source #
Instance details Defined in Cardano.Streaming Associated Types type Rep (ChainSyncEvent a) :: Type -> Type Source # Methods from :: ChainSyncEvent a -> Rep (ChainSyncEvent a) x Source # to :: Rep (ChainSyncEvent a) x -> ChainSyncEvent a Source #
type Rep (ChainSyncEvent a) Source #
Instance details Defined in Cardano.Streaming type Rep (ChainSyncEvent a) = D1 ('MetaData "ChainSyncEvent" "Cardano.Streaming" "cardano-streaming-1.1.0.0-GfX5BNbTZj8Ho0uRFGv3q" 'False) (C1 ('MetaCons "RollForward" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 a) :: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChainTip)) :+: C1 ('MetaCons "RollBackward" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChainPoint) :: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChainTip)))

data ChainSyncEventException Source #

Constructors

NoIntersectionFound

Instances

Instances details

Show ChainSyncEventException Source #
Instance details Defined in Cardano.Streaming Methods showsPrec :: Int -> ChainSyncEventException -> ShowS Source # show :: ChainSyncEventException -> String Source # showList :: [ChainSyncEventException] -> ShowS Source #
Exception ChainSyncEventException Source #
Instance details Defined in Cardano.Streaming Methods toException :: ChainSyncEventException -> SomeException Source # fromException :: SomeException -> Maybe ChainSyncEventException Source # displayException :: ChainSyncEventException -> String Source #