| Safe Haskell | Safe-Inferred |
|---|---|
| Language | Haskell2010 |
Language.Marlowe.Runtime.Indexer.Store
Synopsis
- data StoreSelector f where
- data SaveField
- = RollbackPoint ChainPoint
- | Stats ChangesStatistics
- | LocalTip ChainPoint
- | RemoteTip ChainPoint
- | InvalidCreateTxs (Map ContractId ExtractCreationError)
- | InvalidApplyInputsTxs (Map TxId ExtractMarloweTransactionError)
- data StoreDependencies r m = StoreDependencies {
- databaseQueries :: DatabaseQueries m
- pullEvent :: STM (ChainEvent r)
- store :: (MonadUnliftIO m, MonadInjectEvent r StoreSelector s m, WithLog env Message m) => Component m (StoreDependencies r m) ()
- aggregator :: (MonadUnliftIO m, WithLog env Message m) => Component m (STM (ChainEvent r)) (STM (Changes r))
- data PersisterDependencies r m = PersisterDependencies {
- databaseQueries :: DatabaseQueries m
- readChanges :: STM (Changes r)
- persister :: (MonadUnliftIO m, MonadInjectEvent r StoreSelector s m, WithLog env Message m) => Component m (PersisterDependencies r m) ()
- data Changes r = Changes {
- rollbackTo :: Maybe ChainPoint
- blocks :: [MarloweBlock]
- statistics :: ChangesStatistics
- localTip :: Maybe ChainPoint
- remoteTip :: Maybe ChainPoint
- invalidCreateTxs :: Map ContractId ExtractCreationError
- invalidApplyInputsTxs :: Map TxId ExtractMarloweTransactionError
- events :: [r]
- applyRollback :: ChainPoint -> Changes r -> Changes r
- subStats :: ChangesStatistics -> ChangesStatistics -> ChangesStatistics
- computeStats :: MarloweBlock -> ChangesStatistics
- data ChangesStatistics = ChangesStatistics {}
Documentation
data StoreSelector f where Source #
Constructors
| Save :: StoreSelector SaveField |
Constructors
| RollbackPoint ChainPoint | |
| Stats ChangesStatistics | |
| LocalTip ChainPoint | |
| RemoteTip ChainPoint | |
| InvalidCreateTxs (Map ContractId ExtractCreationError) | |
| InvalidApplyInputsTxs (Map TxId ExtractMarloweTransactionError) |
data StoreDependencies r m Source #
Constructors
| StoreDependencies | |
Fields
| |
store :: (MonadUnliftIO m, MonadInjectEvent r StoreSelector s m, WithLog env Message m) => Component m (StoreDependencies r m) () Source #
The store component aggregates changes into batches in one thread, and pulls batches to save in another.
aggregator :: (MonadUnliftIO m, WithLog env Message m) => Component m (STM (ChainEvent r)) (STM (Changes r)) Source #
The aggregator component pulls chain events and accumulates a batch of changes to persist.
data PersisterDependencies r m Source #
Constructors
| PersisterDependencies | |
Fields
| |
persister :: (MonadUnliftIO m, MonadInjectEvent r StoreSelector s m, WithLog env Message m) => Component m (PersisterDependencies r m) () Source #
A component to save batches of changes to the database.
Constructors
| Changes | |
Fields
| |
Instances
applyRollback :: ChainPoint -> Changes r -> Changes r Source #
data ChangesStatistics Source #
Constructors
| ChangesStatistics | |
Fields
| |