Network.JobQueue.JobQueue.Internal

Synopsis

• type FailureHandleFn a = Alert -> String -> String -> Maybe (Job a) -> IO (Maybe (Job a))
• type AfterExecuteHandleFn a = Job a -> IO ()
• data Unit a => Settings a = Settings {
  • failureHandleFn :: FailureHandleFn a
  • afterExecuteFn :: AfterExecuteHandleFn a
  }
• data JobQueue e a where
  • JobQueue :: BackendQueue q => {
    • jqBackendQueue :: q
    • jqActionState :: JobActionState e a
    • jqFailureHandleFn :: FailureHandleFn a
    • jqAfterExecuteFn :: AfterExecuteHandleFn a
    } -> JobQueue e a
• data ActionForJob a
  • = 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

Documentation