Periodic.Server.Scheduler

Documentation

data SchedT db tp m a

Instances

MonadTrans (SchedT db tp)

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)

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)

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

fail :: String -> SchedT db tp m a

Functor m => Functor (SchedT db tp m)

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)

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)

Defined in Periodic.Server.Scheduler

Methods

liftIO :: IO a -> SchedT db tp m a

MonadUnliftIO m => MonadUnliftIO (SchedT db tp m)

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

data SchedEnv db tp

Instances

Monad m => MonadReader (SchedEnv db tp) (SchedT db tp m)

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)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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