| Portability | non-portable |
|---|---|
| Stability | experimental |
| Safe Haskell | None |
Network.Mom.Patterns.Broker.Common
Description
Majordomo common definitions
- mdpC01 :: ByteString
- mdpW01 :: ByteString
- xReady :: ByteString
- xDisc :: ByteString
- xHeartBeat :: ByteString
- xReply :: ByteString
- xRequest :: ByteString
- type ServiceName = String
- mmiHdr :: ByteString
- mmiSrv :: ByteString
- mmiFound :: ByteString
- mmiNimpl :: ByteString
- mmiNotFound :: ByteString
- mdpCSndReq :: ServiceName -> Conduit ByteString ()
- mdpCRcvReq :: Conduit o (Identity, ByteString)
- mdpCSndRep :: ByteString -> [Identity] -> Conduit ByteString ()
- mdpCRcvRep :: ServiceName -> Conduit ByteString ()
- mdpWSndReq :: Identity -> [Identity] -> Conduit ByteString ()
- mdpWRcvReq :: Conduit o WFrame
- mdpWSndRep :: [Identity] -> Conduit ByteString ()
- mdpWRcvRep :: Conduit o WFrame
- mdpWBeat :: Conduit ByteString ()
- mdpWConnect :: ServiceName -> Source
- mdpWDisconnect :: Source
- mdpWBrkDisc :: Identity -> Source
- data WFrame
- data FrameType
- = ReadyT
- | RequestT
- | ReplyT
- | HeartBeatT
- | DisconnectT
- frameType :: Conduit o FrameType
- empty :: Conduit o ()
- chunk :: ByteString -> String -> Conduit o ()
- getChunk :: Conduit o ByteString
- identity :: Conduit o Identity
- envelope :: Conduit o [Identity]
- toIs :: [Identity] -> [ByteString]
- data MDPException
Documentation
Majordomo protocol client/worker version 1
Majordomo protocol client/worker version 1
Message types (ready, request, reply, heartbeat, disconnect)
Message types (ready, request, reply, heartbeat, disconnect)
xHeartBeat :: ByteStringSource
Message types (ready, request, reply, heartbeat, disconnect)
Message types (ready, request, reply, heartbeat, disconnect)
Message types (ready, request, reply, heartbeat, disconnect)
type ServiceName = StringSource
Service name
Majordomo Management Interface (MMI) - "mmi.service"
Majordomo Management Interface (MMI) - "mmi.service"
Majordomo Management Interface -- responses: Found ("200"), NotFound ("404"), NotImplemented ("501")
Majordomo Management Interface -- responses: Found ("200"), NotFound ("404"), NotImplemented ("501")
mmiNotFound :: ByteStringSource
Majordomo Management Interface -- responses: Found ("200"), NotFound ("404"), NotImplemented ("501")
mdpCSndReq :: ServiceName -> Conduit ByteString ()Source
Client -> Broker: send request
mdpCRcvReq :: Conduit o (Identity, ByteString)Source
Client -> Broker: receive request
mdpCSndRep :: ByteString -> [Identity] -> Conduit ByteString ()Source
Broker -> Client: send reply
mdpCRcvRep :: ServiceName -> Conduit ByteString ()Source
Broker -> Client: receive reply
mdpWSndReq :: Identity -> [Identity] -> Conduit ByteString ()Source
Broker -> Server: send request
mdpWRcvReq :: Conduit o WFrameSource
Broker -> Server: receive request
mdpWSndRep :: [Identity] -> Conduit ByteString ()Source
Server -> Broker: send reply
mdpWRcvRep :: Conduit o WFrameSource
Server -> Broker: receive reply
mdpWBeat :: Conduit ByteString ()Source
Broker <-> Server: send heartbeat
mdpWConnect :: ServiceName -> SourceSource
Server -> Broker: send connect request (ready)
mdpWDisconnect :: SourceSource
Server -> Broker: disconnect
mdpWBrkDisc :: Identity -> SourceSource
Broker -> Server: disconnect
Broker / Server protocol: Heartbeat, Ready, Reply, Request, Disconnect
Worker Frame Type
Constructors
| ReadyT | |
| RequestT | |
| ReplyT | |
| HeartBeatT | |
| DisconnectT |
chunk :: ByteString -> String -> Conduit o ()Source
Check segment contents
getChunk :: Conduit o ByteStringSource
Get segment contents
toIs :: [Identity] -> [ByteString]Source
Create envelope [(identity, B.empty)]