majordomo-0.1.2: Majordomo protocol for ZeroMQ

Safe HaskellSafe-Infered

System.Network.ZMQ.MDP.Worker

Documentation

data Protocol Source

Constructors

WORKER_PROTOCOL 

Instances

type Address = ByteStringSource

data Response Source

Constructors

Response 

Fields

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

data ResponseCode Source

Constructors

REPLY 
READY 
WORKER_HEARTBEAT 

Instances

data CommandCode Source

Constructors

REQUEST 
HEARTBEAT 
DISCONNECT 

Instances

parseCommand :: ByteString -> Maybe CommandCodeSource

type MDError = ByteStringSource

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 :: UTCTimeSource

lIVENESS :: IntSource

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