Safe Haskell	None
Language	Haskell2010

Periodic.Server.Scheduler

Documentation

data SchedT db tp m a Source #

Instances

Instances details

MonadTrans (SchedT db tp) Source #
Instance details Defined in Periodic.Server.Scheduler Methods lift :: Monad m => m a -> SchedT db tp m a #
Monad m => MonadReader (SchedEnv db tp) (SchedT db tp m) Source #
Instance details Defined in Periodic.Server.Scheduler Methods ask :: SchedT db tp m (SchedEnv db tp) # local :: (SchedEnv db tp -> SchedEnv db tp) -> SchedT db tp m a -> SchedT db tp m a # reader :: (SchedEnv db tp -> a) -> SchedT db tp m a #
Monad m => Monad (SchedT db tp m) Source #
Instance details Defined in Periodic.Server.Scheduler Methods (>>=) :: SchedT db tp m a -> (a -> SchedT db tp m b) -> SchedT db tp m b # (>>) :: SchedT db tp m a -> SchedT db tp m b -> SchedT db tp m b # return :: a -> SchedT db tp m a #
Functor m => Functor (SchedT db tp m) Source #
Instance details Defined in Periodic.Server.Scheduler Methods fmap :: (a -> b) -> SchedT db tp m a -> SchedT db tp m b # (<$) :: a -> SchedT db tp m b -> SchedT db tp m a #
Applicative m => Applicative (SchedT db tp m) Source #
Instance details Defined in Periodic.Server.Scheduler Methods pure :: a -> SchedT db tp m a # (<>) :: SchedT db tp m (a -> b) -> SchedT db tp m a -> SchedT db tp m b # liftA2 :: (a -> b -> c) -> SchedT db tp m a -> SchedT db tp m b -> SchedT db tp m c # (>) :: SchedT db tp m a -> SchedT db tp m b -> SchedT db tp m b # (<*) :: SchedT db tp m a -> SchedT db tp m b -> SchedT db tp m a #
MonadIO m => MonadIO (SchedT db tp m) Source #
Instance details Defined in Periodic.Server.Scheduler Methods liftIO :: IO a -> SchedT db tp m a #
MonadUnliftIO m => MonadUnliftIO (SchedT db tp m) Source #
Instance details Defined in Periodic.Server.Scheduler Methods withRunInIO :: ((forall a. SchedT db tp m a -> IO a) -> IO b) -> SchedT db tp m b #

runSchedT :: SchedEnv db tp -> SchedT db tp m a -> m a Source #

data SchedEnv db tp Source #

Instances

Instances details

Monad m => MonadReader (SchedEnv db tp) (SchedT db tp m) Source #
Instance details Defined in Periodic.Server.Scheduler Methods ask :: SchedT db tp m (SchedEnv db tp) # local :: (SchedEnv db tp -> SchedEnv db tp) -> SchedT db tp m a -> SchedT db tp m a # reader :: (SchedEnv db tp -> a) -> SchedT db tp m a #

initSchedEnv :: (MonadUnliftIO m, Persist db) => PersistConfig db -> m () -> m (SchedEnv db tp) Source #

startSchedT :: (MonadUnliftIO m, Persist db, Transport tp) => SchedT db tp m () Source #

pushJob :: (MonadIO m, Persist db) => Job -> SchedT db tp m () Source #

pushGrab :: MonadIO m => IOList FuncName -> IOList JobHandle -> CSEnv tp -> SchedT db tp m () Source #

failJob :: (MonadUnliftIO m, Persist db) => JobHandle -> SchedT db tp m () Source #

doneJob :: (MonadUnliftIO m, Persist db) => JobHandle -> ByteString -> SchedT db tp m () Source #

schedLaterJob :: (MonadUnliftIO m, Persist db) => JobHandle -> Int64 -> Int -> SchedT db tp m () Source #

acquireLock :: (MonadUnliftIO m, Persist db) => LockName -> Int -> JobHandle -> SchedT db tp m Bool Source #

releaseLock :: (MonadUnliftIO m, Persist db) => LockName -> JobHandle -> SchedT db tp m () Source #

addFunc :: (MonadIO m, Persist db) => FuncName -> SchedT db tp m () Source #

removeFunc :: (MonadIO m, Persist db) => FuncName -> SchedT db tp m () Source #

broadcastFunc :: (MonadIO m, Persist db) => FuncName -> Bool -> SchedT db tp m () Source #

dropFunc :: (MonadUnliftIO m, Persist db) => FuncName -> SchedT db tp m () Source #

removeJob :: (MonadIO m, Persist db) => Job -> SchedT db tp m () Source #

dumpJob :: (MonadIO m, Persist db) => SchedT db tp m [Job] Source #

status :: (MonadIO m, Persist db) => SchedT db tp m [FuncStat] Source #

shutdown :: MonadUnliftIO m => SchedT db tp m () Source #

keepalive :: Monad m => SchedT db tp m (TVar Int) Source #

setConfigInt :: (MonadIO m, Persist db) => String -> Int -> SchedT db tp m () Source #

getConfigInt :: (MonadIO m, Persist db) => String -> SchedT db tp m Int Source #

prepareWait :: MonadIO m => Job -> SchedT db tp m () Source #

lookupPrevResult :: MonadIO m => Job -> SchedT db tp m (Maybe ByteString) Source #

waitResult :: MonadIO m => TVar Bool -> Job -> SchedT db tp m ByteString Source #

canRun :: MonadIO m => FuncName -> SchedT db tp m Bool Source #