Network.JobQueue.Types

Synopsis

• data JobActionState e a = JobActionState {
  • jobActions :: [ActionFn e a]
  }
• data (Env e, Unit a) => JobM e a b
• data ActionM e a b
• type ActionFn e a = e -> a -> IO (Maybe (JobResult a))
• data ActionError = ActionError Alert String
• data ActionEnv e a = ActionEnv {
  • getJobEnv :: e
  • getJobUnit :: a
  }
• class (Read a, Show a, Desc a, Eq a) => Unit a where
  • getPriority :: a -> Int
  • getRecovery :: a -> a
• data Next a = Next {
  • nextJob :: Maybe a
  • nextForks :: [(a, Maybe UTCTime)]
  }
• data Failure = Failure Alert String
• type JobResult a = Either Failure (Next a)
• data Alert
  • = Critical
  • | Error
  • | Warning
  • | Notice
  • | Info
• setNextJob :: Unit a => a -> JobResult a -> JobResult a
• addForkJob :: Unit a => (a, Maybe UTCTime) -> JobResult a -> JobResult a
• runS :: JobM e a b -> StateT (JobActionState e a) IO b
• runAM :: ActionM e a b -> ErrorT ActionError (ReaderT (ActionEnv e a) (StateT (JobResultState a) IO)) b
• addAction :: (Env e, Unit a) => ActionFn e a -> JobActionState e a -> JobActionState e a
• setResult :: Unit a => Maybe (JobResult a) -> JobResultState a -> JobResultState a

Documentation