Network.RPC.Curryer.Client

Documentation

type SyncMap = Map UUID (MVar (Either ConnectionError BinaryMessage), UTCTime)

data Connection

Represents a remote connection to server.

Constructors

Connection

Fields

• _conn_sockLock :: Locking Socket
• _conn_asyncThread :: Async ()
• _conn_syncmap :: SyncMap

data ClientAsyncRequestHandler where

Function handlers run on the client, triggered by the server- useful for asynchronous callbacks.

Constructors

ClientAsyncRequestHandler :: forall a. Serialise a => (a -> IO ()) -> ClientAsyncRequestHandler

type ClientAsyncRequestHandlers = [ClientAsyncRequestHandler]

connect :: ClientAsyncRequestHandlers -> HostAddr -> PortNumber -> IO Connection

Connects to a remote server with specific async callbacks registered.

close :: Connection -> IO ()

Close the connection and release all connection resources.

clientAsync :: Socket -> SyncMap -> ClientAsyncRequestHandlers -> IO ()

async thread for handling client-side incoming messages- dispatch to proper waiting thread or asynchronous notifications handler

consumeResponse :: UUID -> Map UUID (MVar a, b) -> a -> IO ()

clientEnvelopeHandler :: ClientAsyncRequestHandlers -> Locking Socket -> SyncMap -> Envelope -> IO ()

handles envelope responses from server- timeout from ths server is ignored, but perhaps that's proper for trusted servers- the server expects the client to process all async requests

call :: (Serialise request, Serialise response) => Connection -> request -> IO (Either ConnectionError response)

Basic remote function call via data type and return value.

callTimeout :: (Serialise request, Serialise response) => Maybe Int -> Connection -> request -> IO (Either ConnectionError response)

Send a request to the remote server and returns a response but with the possibility of a timeout after n microseconds.

asyncCall :: Serialise request => Connection -> request -> IO (Either ConnectionError ())

Call a remote function but do not expect a response from the server.