| Safe Haskell | Safe-Inferred |
|---|---|
| Language | Haskell2010 |
Hasura.Eventing.Common
Synopsis
- data LockedEventsCtx = LockedEventsCtx {}
- saveLockedEvents :: MonadIO m => [EventId] -> TVar (Set EventId) -> m ()
- removeEventFromLockedEvents :: MonadIO m => EventId -> TVar (Set EventId) -> m ()
- generateScheduleTimes :: UTCTime -> Int -> CronSchedule -> [UTCTime]
- cleanupSchedulesToBeGenerated :: Int
- deleteEventTriggerLogsInBatchesWith :: (MonadIO m, MonadError QErr m) => IO (Maybe (TriggerLogCleanupConfig, EventTriggerCleanupStatus)) -> TriggerLogCleanupConfig -> (TriggerLogCleanupConfig -> IO (Either QErr DeletedEventLogStats)) -> m DeletedEventLogStats
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
generateScheduleTimes :: UTCTime -> Int -> CronSchedule -> [UTCTime] Source #
Generates next n events starting from according to CronSchedule
cleanupSchedulesToBeGenerated :: Int Source #
number of cleanup schedules to be generated in one iteration