| Copyright | (c) 2011 MailRank Inc. |
|---|---|
| License | Apache |
| Maintainer | Mark Hibberd <mark@hibberd.id.au>, Nathan Hunter <nhunter@janrain.com> |
| Stability | experimental |
| Portability | portable |
| Safe Haskell | None |
| Language | Haskell2010 |
Network.Riak.Connection.Internal
Description
Low-level network connection management.
Synopsis
- connect :: Client -> IO Connection
- disconnect :: Connection -> IO ()
- setClientID :: Connection -> ClientID -> IO ()
- defaultClient :: Client
- makeClientID :: IO ClientID
- exchange :: Exchange req resp => Connection -> req -> IO resp
- exchangeMaybe :: Exchange req resp => Connection -> req -> IO (Maybe resp)
- exchange_ :: Request req => Connection -> req -> IO ()
- pipeline :: Exchange req resp => Connection -> [req] -> IO [resp]
- pipelineMaybe :: Exchange req resp => Connection -> [req] -> IO [Maybe resp]
- pipeline_ :: Request req => Connection -> [req] -> IO ()
- sendRequest :: Request req => Connection -> req -> IO ()
- recvResponse :: Response a => Connection -> IO a
- recvMaybeResponse :: Response a => Connection -> IO (Maybe a)
- recvResponse_ :: Connection -> MessageTag -> IO ()
Connection management
disconnect :: Connection -> IO () Source #
Disconnect from a server.
setClientID :: Connection -> ClientID -> IO () Source #
Tell the server our client ID.
Client configuration
defaultClient :: Client Source #
Default client configuration. Talks to localhost, port 8087, with a randomly chosen client ID.
makeClientID :: IO ClientID Source #
Generate a random client ID.
Requests and responses
Sending and receiving requests and responses
exchange :: Exchange req resp => Connection -> req -> IO resp Source #
Send a request to the server, and receive its response.
exchangeMaybe :: Exchange req resp => Connection -> req -> IO (Maybe resp) Source #
Send a request to the server, and receive its response (which may be empty).
exchange_ :: Request req => Connection -> req -> IO () Source #
Send a request to the server, and receive its response, but do not decode it.
Pipelining many requests
pipeline :: Exchange req resp => Connection -> [req] -> IO [resp] Source #
Send a series of requests to the server, back to back, and receive a response for each request sent. The sending and receiving will be overlapped if possible, to improve concurrency and reduce latency.
pipelineMaybe :: Exchange req resp => Connection -> [req] -> IO [Maybe resp] Source #
Send a series of requests to the server, back to back, and receive a response for each request sent (the responses may be empty). The sending and receiving will be overlapped if possible, to improve concurrency and reduce latency.
pipeline_ :: Request req => Connection -> [req] -> IO () Source #
Send a series of requests to the server, back to back, and receive (but do not decode) a response for each request sent. The sending and receiving will be overlapped if possible, to improve concurrency and reduce latency.
Low-level protocol operations
Sending and receiving
sendRequest :: Request req => Connection -> req -> IO () Source #
recvResponse :: Response a => Connection -> IO a Source #
recvMaybeResponse :: Response a => Connection -> IO (Maybe a) Source #
recvResponse_ :: Connection -> MessageTag -> IO () Source #
Orphan instances
| Exception RpbErrorResp Source # | |
Methods toException :: RpbErrorResp -> SomeException # fromException :: SomeException -> Maybe RpbErrorResp # displayException :: RpbErrorResp -> String # | |