Network.JobQueue.Types

Synopsis

• data JobActionState e a = JobActionState {
  • jobActions :: [ActionFn e a]
  }
• data (Env e, Unit a) => JobM e a b
• type ActionM e a b = ActionT e a IO b
• data ActionT e a m b
• type ActionFn e a = e -> a -> IO (Either Break (Maybe (RuntimeState a)))
• 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
  • toBeLogged :: a -> Bool
• data RuntimeState a = RS {
  • rsNextJob :: Maybe a
  • rsNextForks :: [(a, Maybe UTCTime)]
  • rsCommits :: Int
  }
• data Break
  • = Unhandled SomeException
  • | Failure String
  • | Retriable
• data LogLevel :: *
  • = LevelDebug
  • | LevelInfo
  • | LevelWarn
  • | LevelError
  • | LevelOther Text
• setNextJob :: Unit a => a -> RuntimeState a -> RuntimeState a
• setNextJobIfEmpty :: Unit a => a -> RuntimeState a -> RuntimeState a
• emptyNextJob :: Unit a => RuntimeState a -> RuntimeState a
• addForkJob :: Unit a => (a, Maybe UTCTime) -> RuntimeState a -> RuntimeState a
• incrementCommits :: Unit a => RuntimeState a -> RuntimeState a
• getCommits :: Unit a => RuntimeState a -> Int
• runS :: JobM e a b -> StateT (JobActionState e a) IO b
• runAM :: ActionT e a m b -> ExceptT Break (ReaderT (ActionEnv e a) (StateT (Maybe (RuntimeState a)) (LoggingT m))) b
• addAction :: (Env e, Unit a) => ActionFn e a -> JobActionState e a -> JobActionState e a
• setResult :: Unit a => Maybe (RuntimeState a) -> Maybe (RuntimeState a) -> Maybe (RuntimeState a)

Documentation