Safe Haskell	Safe-Inferred
Language	Haskell2010

Mafoc.Core

Contents

Mafoc.Logging
Re-exports from other packages

Synopsis

data DbPathAndTableName = DbPathAndTableName (Maybe FilePath) (Maybe String)
data Interval = Interval {
- from :: (Bool, Either SlotNo ChainPoint)
- upTo :: UpTo
}
data UpTo
- = SlotNo SlotNo
- | Infinity
- | CurrentTip
data ConcurrencyPrimitive
- = MVar
- | Chan
- | TChan
data LocalChainsyncRuntime = LocalChainsyncRuntime {
- localNodeConnection :: LocalNodeConnectInfo CardanoMode
- interval :: (ChainPoint, UpTo)
- securityParam :: SecurityParam
- logging :: Bool
- profiling :: Maybe ProfilingConfig
- pipelineSize :: Word32
- concurrencyPrimitive :: ConcurrencyPrimitive
}
type LocalChainsyncConfig_ = LocalChainsyncConfig (Either NetworkId NodeConfig)
data LocalChainsyncConfig a = LocalChainsyncConfig {
- nodeInfo :: NodeInfo a
- intervalInfo :: (Interval, Maybe DbPathAndTableName)
- logging_ :: Bool
- profiling_ :: Maybe ProfilingConfig
- pipelineSize_ :: Word32
- concurrencyPrimitive_ :: ConcurrencyPrimitive
}
newtype NodeInfo a = NodeInfo (Either NodeFolder (SocketPath, a))
class Indexer a => IndexerHttpApi a where
- type API a
- server :: Runtime a -> MVar (State a, BatchState a) -> Server (API a)
type CheckpointPredicateInterval = UTCTime -> UTCTime -> Bool
data CheckpointInterval
- = Never
- | Every NominalDiffTime
newtype BatchSize = BatchSize Natural
data BatchState a
- = BatchState {
  - lastCheckpointTime :: UTCTime
  - slotNoBhh :: SlotNoBhh
  - indexerState :: State a
  - batchFill :: BatchSize
  - bufferedEvents :: [[Event a]]
  }
- | BatchEmpty {
  - lastCheckpointTime :: UTCTime
  - slotNoBhh :: SlotNoBhh
  - indexerState :: State a
  }
- | NoProgress {
  - chainPointAtStart :: ChainPoint
  - lastCheckpointTime :: UTCTime
  }
type RunIndexer = BatchSize -> Stop -> Checkpoint -> ChainsyncStats -> Severity -> CheckpointInterval -> IO ()
class Indexer a where
- data Runtime a
- data Event a
- data State a
- description :: Text
- parseCli :: Parser a
- toEvents :: Runtime a -> State a -> BlockInMode CardanoMode -> (State a, [Event a])
- initialize :: a -> Trace IO Text -> IO (State a, LocalChainsyncRuntime, Runtime a)
- persistMany :: Runtime a -> [Event a] -> IO ()
- checkpoint :: Runtime a -> State a -> (SlotNo, Hash BlockHeader) -> IO ()
runIndexer :: forall a. (Indexer a, Show a) => a -> Maybe (Runtime a -> MVar (State a, BatchState a) -> IO ()) -> RunIndexer
getBatchFill :: BatchState a -> BatchSize
getBufferedEvents :: BatchState a -> [[Event a]]
persistStep :: forall a. Indexer a => Trace IO Text -> Runtime a -> Checkpoint -> BatchSize -> CheckpointPredicateInterval -> BatchState a -> (SlotNoBhh, [Event a], State a) -> IO (BatchState a)
persistStepFinal :: Indexer a => Runtime a -> BatchState a -> Trace IO Text -> IO (Maybe ChainPoint)
checkpointIntervalPredicate :: CheckpointInterval -> CheckpointPredicateInterval
initialNotice :: Show a => a -> BatchSize -> Severity -> CheckpointInterval -> Trace IO Text -> IO ()
modifyStartingPoint :: LocalChainsyncRuntime -> (ChainPoint -> ChainPoint) -> LocalChainsyncRuntime
initializeLocalChainsync :: LocalChainsyncConfig a -> NetworkId -> Trace IO Text -> IO LocalChainsyncRuntime
initializeLocalChainsync_ :: LocalChainsyncConfig_ -> Trace IO Text -> IO LocalChainsyncRuntime
rollbackRingBuffer :: SecurityParam -> Stream (Of (ChainSyncEvent (BlockInMode CardanoMode))) IO () -> Stream (Of (BlockInMode CardanoMode)) IO ()
blockProducer :: forall r. LocalNodeConnectInfo CardanoMode -> Word32 -> ChainPoint -> ConcurrencyPrimitive -> Stream (Of (ChainSyncEvent (BlockInMode CardanoMode))) IO r
takeUpTo :: Trace IO Text -> UpTo -> Stop -> Stream (Of (ChainSyncEvent (BlockInMode mode))) IO () -> Stream (Of (ChainSyncEvent (BlockInMode mode))) IO ()
loadLatestTrace :: String -> IO a -> (FilePath -> IO a) -> Trace IO Text -> IO (a, ChainPoint)
query1 :: (ToField q, FromRow r) => Connection -> Query -> q -> IO [r]
mkParam :: ToField v => Query -> Text -> v -> (NamedParam, Query)
andFilters :: [Query] -> Query
defaultTableName :: String -> DbPathAndTableName -> (FilePath, String)
sqliteInitCheckpoints :: Connection -> IO ()
setCheckpointSqlite :: Connection -> String -> (SlotNo, Hash BlockHeader) -> IO ()
getCheckpointSqlite :: Connection -> String -> IO (Maybe ChainPoint)
initializeSqlite :: FilePath -> String -> IO (Connection, ChainPoint)
sqliteOpen :: FilePath -> IO Connection
eventsToSingleChainpoint :: [(SlotNo, Hash BlockHeader)] -> Maybe ChainPoint
chainPointForSlotNo :: Connection -> String -> SlotNo -> IO (Maybe ChainPoint)
previousChainPointForSlotNo :: Connection -> String -> SlotNo -> IO (Maybe ChainPoint)
intervalStartToChainSyncStart :: Trace IO Text -> Maybe DbPathAndTableName -> (Bool, Either SlotNo ChainPoint) -> IO ChainPoint
mkMaybeAddressFilter :: [Address ShelleyAddr] -> Maybe (Address ShelleyAddr -> Bool)
todo :: a
data TxIndexInBlock
data LedgerEra
newtype SocketPath = SocketPath FilePath
newtype NodeConfig = NodeConfig FilePath
newtype NodeFolder = NodeFolder FilePath
type SlotNoBhh = (SlotNo, Hash BlockHeader)
getSecurityParamAndNetworkId :: FilePath -> IO (SecurityParam, NetworkId)
getNetworkId :: FilePath -> IO NetworkId
tipDistance :: BlockInMode mode -> ChainTip -> Natural
querySecurityParam :: LocalNodeConnectInfo CardanoMode -> IO SecurityParam
blockChainPoint :: BlockInMode mode -> ChainPoint
blockSlotNoBhh :: BlockInMode mode -> SlotNoBhh
blockSlotNo :: BlockInMode mode -> SlotNo
chainPointSlotNo :: ChainPoint -> SlotNo
foldYield :: Monad m => (st -> a -> m (st, b)) -> st -> Stream (Of a) m r -> Stream (Of b) m r
defaultConfigStderrSeverity :: Severity -> IO Configuration
slotEra :: SlotNo -> LedgerEra
allDatums :: Tx era -> [(Hash ScriptData, ScriptData)]
plutusDatums :: [Tx era] -> [(Hash ScriptData, ScriptData)]
txPlutusDatums :: Tx era -> [(Hash ScriptData, ScriptData)]
txAddressDatums :: Tx era -> [(AddressAny, Either (Hash ScriptData) (Hash ScriptData, ScriptData))]
txDatums :: Tx era -> [Either (Hash ScriptData) (Hash ScriptData, ScriptData)]
maybeDatum :: TxOut CtxTx era -> Maybe (Either (Hash ScriptData) (Hash ScriptData, ScriptData))
newtype AssetIdString = AssetIdString AssetId
newtype SlotNoBhhString = SlotNoBhhString SlotNoBhh
renderPretty :: Pretty a => a -> Text
traceInfo :: Trace IO Text -> Doc () -> IO ()
type CurrentEra = BabbageEra

Documentation

data DbPathAndTableName #

Constructors

DbPathAndTableName (Maybe FilePath) (Maybe String)

Instances

Instances details

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

data Interval #

Constructors

Interval
Fields from :: (Bool, Either SlotNo ChainPoint) upTo :: UpTo

Instances

Instances details

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

data UpTo #

Constructors

SlotNo SlotNo
Infinity
CurrentTip

Instances

Instances details

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

data ConcurrencyPrimitive #

This is a very internal data type to help swap the concurrency primitive used to pass blocks from the local chainsync's green thread to the indexer.

Constructors

MVar
Chan
TChan

Instances

Instances details

Bounded ConcurrencyPrimitive #
Instance details Defined in Mafoc.Core Methods minBound :: ConcurrencyPrimitive # maxBound :: ConcurrencyPrimitive #
Enum ConcurrencyPrimitive #
Instance details Defined in Mafoc.Core Methods succ :: ConcurrencyPrimitive -> ConcurrencyPrimitive # pred :: ConcurrencyPrimitive -> ConcurrencyPrimitive # toEnum :: Int -> ConcurrencyPrimitive # fromEnum :: ConcurrencyPrimitive -> Int # enumFrom :: ConcurrencyPrimitive -> [ConcurrencyPrimitive] # enumFromThen :: ConcurrencyPrimitive -> ConcurrencyPrimitive -> [ConcurrencyPrimitive] # enumFromTo :: ConcurrencyPrimitive -> ConcurrencyPrimitive -> [ConcurrencyPrimitive] # enumFromThenTo :: ConcurrencyPrimitive -> ConcurrencyPrimitive -> ConcurrencyPrimitive -> [ConcurrencyPrimitive] #
Read ConcurrencyPrimitive #
Instance details Defined in Mafoc.Core Methods readsPrec :: Int -> ReadS ConcurrencyPrimitive # readList :: ReadS [ConcurrencyPrimitive] # readPrec :: ReadPrec ConcurrencyPrimitive # readListPrec :: ReadPrec [ConcurrencyPrimitive] #
Show ConcurrencyPrimitive #
Instance details Defined in Mafoc.Core Methods showsPrec :: Int -> ConcurrencyPrimitive -> ShowS # show :: ConcurrencyPrimitive -> String # showList :: [ConcurrencyPrimitive] -> ShowS #

data LocalChainsyncRuntime #

Static configuration for block source

Constructors

LocalChainsyncRuntime
Fields localNodeConnection :: LocalNodeConnectInfo CardanoMode interval :: (ChainPoint, UpTo) securityParam :: SecurityParam logging :: Bool profiling :: Maybe ProfilingConfig pipelineSize :: Word32 concurrencyPrimitive :: ConcurrencyPrimitive

type LocalChainsyncConfig_ = LocalChainsyncConfig (Either NetworkId NodeConfig) #

data LocalChainsyncConfig a #

Configuration for local chainsync streaming setup.

Constructors

LocalChainsyncConfig
Fields nodeInfo :: NodeInfo a intervalInfo :: (Interval, Maybe DbPathAndTableName) logging_ :: Bool profiling_ :: Maybe ProfilingConfig pipelineSize_ :: Word32 concurrencyPrimitive_ :: ConcurrencyPrimitive

Instances

Instances details

IsLabel "getNetworkId" (LocalChainsyncConfig NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig NodeConfig -> IO NetworkId #
IsLabel "getNetworkId" (LocalChainsyncConfig_ -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig_ -> IO NetworkId #
IsLabel "nodeConfig" (LocalChainsyncConfig NodeConfig -> NodeConfig) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig NodeConfig -> NodeConfig #
IsLabel "socketPath" (LocalChainsyncConfig a -> SocketPath) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig a -> SocketPath #
Show a => Show (LocalChainsyncConfig a) #
Instance details Defined in Mafoc.Core Methods showsPrec :: Int -> LocalChainsyncConfig a -> ShowS # show :: LocalChainsyncConfig a -> String # showList :: [LocalChainsyncConfig a] -> ShowS #

newtype NodeInfo a #

Constructors

NodeInfo (Either NodeFolder (SocketPath, a))

Instances

Instances details

IsLabel "getNetworkId" (NodeInfo NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo NodeConfig -> IO NetworkId #
IsLabel "nodeConfig" (NodeInfo NodeConfig -> NodeConfig) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo NodeConfig -> NodeConfig #
IsLabel "socketPath" (NodeInfo a -> SocketPath) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo a -> SocketPath #
Show a => Show (NodeInfo a) #
Instance details Defined in Mafoc.Core Methods showsPrec :: Int -> NodeInfo a -> ShowS # show :: NodeInfo a -> String # showList :: [NodeInfo a] -> ShowS #

class Indexer a => IndexerHttpApi a where #

Associated Types

type API a #

Methods

server :: Runtime a -> MVar (State a, BatchState a) -> Server (API a) #

Instances

Instances details

IndexerHttpApi Mamba #
Instance details Defined in Mafoc.Indexers.Mamba Associated Types type API Mamba # Methods server :: Runtime Mamba -> MVar (State Mamba, BatchState Mamba) -> Server (API Mamba) #

type CheckpointPredicateInterval = UTCTime -> UTCTime -> Bool #

data CheckpointInterval #

Constructors

Never
Every NominalDiffTime

Instances

Instances details

Show CheckpointInterval #
Instance details Defined in Mafoc.Core Methods showsPrec :: Int -> CheckpointInterval -> ShowS # show :: CheckpointInterval -> String # showList :: [CheckpointInterval] -> ShowS #
Eq CheckpointInterval #
Instance details Defined in Mafoc.Core Methods (==) :: CheckpointInterval -> CheckpointInterval -> Bool # (/=) :: CheckpointInterval -> CheckpointInterval -> Bool #

newtype BatchSize #

Constructors

BatchSize Natural

Instances

Instances details

Enum BatchSize #
Instance details Defined in Mafoc.Core Methods succ :: BatchSize -> BatchSize # pred :: BatchSize -> BatchSize # toEnum :: Int -> BatchSize # fromEnum :: BatchSize -> Int # enumFrom :: BatchSize -> [BatchSize] # enumFromThen :: BatchSize -> BatchSize -> [BatchSize] # enumFromTo :: BatchSize -> BatchSize -> [BatchSize] # enumFromThenTo :: BatchSize -> BatchSize -> BatchSize -> [BatchSize] #
Num BatchSize #
Instance details Defined in Mafoc.Core Methods (+) :: BatchSize -> BatchSize -> BatchSize # (-) :: BatchSize -> BatchSize -> BatchSize # (*) :: BatchSize -> BatchSize -> BatchSize # negate :: BatchSize -> BatchSize # abs :: BatchSize -> BatchSize # signum :: BatchSize -> BatchSize # fromInteger :: Integer -> BatchSize #
Read BatchSize #
Instance details Defined in Mafoc.Core Methods readsPrec :: Int -> ReadS BatchSize # readList :: ReadS [BatchSize] # readPrec :: ReadPrec BatchSize # readListPrec :: ReadPrec [BatchSize] #
Show BatchSize #
Instance details Defined in Mafoc.Core Methods showsPrec :: Int -> BatchSize -> ShowS # show :: BatchSize -> String # showList :: [BatchSize] -> ShowS #
Eq BatchSize #
Instance details Defined in Mafoc.Core Methods (==) :: BatchSize -> BatchSize -> Bool # (/=) :: BatchSize -> BatchSize -> Bool #
Ord BatchSize #
Instance details Defined in Mafoc.Core Methods compare :: BatchSize -> BatchSize -> Ordering # (<) :: BatchSize -> BatchSize -> Bool # (<=) :: BatchSize -> BatchSize -> Bool # (>) :: BatchSize -> BatchSize -> Bool # (>=) :: BatchSize -> BatchSize -> Bool # max :: BatchSize -> BatchSize -> BatchSize # min :: BatchSize -> BatchSize -> BatchSize #

data BatchState a #

Constructors

BatchState
Fields lastCheckpointTime :: UTCTime slotNoBhh :: SlotNoBhh indexerState :: State a batchFill :: BatchSize bufferedEvents :: [[Event a]]
BatchEmpty
Fields lastCheckpointTime :: UTCTime slotNoBhh :: SlotNoBhh indexerState :: State a
NoProgress
Fields chainPointAtStart :: ChainPoint lastCheckpointTime :: UTCTime

type RunIndexer = BatchSize -> Stop -> Checkpoint -> ChainsyncStats -> Severity -> CheckpointInterval -> IO () #

class Indexer a where #

Class for an indexer. The argument a doubles as both a type representation (a "tag") for the indexer, and also as the initial configuration required to run the indexer.

Associated Types

data Runtime a #

The a itself doubles as cli configuration, no need for the following: type Config a = r | r -> a

Runtime configuration, i.e the reader for the indexer, used for e.g the db connection, for communication with other threads (respond to queries).

data Event a #

Event type, i.e the "business requirement". Any input block is converted to zero or more events which are then to be persisted.

data State a #

The fold state. Some don't require a state so, for those it's defined as a data type with no fields, equivalent to unit. As a consequence these indexers can be resumed from arbitrary chain points on request.

Methods

description :: Text #

A text description of the indexer, used for help messages.

parseCli :: Parser a #

A CLI parser for a.

toEvents :: Runtime a -> State a -> BlockInMode CardanoMode -> (State a, [Event a]) #

Convert a state and a block to events and a new state.

initialize :: a -> Trace IO Text -> IO (State a, LocalChainsyncRuntime, Runtime a) #

Initialize an indexer from a to a runtime for local chainsync, indexer's runtime configuration and the indexer state.

persistMany :: Runtime a -> [Event a] -> IO () #

Persist many events at a time, defaults to mapping over events with persist.

checkpoint :: Runtime a -> State a -> (SlotNo, Hash BlockHeader) -> IO () #

Checkpoint indexer by writing the chain point and the state at that point, destination being provided by the runtime. Checkpoints are used for resuming

Instances

Instances details

Indexer AddressBalance #
Instance details Defined in Mafoc.Indexers.AddressBalance Associated Types data Runtime AddressBalance # data Event AddressBalance # data State AddressBalance # Methods description :: Text # parseCli :: Parser AddressBalance # toEvents :: Runtime AddressBalance -> State AddressBalance -> BlockInMode CardanoMode -> (State AddressBalance, [Event AddressBalance]) # initialize :: AddressBalance -> Trace IO Text -> IO (State AddressBalance, LocalChainsyncRuntime, Runtime AddressBalance) # persistMany :: Runtime AddressBalance -> [Event AddressBalance] -> IO () # checkpoint :: Runtime AddressBalance -> State AddressBalance -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer AddressDatum #
Instance details Defined in Mafoc.Indexers.AddressDatum Associated Types data Runtime AddressDatum # data Event AddressDatum # data State AddressDatum # Methods description :: Text # parseCli :: Parser AddressDatum # toEvents :: Runtime AddressDatum -> State AddressDatum -> BlockInMode CardanoMode -> (State AddressDatum, [Event AddressDatum]) # initialize :: AddressDatum -> Trace IO Text -> IO (State AddressDatum, LocalChainsyncRuntime, Runtime AddressDatum) # persistMany :: Runtime AddressDatum -> [Event AddressDatum] -> IO () # checkpoint :: Runtime AddressDatum -> State AddressDatum -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer BlockBasics #
Instance details Defined in Mafoc.Indexers.BlockBasics Associated Types data Runtime BlockBasics # data Event BlockBasics # data State BlockBasics # Methods description :: Text # parseCli :: Parser BlockBasics # toEvents :: Runtime BlockBasics -> State BlockBasics -> BlockInMode CardanoMode -> (State BlockBasics, [Event BlockBasics]) # initialize :: BlockBasics -> Trace IO Text -> IO (State BlockBasics, LocalChainsyncRuntime, Runtime BlockBasics) # persistMany :: Runtime BlockBasics -> [Event BlockBasics] -> IO () # checkpoint :: Runtime BlockBasics -> State BlockBasics -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer Datum #
Instance details Defined in Mafoc.Indexers.Datum Associated Types data Runtime Datum # data Event Datum # data State Datum # Methods description :: Text # parseCli :: Parser Datum # toEvents :: Runtime Datum -> State Datum -> BlockInMode CardanoMode -> (State Datum, [Event Datum]) # initialize :: Datum -> Trace IO Text -> IO (State Datum, LocalChainsyncRuntime, Runtime Datum) # persistMany :: Runtime Datum -> [Event Datum] -> IO () # checkpoint :: Runtime Datum -> State Datum -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer Deposit #
Instance details Defined in Mafoc.Indexers.Deposit Associated Types data Runtime Deposit # data Event Deposit # data State Deposit # Methods description :: Text # parseCli :: Parser Deposit # toEvents :: Runtime Deposit -> State Deposit -> BlockInMode CardanoMode -> (State Deposit, [Event Deposit]) # initialize :: Deposit -> Trace IO Text -> IO (State Deposit, LocalChainsyncRuntime, Runtime Deposit) # persistMany :: Runtime Deposit -> [Event Deposit] -> IO () # checkpoint :: Runtime Deposit -> State Deposit -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer EpochNonce #
Instance details Defined in Mafoc.Indexers.EpochNonce Associated Types data Runtime EpochNonce # data Event EpochNonce # data State EpochNonce # Methods description :: Text # parseCli :: Parser EpochNonce # toEvents :: Runtime EpochNonce -> State EpochNonce -> BlockInMode CardanoMode -> (State EpochNonce, [Event EpochNonce]) # initialize :: EpochNonce -> Trace IO Text -> IO (State EpochNonce, LocalChainsyncRuntime, Runtime EpochNonce) # persistMany :: Runtime EpochNonce -> [Event EpochNonce] -> IO () # checkpoint :: Runtime EpochNonce -> State EpochNonce -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer EpochStakepoolSize #
Instance details Defined in Mafoc.Indexers.EpochStakepoolSize Associated Types data Runtime EpochStakepoolSize # data Event EpochStakepoolSize # data State EpochStakepoolSize # Methods description :: Text # parseCli :: Parser EpochStakepoolSize # toEvents :: Runtime EpochStakepoolSize -> State EpochStakepoolSize -> BlockInMode CardanoMode -> (State EpochStakepoolSize, [Event EpochStakepoolSize]) # initialize :: EpochStakepoolSize -> Trace IO Text -> IO (State EpochStakepoolSize, LocalChainsyncRuntime, Runtime EpochStakepoolSize) # persistMany :: Runtime EpochStakepoolSize -> [Event EpochStakepoolSize] -> IO () # checkpoint :: Runtime EpochStakepoolSize -> State EpochStakepoolSize -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer Mamba #
Instance details Defined in Mafoc.Indexers.Mamba Associated Types data Runtime Mamba # data Event Mamba # data State Mamba # Methods description :: Text # parseCli :: Parser Mamba # toEvents :: Runtime Mamba -> State Mamba -> BlockInMode CardanoMode -> (State Mamba, [Event Mamba]) # initialize :: Mamba -> Trace IO Text -> IO (State Mamba, LocalChainsyncRuntime, Runtime Mamba) # persistMany :: Runtime Mamba -> [Event Mamba] -> IO () # checkpoint :: Runtime Mamba -> State Mamba -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer MintBurn #
Instance details Defined in Mafoc.Indexers.MintBurn Associated Types data Runtime MintBurn # data Event MintBurn # data State MintBurn # Methods description :: Text # parseCli :: Parser MintBurn # toEvents :: Runtime MintBurn -> State MintBurn -> BlockInMode CardanoMode -> (State MintBurn, [Event MintBurn]) # initialize :: MintBurn -> Trace IO Text -> IO (State MintBurn, LocalChainsyncRuntime, Runtime MintBurn) # persistMany :: Runtime MintBurn -> [Event MintBurn] -> IO () # checkpoint :: Runtime MintBurn -> State MintBurn -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer NoOp #
Instance details Defined in Mafoc.Indexers.NoOp Associated Types data Runtime NoOp # data Event NoOp # data State NoOp # Methods description :: Text # parseCli :: Parser NoOp # toEvents :: Runtime NoOp -> State NoOp -> BlockInMode CardanoMode -> (State NoOp, [Event NoOp]) # initialize :: NoOp -> Trace IO Text -> IO (State NoOp, LocalChainsyncRuntime, Runtime NoOp) # persistMany :: Runtime NoOp -> [Event NoOp] -> IO () # checkpoint :: Runtime NoOp -> State NoOp -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer ScriptTx #
Instance details Defined in Mafoc.Indexers.ScriptTx Associated Types data Runtime ScriptTx # data Event ScriptTx # data State ScriptTx # Methods description :: Text # parseCli :: Parser ScriptTx # toEvents :: Runtime ScriptTx -> State ScriptTx -> BlockInMode CardanoMode -> (State ScriptTx, [Event ScriptTx]) # initialize :: ScriptTx -> Trace IO Text -> IO (State ScriptTx, LocalChainsyncRuntime, Runtime ScriptTx) # persistMany :: Runtime ScriptTx -> [Event ScriptTx] -> IO () # checkpoint :: Runtime ScriptTx -> State ScriptTx -> (SlotNo, Hash BlockHeader) -> IO () #
Indexer Utxo #
Instance details Defined in Mafoc.Indexers.Utxo Associated Types data Runtime Utxo # data Event Utxo # data State Utxo # Methods description :: Text # parseCli :: Parser Utxo # toEvents :: Runtime Utxo -> State Utxo -> BlockInMode CardanoMode -> (State Utxo, [Event Utxo]) # initialize :: Utxo -> Trace IO Text -> IO (State Utxo, LocalChainsyncRuntime, Runtime Utxo) # persistMany :: Runtime Utxo -> [Event Utxo] -> IO () # checkpoint :: Runtime Utxo -> State Utxo -> (SlotNo, Hash BlockHeader) -> IO () #

runIndexer :: forall a. (Indexer a, Show a) => a -> Maybe (Runtime a -> MVar (State a, BatchState a) -> IO ()) -> RunIndexer #

Run an indexer

getBatchFill :: BatchState a -> BatchSize #

getBufferedEvents :: BatchState a -> [[Event a]] #

persistStep :: forall a. Indexer a => Trace IO Text -> Runtime a -> Checkpoint -> BatchSize -> CheckpointPredicateInterval -> BatchState a -> (SlotNoBhh, [Event a], State a) -> IO (BatchState a) #

persistStepFinal :: Indexer a => Runtime a -> BatchState a -> Trace IO Text -> IO (Maybe ChainPoint) #

checkpointIntervalPredicate :: CheckpointInterval -> CheckpointPredicateInterval #

initialNotice :: Show a => a -> BatchSize -> Severity -> CheckpointInterval -> Trace IO Text -> IO () #

modifyStartingPoint :: LocalChainsyncRuntime -> (ChainPoint -> ChainPoint) -> LocalChainsyncRuntime #

initializeLocalChainsync :: LocalChainsyncConfig a -> NetworkId -> Trace IO Text -> IO LocalChainsyncRuntime #

initializeLocalChainsync_ :: LocalChainsyncConfig_ -> Trace IO Text -> IO LocalChainsyncRuntime #

Resolve LocalChainsyncConfig that came from e.g command line arguments into an "actionable" LocalChainsyncRuntime runtime config which can be used to generate a stream of blocks.

rollbackRingBuffer :: SecurityParam -> Stream (Of (ChainSyncEvent (BlockInMode CardanoMode))) IO () -> Stream (Of (BlockInMode CardanoMode)) IO () #

blockProducer :: forall r. LocalNodeConnectInfo CardanoMode -> Word32 -> ChainPoint -> ConcurrencyPrimitive -> Stream (Of (ChainSyncEvent (BlockInMode CardanoMode))) IO r #

takeUpTo :: Trace IO Text -> UpTo -> Stop -> Stream (Of (ChainSyncEvent (BlockInMode mode))) IO () -> Stream (Of (ChainSyncEvent (BlockInMode mode))) IO () #

loadLatestTrace :: String -> IO a -> (FilePath -> IO a) -> Trace IO Text -> IO (a, ChainPoint) #

query1 :: (ToField q, FromRow r) => Connection -> Query -> q -> IO [r] #

Helper to query with a single param

mkParam :: ToField v => Query -> Text -> v -> (NamedParam, Query) #

andFilters :: [Query] -> Query #

Convert [":field1 = field1", ":field2 = field2"] into ":field1 = field1 AND :field2 = field2"

defaultTableName :: String -> DbPathAndTableName -> (FilePath, String) #

sqliteInitCheckpoints :: Connection -> IO () #

setCheckpointSqlite :: Connection -> String -> (SlotNo, Hash BlockHeader) -> IO () #

getCheckpointSqlite :: Connection -> String -> IO (Maybe ChainPoint) #

Get checkpoint (the place where we left off) for an indexer with name

initializeSqlite :: FilePath -> String -> IO (Connection, ChainPoint) #

If ChainPointAtGenesis is returned, then there was no chain point in the database.

sqliteOpen :: FilePath -> IO Connection #

eventsToSingleChainpoint :: [(SlotNo, Hash BlockHeader)] -> Maybe ChainPoint #

chainPointForSlotNo :: Connection -> String -> SlotNo -> IO (Maybe ChainPoint) #

previousChainPointForSlotNo :: Connection -> String -> SlotNo -> IO (Maybe ChainPoint) #

intervalStartToChainSyncStart :: Trace IO Text -> Maybe DbPathAndTableName -> (Bool, Either SlotNo ChainPoint) -> IO ChainPoint #

Convert starting point from CLI to chainpoint, possibly with the help of header DB.

mkMaybeAddressFilter :: [Address ShelleyAddr] -> Maybe (Address ShelleyAddr -> Bool) #

todo :: a #

data TxIndexInBlock #

Instances

Instances details

FromJSON TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods parseJSON :: Value -> Parser TxIndexInBlock parseJSONList :: Value -> Parser [TxIndexInBlock]
ToJSON TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods toJSON :: TxIndexInBlock -> Value toEncoding :: TxIndexInBlock -> Encoding toJSONList :: [TxIndexInBlock] -> Value toEncodingList :: [TxIndexInBlock] -> Encoding
Enum TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods succ :: TxIndexInBlock -> TxIndexInBlock # pred :: TxIndexInBlock -> TxIndexInBlock # toEnum :: Int -> TxIndexInBlock # fromEnum :: TxIndexInBlock -> Int # enumFrom :: TxIndexInBlock -> [TxIndexInBlock] # enumFromThen :: TxIndexInBlock -> TxIndexInBlock -> [TxIndexInBlock] # enumFromTo :: TxIndexInBlock -> TxIndexInBlock -> [TxIndexInBlock] # enumFromThenTo :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock -> [TxIndexInBlock] #
Num TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods (+) :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # (-) :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # (*) :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # negate :: TxIndexInBlock -> TxIndexInBlock # abs :: TxIndexInBlock -> TxIndexInBlock # signum :: TxIndexInBlock -> TxIndexInBlock # fromInteger :: Integer -> TxIndexInBlock #
Show TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> TxIndexInBlock -> ShowS # show :: TxIndexInBlock -> String # showList :: [TxIndexInBlock] -> ShowS #
FromCBOR TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods fromCBOR :: Decoder s TxIndexInBlock label :: Proxy TxIndexInBlock -> Text
ToCBOR TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods toCBOR :: TxIndexInBlock -> Encoding encodedSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy TxIndexInBlock -> Size encodedListSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy [TxIndexInBlock] -> Size
Eq TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods (==) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (/=) :: TxIndexInBlock -> TxIndexInBlock -> Bool #
Ord TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods compare :: TxIndexInBlock -> TxIndexInBlock -> Ordering # (<) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (<=) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (>) :: TxIndexInBlock -> TxIndexInBlock -> Bool # (>=) :: TxIndexInBlock -> TxIndexInBlock -> Bool # max :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock # min :: TxIndexInBlock -> TxIndexInBlock -> TxIndexInBlock #
FromField TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods fromField :: FieldParser TxIndexInBlock
ToField TxIndexInBlock #
Instance details Defined in Mafoc.Upstream Methods toField :: TxIndexInBlock -> SQLData

data LedgerEra #

Instances

Instances details

ToJSON LedgerEra #
Instance details Defined in Mafoc.Upstream Methods toJSON :: LedgerEra -> Value toEncoding :: LedgerEra -> Encoding toJSONList :: [LedgerEra] -> Value toEncodingList :: [LedgerEra] -> Encoding
Bounded LedgerEra #
Instance details Defined in Mafoc.Upstream Methods minBound :: LedgerEra # maxBound :: LedgerEra #
Enum LedgerEra #
Instance details Defined in Mafoc.Upstream Methods succ :: LedgerEra -> LedgerEra # pred :: LedgerEra -> LedgerEra # toEnum :: Int -> LedgerEra # fromEnum :: LedgerEra -> Int # enumFrom :: LedgerEra -> [LedgerEra] # enumFromThen :: LedgerEra -> LedgerEra -> [LedgerEra] # enumFromTo :: LedgerEra -> LedgerEra -> [LedgerEra] # enumFromThenTo :: LedgerEra -> LedgerEra -> LedgerEra -> [LedgerEra] #
Generic LedgerEra #
Instance details Defined in Mafoc.Upstream Associated Types type Rep LedgerEra :: Type -> Type # Methods from :: LedgerEra -> Rep LedgerEra x # to :: Rep LedgerEra x -> LedgerEra #
Show LedgerEra #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> LedgerEra -> ShowS # show :: LedgerEra -> String # showList :: [LedgerEra] -> ShowS #
Eq LedgerEra #
Instance details Defined in Mafoc.Upstream Methods (==) :: LedgerEra -> LedgerEra -> Bool # (/=) :: LedgerEra -> LedgerEra -> Bool #
Ord LedgerEra #
Instance details Defined in Mafoc.Upstream Methods compare :: LedgerEra -> LedgerEra -> Ordering # (<) :: LedgerEra -> LedgerEra -> Bool # (<=) :: LedgerEra -> LedgerEra -> Bool # (>) :: LedgerEra -> LedgerEra -> Bool # (>=) :: LedgerEra -> LedgerEra -> Bool # max :: LedgerEra -> LedgerEra -> LedgerEra # min :: LedgerEra -> LedgerEra -> LedgerEra #
type Rep LedgerEra #
Instance details Defined in Mafoc.Upstream type Rep LedgerEra = D1 ('MetaData "LedgerEra" "Mafoc.Upstream" "mafoc-0.0.0.1-inplace" 'False) ((C1 ('MetaCons "Byron" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "Shelley" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Allegra" 'PrefixI 'False) (U1 :: Type -> Type))) :+: (C1 ('MetaCons "Mary" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "Alonzo" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Babbage" 'PrefixI 'False) (U1 :: Type -> Type))))

newtype SocketPath #

Constructors

SocketPath FilePath

Instances

Instances details

IsString SocketPath #
Instance details Defined in Mafoc.Upstream Methods fromString :: String -> SocketPath #
Show SocketPath #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> SocketPath -> ShowS # show :: SocketPath -> String # showList :: [SocketPath] -> ShowS #
IsLabel "socketPath" (LocalChainsyncConfig a -> SocketPath) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig a -> SocketPath #
IsLabel "socketPath" (NodeInfo a -> SocketPath) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo a -> SocketPath #

newtype NodeConfig #

Constructors

NodeConfig FilePath

Instances

Instances details

IsString NodeConfig #
Instance details Defined in Mafoc.Upstream Methods fromString :: String -> NodeConfig #
Show NodeConfig #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> NodeConfig -> ShowS # show :: NodeConfig -> String # showList :: [NodeConfig] -> ShowS #
IsLabel "getNetworkId" (LocalChainsyncConfig NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig NodeConfig -> IO NetworkId #
IsLabel "getNetworkId" (LocalChainsyncConfig_ -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig_ -> IO NetworkId #
IsLabel "getNetworkId" (NodeInfo NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo NodeConfig -> IO NetworkId #
IsLabel "getNetworkId" (NodeConfig -> IO NetworkId) #
Instance details Defined in Mafoc.Upstream Methods fromLabel :: NodeConfig -> IO NetworkId #
IsLabel "nodeConfig" (LocalChainsyncConfig NodeConfig -> NodeConfig) #
Instance details Defined in Mafoc.Core Methods fromLabel :: LocalChainsyncConfig NodeConfig -> NodeConfig #
IsLabel "nodeConfig" (NodeInfo NodeConfig -> NodeConfig) #
Instance details Defined in Mafoc.Core Methods fromLabel :: NodeInfo NodeConfig -> NodeConfig #
IsLabel "nodeConfig" (NodeFolder -> NodeConfig) #
Instance details Defined in Mafoc.Upstream Methods fromLabel :: NodeFolder -> NodeConfig #

newtype NodeFolder #

Not sure if anyone actually wants these upstreamed

Constructors

NodeFolder FilePath

Instances

Instances details

IsString NodeFolder #
Instance details Defined in Mafoc.Upstream Methods fromString :: String -> NodeFolder #
Show NodeFolder #
Instance details Defined in Mafoc.Upstream Methods showsPrec :: Int -> NodeFolder -> ShowS # show :: NodeFolder -> String # showList :: [NodeFolder] -> ShowS #
IsLabel "nodeConfig" (NodeFolder -> NodeConfig) #
Instance details Defined in Mafoc.Upstream Methods fromLabel :: NodeFolder -> NodeConfig #

type SlotNoBhh = (SlotNo, Hash BlockHeader) #

getSecurityParamAndNetworkId :: FilePath -> IO (SecurityParam, NetworkId) #

getNetworkId :: FilePath -> IO NetworkId #

tipDistance :: BlockInMode mode -> ChainTip -> Natural #

querySecurityParam :: LocalNodeConnectInfo CardanoMode -> IO SecurityParam #

blockChainPoint :: BlockInMode mode -> ChainPoint #

Create a ChainPoint from BlockInMode

blockSlotNoBhh :: BlockInMode mode -> SlotNoBhh #

blockSlotNo :: BlockInMode mode -> SlotNo #

chainPointSlotNo :: ChainPoint -> SlotNo #

foldYield :: Monad m => (st -> a -> m (st, b)) -> st -> Stream (Of a) m r -> Stream (Of b) m r #

Fold a stream of a's, yield a stream of bs, while keeping a state of @st".

defaultConfigStderrSeverity :: Severity -> IO Configuration #

slotEra :: SlotNo -> LedgerEra #

allDatums :: Tx era -> [(Hash ScriptData, ScriptData)] #

plutusDatums :: [Tx era] -> [(Hash ScriptData, ScriptData)] #

Get a map of datum hash to datum from a list of transactions.

txPlutusDatums :: Tx era -> [(Hash ScriptData, ScriptData)] #

txAddressDatums :: Tx era -> [(AddressAny, Either (Hash ScriptData) (Hash ScriptData, ScriptData))] #

txDatums :: Tx era -> [Either (Hash ScriptData) (Hash ScriptData, ScriptData)] #

maybeDatum :: TxOut CtxTx era -> Maybe (Either (Hash ScriptData) (Hash ScriptData, ScriptData)) #

newtype AssetIdString #

Newtype of AssetId which renders as "policyId.assetName"

Constructors

AssetIdString AssetId

Instances

Instances details

ToJSON AssetIdString #
Instance details Defined in Mafoc.Upstream.Formats Methods toJSON :: AssetIdString -> Value toEncoding :: AssetIdString -> Encoding toJSONList :: [AssetIdString] -> Value toEncodingList :: [AssetIdString] -> Encoding
ToJSONKey AssetIdString #
Instance details Defined in Mafoc.Upstream.Formats Methods toJSONKey :: ToJSONKeyFunction AssetIdString toJSONKeyList :: ToJSONKeyFunction [AssetIdString]
Eq AssetIdString #
Instance details Defined in Mafoc.Upstream.Formats Methods (==) :: AssetIdString -> AssetIdString -> Bool # (/=) :: AssetIdString -> AssetIdString -> Bool #
Ord AssetIdString #
Instance details Defined in Mafoc.Upstream.Formats Methods compare :: AssetIdString -> AssetIdString -> Ordering # (<) :: AssetIdString -> AssetIdString -> Bool # (<=) :: AssetIdString -> AssetIdString -> Bool # (>) :: AssetIdString -> AssetIdString -> Bool # (>=) :: AssetIdString -> AssetIdString -> Bool # max :: AssetIdString -> AssetIdString -> AssetIdString # min :: AssetIdString -> AssetIdString -> AssetIdString #

newtype SlotNoBhhString #

Constructors

SlotNoBhhString SlotNoBhh

Instances

Instances details

ToJSON SlotNoBhhString #
Instance details Defined in Mafoc.Upstream.Formats Methods toJSON :: SlotNoBhhString -> Value toEncoding :: SlotNoBhhString -> Encoding toJSONList :: [SlotNoBhhString] -> Value toEncodingList :: [SlotNoBhhString] -> Encoding
ToJSONKey SlotNoBhhString #
Instance details Defined in Mafoc.Upstream.Formats Methods toJSONKey :: ToJSONKeyFunction SlotNoBhhString toJSONKeyList :: ToJSONKeyFunction [SlotNoBhhString]
Eq SlotNoBhhString #
Instance details Defined in Mafoc.Upstream.Formats Methods (==) :: SlotNoBhhString -> SlotNoBhhString -> Bool # (/=) :: SlotNoBhhString -> SlotNoBhhString -> Bool #
Ord SlotNoBhhString #
Instance details Defined in Mafoc.Upstream.Formats Methods compare :: SlotNoBhhString -> SlotNoBhhString -> Ordering # (<) :: SlotNoBhhString -> SlotNoBhhString -> Bool # (<=) :: SlotNoBhhString -> SlotNoBhhString -> Bool # (>) :: SlotNoBhhString -> SlotNoBhhString -> Bool # (>=) :: SlotNoBhhString -> SlotNoBhhString -> Bool # max :: SlotNoBhhString -> SlotNoBhhString -> SlotNoBhhString # min :: SlotNoBhhString -> SlotNoBhhString -> SlotNoBhhString #

Mafoc.Logging

renderPretty :: Pretty a => a -> Text #

traceInfo :: Trace IO Text -> Doc () -> IO () #

Re-exports from other packages

type CurrentEra = BabbageEra #