| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Hasura.Eventing.Common
Synopsis
- data LockedEventsCtx = LockedEventsCtx {
- leCronEvents :: TVar (Set CronEventId)
- leOneOffEvents :: TVar (Set OneOffScheduledEventId)
- leEvents :: TVar (HashMap SourceName (Set EventId))
- leActionEvents :: TVar (Set LockedActionEventId)
- saveLockedEvents :: MonadIO m => [EventId] -> TVar (Set EventId) -> m ()
- removeEventFromLockedEvents :: MonadIO m => EventId -> TVar (Set EventId) -> m ()
Documentation
data LockedEventsCtx Source #
Constructors
| LockedEventsCtx | |
Fields
| |
saveLockedEvents :: MonadIO m => [EventId] -> TVar (Set EventId) -> m () Source #
After the events are fetched from the DB, we store the locked events in a hash set(order doesn't matter and look ups are faster) in the event engine context
removeEventFromLockedEvents :: MonadIO m => EventId -> TVar (Set EventId) -> m () Source #
Remove an event from the LockedEventsCtx after it has been processed