Safe Haskell	Safe-Inferred
Language	Haskell2010

Mafoc.Speed

Contents

Measuer local chainsync speed
Rewindable index
Exit loops with exception

Synopsis

data BlockSource
- = Callback {
  - callbackOptionsSocketPath :: String
  - callbackOptionsNodeConfigPath :: String
  - callbackOptionsStart :: Maybe ChainPoint
  - callbackOptionsEnd :: Maybe SlotNo
  }
- | CallbackPipelined {
  - callbackPipelinedOptionsSocketPath :: String
  - callbackPipelinedOptionsNodeConfigPath :: String
  - callbackPipelinedOptionsStart :: Maybe ChainPoint
  - callbackPipelinedOptionsEnd :: Maybe SlotNo
  - callbackPipelinedPipelineSize :: Word32
  }
- | RewindableIndex {
  - rewindableIndexOptionsSocketPath :: String
  - rewindableIndexOptionsStart :: Maybe ChainPoint
  - rewindableIndexOptionsEnd :: Maybe SlotNo
  - rewindableIndexNetworkId :: NetworkId
  }
mkCallback :: (LocalNodeConnectInfo CardanoMode -> ChainPoint -> (ChainSyncEvent (BlockInMode CardanoMode) -> IO ()) -> IO b) -> FilePath -> FilePath -> Maybe ChainPoint -> Maybe SlotNo -> IO b
data NoopHandler = NoopHandler
type NoopIndexer = State NoopHandler
rewindableIndex :: FilePath -> Maybe ChainPoint -> Maybe SlotNo -> NetworkId -> IO ()
printAndDieWhenEnd :: SlotNo -> BlockInMode CardanoMode -> IO ()

Measuer local chainsync speed

data BlockSource #

Constructors

Callback
Fields callbackOptionsSocketPath :: String callbackOptionsNodeConfigPath :: String callbackOptionsStart :: Maybe ChainPoint callbackOptionsEnd :: Maybe SlotNo
CallbackPipelined
Fields callbackPipelinedOptionsSocketPath :: String callbackPipelinedOptionsNodeConfigPath :: String callbackPipelinedOptionsStart :: Maybe ChainPoint callbackPipelinedOptionsEnd :: Maybe SlotNo callbackPipelinedPipelineSize :: Word32
RewindableIndex
Fields rewindableIndexOptionsSocketPath :: String rewindableIndexOptionsStart :: Maybe ChainPoint rewindableIndexOptionsEnd :: Maybe SlotNo rewindableIndexNetworkId :: NetworkId

Instances

Instances details

Show BlockSource #
Instance details Defined in Mafoc.Speed Methods showsPrec :: Int -> BlockSource -> ShowS # show :: BlockSource -> String # showList :: [BlockSource] -> ShowS #

mkCallback :: (LocalNodeConnectInfo CardanoMode -> ChainPoint -> (ChainSyncEvent (BlockInMode CardanoMode) -> IO ()) -> IO b) -> FilePath -> FilePath -> Maybe ChainPoint -> Maybe SlotNo -> IO b #

Rewindable index

data NoopHandler #

Constructors

NoopHandler

Instances

Instances details

Buffered NoopHandler #
Instance details Defined in Mafoc.Speed Methods persistToStorage :: Foldable f => f (StorableEvent NoopHandler) -> NoopHandler -> StorableMonad NoopHandler NoopHandler getStoredEvents :: NoopHandler -> StorableMonad NoopHandler [StorableEvent NoopHandler]
Rewindable NoopHandler #
Instance details Defined in Mafoc.Speed Methods rewindStorage :: StorablePoint NoopHandler -> NoopHandler -> StorableMonad NoopHandler NoopHandler
HasPoint (StorableEvent NoopHandler) ChainPoint #
Instance details Defined in Mafoc.Speed Methods getPoint :: StorableEvent NoopHandler -> ChainPoint
data StorableEvent NoopHandler #
Instance details Defined in Mafoc.Speed data StorableEvent NoopHandler = NoopEvent ChainPoint
type StorableMonad NoopHandler #
Instance details Defined in Mafoc.Speed type StorableMonad NoopHandler = IO
type StorablePoint NoopHandler #
Instance details Defined in Mafoc.Speed type StorablePoint NoopHandler = ChainPoint

type NoopIndexer = State NoopHandler #

rewindableIndex :: FilePath -> Maybe ChainPoint -> Maybe SlotNo -> NetworkId -> IO () #

Exit loops with exception

printAndDieWhenEnd :: SlotNo -> BlockInMode CardanoMode -> IO () #