Periodic.Job

Documentation

type JobM = JobT Socket IO

type BaseClientT u = NodeT u ServerCommand

submitJob_ :: (MonadUnliftIO m, Transport tp) => Job -> BaseClientT u tp m Bool

submitJob :: (MonadUnliftIO m, Transport tp) => FuncName -> JobName -> Maybe Workload -> Maybe Int64 -> BaseClientT u tp m Bool

runJob_ :: (MonadUnliftIO m, Transport tp) => Job -> BaseClientT u tp m (Maybe ByteString)

runJob :: (MonadUnliftIO m, Transport tp) => FuncName -> JobName -> Maybe Workload -> BaseClientT u tp m (Maybe ByteString)

type JobEnv = SessionEnv (Maybe Job) ServerCommand

name :: (FromBS a, Show a, Monad m) => JobT tp m a

name_ :: Monad m => JobT tp m JobName

func :: (FromBS a, Show a, Monad m) => JobT tp m a

func_ :: Monad m => JobT tp m FuncName

workload :: (FromBS a, Show a, Monad m) => JobT tp m a

workload_ :: Monad m => JobT tp m Workload

count :: Monad m => JobT tp m Int

timeout :: Monad m => JobT tp m Int

workDone :: (MonadUnliftIO m, Transport tp) => JobT tp m ()

workDone_ :: (MonadUnliftIO m, Transport tp) => ByteString -> JobT tp m ()

workFail :: (MonadUnliftIO m, Transport tp) => JobT tp m ()

schedLater :: (MonadUnliftIO m, Transport tp) => Int64 -> JobT tp m ()

schedLater' :: (MonadUnliftIO m, Transport tp) => Int64 -> Int -> JobT tp m ()

acquireLock :: (MonadUnliftIO m, Transport tp) => LockName -> Int -> JobT tp m Bool

releaseLock :: (MonadUnliftIO m, Transport tp) => LockName -> JobT tp m ()

withLock_ :: (MonadUnliftIO m, Transport tp) => LockName -> Int -> JobT tp m () -> JobT tp m ()

withLock :: (MonadUnliftIO m, Transport tp) => LockName -> Int -> JobT tp m () -> JobT tp m ()