| Safe Haskell | None |
|---|---|
| Language | GHC2021 |
Hindsight.Store.PostgreSQL.Projections.State
Contents
Synopsis
State Management
updateSyncProjectionState :: ProjectionId -> SQLCursor -> Transaction () Source #
Update sync projection state after successful processing
Uses the shared upsert operation from Hindsight.Projection.State which handles cursor updates and error clearing.
registerSyncProjectionInDb :: ProjectionId -> Transaction () Source #
Register a sync projection in the database if it doesn't exist
Uses the shared registration operation from Hindsight.Projection.State.
getActiveProjections :: Transaction [SyncProjectionState] Source #
Get all active sync projections from the database
Types
data SyncProjectionState Source #
State of a sync projection in the database
Constructors
| SyncProjectionState | |
Fields | |
Instances
| Show SyncProjectionState Source # | |
Defined in Hindsight.Store.PostgreSQL.Projections.State Methods showsPrec :: Int -> SyncProjectionState -> ShowS # show :: SyncProjectionState -> String # showList :: [SyncProjectionState] -> ShowS # | |
| Eq SyncProjectionState Source # | |
Defined in Hindsight.Store.PostgreSQL.Projections.State Methods (==) :: SyncProjectionState -> SyncProjectionState -> Bool # (/=) :: SyncProjectionState -> SyncProjectionState -> Bool # | |