Queue.hs

module IHP.Job.Queue
( runPool
, fetchNextJob
, pendingJobConditionSQL
, watchForJob
, watchForJobWithPollerTriggerRepair
, pollForJob
, notificationTriggersHealthy
, ensureNotificationTriggers
, createNotificationTriggerSQL
, channelName
, jobDidFail
, jobDidTimeout
, jobDidSucceed
, backoffDelay
, recoverStaleJobs
, textToEnumJobStatusMap
, textToEnumJobStatus
, tryWriteTBQueue
) where

import IHP.Job.Queue.Pool (runPool)
import IHP.Job.Queue.Fetch (fetchNextJob, pendingJobConditionSQL)
import IHP.Job.Queue.Watch
    ( watchForJob
    , watchForJobWithPollerTriggerRepair
    , pollForJob
    , notificationTriggersHealthy
    , ensureNotificationTriggers
    , createNotificationTriggerSQL
    , channelName
    )
import IHP.Job.Queue.Result
    ( jobDidFail
    , jobDidTimeout
    , jobDidSucceed
    , backoffDelay
    , recoverStaleJobs
    )
import IHP.Job.Queue.StatusInstances
    ( textToEnumJobStatusMap
    , textToEnumJobStatus
    )
import IHP.Job.Queue.STM (tryWriteTBQueue)