cardano-streaming-1.2.0.0
Safe Haskell None
Language Haskell2010

Cardano.Streaming.Helpers

Synopsis

ChainSyncEvent

data ChainSyncEvent a Source #

Constructors

RollForward a ChainTip
RollBackward ChainPoint ChainTip

Instances

Instances details
Functor ChainSyncEvent Source #
Instance details

Defined in Cardano.Streaming.Helpers

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.Helpers

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.Helpers

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.Helpers

type Rep ( ChainSyncEvent a) = D1 (' MetaData "ChainSyncEvent" "Cardano.Streaming.Helpers" "cardano-streaming-1.2.0.0-3K1SjQkdiXnGaRr9D4cHjb" ' 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.Helpers

Methods

showsPrec :: Int -> ChainSyncEventException -> ShowS Source #

show :: ChainSyncEventException -> String Source #

showList :: [ ChainSyncEventException ] -> ShowS Source #

Exception ChainSyncEventException Source #
Instance details

Defined in Cardano.Streaming.Helpers

Methods

toException :: ChainSyncEventException -> SomeException Source #

fromException :: SomeException -> Maybe ChainSyncEventException Source #

displayException :: ChainSyncEventException -> String Source #

data RollbackException Source #

Constructors

RollbackLocationNotFound ChainPoint ChainTip

Instances

Instances details
Eq RollbackException Source #
Instance details

Defined in Cardano.Streaming.Helpers

Methods

(==) :: RollbackException -> RollbackException -> Bool Source #

(/=) :: RollbackException -> RollbackException -> Bool Source #

Show RollbackException Source #
Instance details

Defined in Cardano.Streaming.Helpers

Methods

showsPrec :: Int -> RollbackException -> ShowS Source #

show :: RollbackException -> String Source #

showList :: [ RollbackException ] -> ShowS Source #

Exception RollbackException Source #
Instance details

Defined in Cardano.Streaming.Helpers

Methods

toException :: RollbackException -> SomeException Source #

fromException :: SomeException -> Maybe RollbackException Source #

displayException :: RollbackException -> String Source #

Orphans

Block

bimBlockNo :: BlockInMode CardanoMode -> BlockNo Source #

bimSlotNo :: BlockInMode CardanoMode -> SlotNo Source #

getEpochNo :: LedgerState -> Maybe EpochNo Source #

fromChainTip :: ChainTip -> WithOrigin BlockNo Source #

IO

linkedAsync :: IO a -> IO () Source #

LocalNodeConnectInfo

mkLocalNodeConnectInfo :: NetworkId -> FilePath -> LocalNodeConnectInfo CardanoMode Source #

mkConnectInfo :: Env -> FilePath -> LocalNodeConnectInfo CardanoMode Source #

Derive LocalNodeConnectInfo from Env.

ignoreRollbacks :: Monad m => Stream ( Of ( ChainSyncEvent a)) m r -> Stream ( Of a) m r Source #

Ignore rollback events in the chainsync event stream. Useful for monitor which blocks has been seen by the node, regardless whether they are permanent.

Orphan instances