Periodic.Trans.ClientPool

Documentation

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

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 ClientT = BaseClientT ()

type ClientEnv = BaseClientEnv ()

runClientT :: Monad m => ClientEnv tp -> ClientT tp m a -> m a

open :: (MonadUnliftIO m, Transport tp) => TransportConfig tp -> m (ClientEnv tp)

dropFunc :: (MonadUnliftIO m, Transport tp) => FuncName -> BaseClientT u tp m Bool

removeJob :: (MonadUnliftIO m, Transport tp) => FuncName -> JobName -> BaseClientT u tp m Bool

status :: (MonadUnliftIO m, Transport tp) => BaseClientT u tp m ByteString

configGet :: (MonadUnliftIO m, Transport tp) => String -> BaseClientT u tp m Int

configSet :: (MonadUnliftIO m, Transport tp) => String -> Int -> BaseClientT u tp m Bool

load :: (MonadUnliftIO m, Transport tp) => [Job] -> BaseClientT u tp m Bool

dump :: (MonadUnliftIO m, Transport tp) => BaseClientT u tp m [Job]

shutdown :: (MonadUnliftIO m, Transport tp) => BaseClientT u tp m ()

type ClientPoolEnv tp = Pool (ClientEnv tp)

runClientPoolT :: ClientPoolEnv tp -> ClientT tp IO a -> IO a

openPool :: Transport tp => TransportConfig tp -> Int -> IO (ClientPoolEnv tp)