Documentation

data Config m Source #

type Configurator m = StateT (Config m) m () Source #

data Manager Source #

data ManagerStatus Source #

type Middleware m = Manager -> Worker m Value -> Object -> Queue -> m () -> m () Source #

data Worker m a Source #

await :: Manager -> IO () Source #

checkStatus :: MonadIO m => Manager -> Connection -> m ManagerStatus Source #

concurrency :: Monad m => Int -> Configurator m Source #

halt :: (MonadBaseControl IO m, MonadIO m) => Manager -> m () Source #

enqueue :: (ToJSON a, MonadIO m) => Manager -> Worker m a -> a -> m () Source #

enqueueAt :: (ToJSON a, MonadIO m) => UTCTime -> Manager -> Worker m a -> a -> m () Source #

enqueueIn :: (ToJSON a, MonadIO m) => Rational -> Manager -> Worker m a -> a -> m () Source #

mkConf :: Monad m => Connection -> Configurator m -> m (Config m) Source #

middleware :: Monad m => Middleware m -> Configurator m Source #

record :: (MonadBaseControl IO m, MonadIO m) => Middleware m Source #

register :: (MonadLogger m, MonadIO m, FromJSON a) => Worker m a -> Configurator m Source #

retry :: (MonadLogger m, MonadBaseControl IO m, MonadIO m) => Middleware m Source #

sleep :: Int -> IO () Source #

startProcess :: (MonadBaseControl IO m, MonadIO m, MonadLogger m) => Config m -> m Manager Source #