marconi-cardano-core-1.2.0.0
Safe HaskellSafe-Inferred
LanguageHaskell2010

Marconi.Cardano.Core.Transformer.WithSyncStats

Synopsis

Transformer

data WithSyncStats indexer event #

A modifier that adds sync stats to the indexer

Instances

Instances details
IndexerTrans WithSyncStats # 
Instance details

Defined in Marconi.Cardano.Core.Transformer.WithSyncStats

Methods

unwrap :: forall (indexer :: Type -> Type) event. Lens' (WithSyncStats indexer event) (indexer event) Source #

(Queryable m event query indexer, IsSync m event indexer) => Queryable m event query (WithSyncStats indexer) # 
Instance details

Defined in Marconi.Cardano.Core.Transformer.WithSyncStats

Methods

query :: Point event -> query -> WithSyncStats indexer event -> m (Result query) Source #

queryLatest :: query -> WithSyncStats indexer event -> m (Result query) Source #

(MonadIO m, MonadError IndexerError m, IsIndex m TipAndBlock indexer) => IsIndex m TipAndBlock (WithSyncStats indexer) # 
Instance details

Defined in Marconi.Cardano.Core.Transformer.WithSyncStats

Methods

index :: Timed (Point TipAndBlock) (Maybe TipAndBlock) -> WithSyncStats indexer TipAndBlock -> m (WithSyncStats indexer TipAndBlock) Source #

indexAll :: (Eq (Point TipAndBlock), Traversable f) => f (Timed (Point TipAndBlock) (Maybe TipAndBlock)) -> WithSyncStats indexer TipAndBlock -> m (WithSyncStats indexer TipAndBlock) Source #

indexAllDescending :: (Eq (Point TipAndBlock), Traversable f) => f (Timed (Point TipAndBlock) (Maybe TipAndBlock)) -> WithSyncStats indexer TipAndBlock -> m (WithSyncStats indexer TipAndBlock) Source #

rollback :: Point TipAndBlock -> WithSyncStats indexer TipAndBlock -> m (WithSyncStats indexer TipAndBlock) Source #

setLastStablePoint :: Point TipAndBlock -> WithSyncStats indexer TipAndBlock -> m (WithSyncStats indexer TipAndBlock) Source #

IsSync m event indexer => IsSync m event (WithSyncStats indexer) # 
Instance details

Defined in Marconi.Cardano.Core.Transformer.WithSyncStats

Methods

lastStablePoint :: WithSyncStats indexer event -> m (Point event) Source #

lastSyncPoint :: WithSyncStats indexer event -> m (Point event) Source #

Closeable m indexer => Closeable m (WithSyncStats indexer) # 
Instance details

Defined in Marconi.Cardano.Core.Transformer.WithSyncStats

Methods

close :: WithSyncStats indexer event -> m () Source #

withSyncStats :: [StatsBackend] -> indexer event -> WithSyncStats indexer event #

A smart constructor for WithSyncStats

Stats

data LastSyncStats #

Chain synchronisation statistics measured starting from previously measured LastSyncStats.

Constructors

LastSyncStats !Word64 !Word64 ChainPoint ChainTip !(Maybe UTCTime) 

Instances

Instances details
Show LastSyncStats # 
Instance details

Defined in Marconi.Cardano.Core.Transformer.WithSyncStats

Methods

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

show :: LastSyncStats -> String Source #

showList :: [LastSyncStats] -> ShowS Source #

Eq LastSyncStats # 
Instance details

Defined in Marconi.Cardano.Core.Transformer.WithSyncStats

Methods

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

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

syncStatsNumBlocks :: Lens' LastSyncStats Word64 #

syncStatsNumRollbacks :: Lens' LastSyncStats Word64 #

syncStatsChainSyncPoint :: Lens' LastSyncStats ChainPoint #

syncStatsNodeTip :: Lens' LastSyncStats ChainTip #

syncStatsLastMessageTime :: Lens' LastSyncStats (Maybe UTCTime) #

emptyLastSyncStats :: LastSyncStats #

Backend

data StatsBackend #

The data needed to act upon stats with an arbitrary backend

Constructors

StatsBackend (LastSyncStats -> IO ()) NominalDiffTime LastSyncStats 

statsBackendAction :: Lens' StatsBackend (LastSyncStats -> IO ()) #

statsBackendTimeBetweenActions :: Lens' StatsBackend NominalDiffTime #

statsBackendState :: Lens' StatsBackend LastSyncStats #