Faktory.Client

Client operations

data Client

newClient :: HasCallStack => Settings -> Maybe WorkerId -> IO Client

Open a new Client connection with the given Settings

closeClient :: Client -> IO ()

Close a Client

High-level Job operations

pushJob :: (HasCallStack, ToJSON a) => Client -> a -> IO ()

Push a Job to the Server

flush :: HasCallStack => Client -> IO ()

Clear all job data in the Faktory server

Use with caution!

High-level Client API

command_ :: Client -> ByteString -> [ByteString] -> IO ()

Send a command, read and discard the response

commandOK :: HasCallStack => Client -> ByteString -> [ByteString] -> IO ()

Send a command, assert the response is OK

commandJSON :: FromJSON a => Client -> ByteString -> [ByteString] -> IO (Either String (Maybe a))

Send a command, parse the response as JSON