Network.JobQueue.JobQueue.Internal

Documentation

type FailureHandleFn a = Alert -> String -> String -> Maybe (Job a) -> IO (Maybe (Job a))

type AfterExecuteHandleFn a = Job a -> IO ()

data Unit a => Settings a

Job queue settings

Constructors

Settings

Fields

failureHandleFn :: FailureHandleFn a

a function called when an action fails

afterExecuteFn :: AfterExecuteHandleFn a

a function called after an action is executed (for debugging)

Instances

Unit a => Default (Settings a)

data JobQueue e a where

Constructors

JobQueue :: BackendQueue q => q -> JobActionState e a -> FailureHandleFn a -> AfterExecuteHandleFn a -> JobQueue e a

Fields

jqBackendQueue :: q

jqActionState :: JobActionState e a

jqFailureHandleFn :: FailureHandleFn a

jqAfterExecuteFn :: AfterExecuteHandleFn a

data ActionForJob a

Constructors

Unit a => Execute (Job a)

Delete

Skip

actionForJob :: Unit a => Job a -> String -> ActionForJob a

peekJob' :: Unit a => JobQueue e a -> IO (Maybe (Job a, String, String, Int))

executeJob' :: (Env e, Unit a) => JobQueue e a -> e -> String -> Job a -> Int -> IO (Maybe (JobResult a))

afterExecuteJob :: Unit a => JobQueue e a -> String -> Job a -> Int -> Maybe (JobResult a) -> IO ()

rescheduleJob :: Unit a => JobQueue e a -> Maybe UTCTime -> a -> IO ()

updateJob :: Unit a => JobQueue e a -> String -> Job a -> Int -> IO Bool

pack :: Unit a => Job a -> ByteString