majordomo-0.1.6: Majordomo protocol for ZeroMQ

Safe Haskell	Safe-Infered

System.Network.ZMQ.MDP.Worker

Documentation

data Protocol Source

Constructors

WORKER_PROTOCOL

Instances

type Address = ByteString Source

data Response Source

Constructors

Response
Fields envelope :: ![Address] body :: ![ByteString]

data ResponseCode Source

Constructors

REPLY
READY
WORKER_HEARTBEAT

Instances

Show ResponseCode

data CommandCode Source

Constructors

REQUEST
HEARTBEAT
DISCONNECT

Instances

Show CommandCode

parseCommand :: ByteString -> Maybe CommandCode Source

type MDError = ByteString Source

sendToBroker :: Socket a -> ResponseCode -> [ByteString] -> [ByteString] -> IO ()Source

sendResponse :: Socket a -> Response -> IO ()Source

whileJust :: Monad m => (b -> m (Maybe b)) -> b -> m bSource

start :: WorkerState a -> IO ()Source

readTillDrop :: Socket a -> WorkerState a1 -> IO (WorkerState a1)Source

data WorkerState a Source

Constructors

WorkerState
Fields heartbeat_at :: !UTCTime liveness :: !Int heartbeat :: !Int64 reconnect :: !Int broker :: String context :: Context svc :: ByteString handler :: [ByteString] -> IO [ByteString]

epoch :: UTCTime Source

lIVENESS :: Int Source

withWorker :: String -> ByteString -> ([ByteString] -> IO [ByteString]) -> IO ()Source

withBroker :: (Socket XReq -> WorkerState a -> IO b) -> WorkerState t -> IO bSource

loggedPut :: String -> IO ()Source

receive :: Socket a -> WorkerState a1 -> IO (Maybe (WorkerState a2))Source