Periodic.Trans.Worker

Documentation

data WorkerT tp m a

Instances

MonadTrans (WorkerT tp)

Defined in Periodic.Trans.Worker

Methods

lift :: Monad m => m a -> WorkerT tp m a

Monad m => Monad (WorkerT tp m)

Defined in Periodic.Trans.Worker

Methods

(>>=) :: WorkerT tp m a -> (a -> WorkerT tp m b) -> WorkerT tp m b

(>>) :: WorkerT tp m a -> WorkerT tp m b -> WorkerT tp m b

return :: a -> WorkerT tp m a

fail :: String -> WorkerT tp m a

Functor m => Functor (WorkerT tp m)

Defined in Periodic.Trans.Worker

Methods

fmap :: (a -> b) -> WorkerT tp m a -> WorkerT tp m b

(<$) :: a -> WorkerT tp m b -> WorkerT tp m a

Applicative m => Applicative (WorkerT tp m)

Defined in Periodic.Trans.Worker

Methods

pure :: a -> WorkerT tp m a

(<*>) :: WorkerT tp m (a -> b) -> WorkerT tp m a -> WorkerT tp m b

liftA2 :: (a -> b -> c) -> WorkerT tp m a -> WorkerT tp m b -> WorkerT tp m c

(*>) :: WorkerT tp m a -> WorkerT tp m b -> WorkerT tp m b

(<*) :: WorkerT tp m a -> WorkerT tp m b -> WorkerT tp m a

MonadIO m => MonadIO (WorkerT tp m)

Defined in Periodic.Trans.Worker

Methods

liftIO :: IO a -> WorkerT tp m a

MonadUnliftIO m => MonadUnliftIO (WorkerT tp m)

Defined in Periodic.Trans.Worker

Methods

withRunInIO :: ((forall a. WorkerT tp m a -> IO a) -> IO b) -> WorkerT tp m b

startWorkerT :: (MonadUnliftIO m, Transport tp) => TransportConfig tp -> WorkerT tp m () -> m ()

ping :: (MonadUnliftIO m, Transport tp) => WorkerT tp m Bool

addFunc :: (MonadUnliftIO m, Transport tp) => FuncName -> JobT tp m () -> WorkerT tp m ()

broadcast :: (MonadUnliftIO m, Transport tp) => FuncName -> JobT tp m () -> WorkerT tp m ()

removeFunc :: (MonadUnliftIO m, Transport tp) => FuncName -> WorkerT tp m ()

work :: (MonadUnliftIO m, Transport tp) => Int -> WorkerT tp m ()

close :: (MonadUnliftIO m, Transport tp) => WorkerT tp m ()

runJobT :: Monad m => JobT tp m a -> WorkerT tp m a

getClientEnv :: (Monad m, Transport tp) => WorkerT tp m (BaseClientEnv (Maybe Job) tp)