Documentation

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

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

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

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

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

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

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

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

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

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

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

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

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

type ClientEnv = ClientEnv Socket Source #

type ClientM = ClientT Socket IO Source #

open :: String -> IO ClientEnv Source #

runClientM :: ClientEnv -> ClientM a -> IO a Source #

type ClientPoolEnv = ClientPoolEnv Socket Source #

runClientPoolM :: ClientPoolEnv -> ClientM a -> IO a Source #

openPool :: String -> Int -> IO ClientPoolEnv Source #