B | |
Blocking [Log] | |
Box [Weak_hashtbl] | Weak_hashtbl requires that all values in the table be boxed, which ensures that
weak pointers and finalization work as expected.
|
C | |
Callee_converts [Versioned_rpc] | |
Caller_converts [Versioned_rpc] | |
Client [Versioned_typed_tcp.S] | |
Client [Versioned_typed_tcp.Make] | |
Client [Tcp_file] | |
Client_id [Typed_tcp_intf.S] | |
Client_message [Typed_tcp_intf.Arg] | |
Client_message [Typed_tcp_intf.S] | |
Client_msg [Versioned_typed_tcp] | |
Connection [Rpc] | |
Control [Versioned_typed_tcp.Client_msg] | |
Control [Versioned_typed_tcp.Server_msg] | |
D | |
Datumable_of_binable [Versioned_typed_tcp] |
Helpers to make your types Datumable if they are binable.
|
Description [Rpc.Implementation] | |
Dont_care_about_mode [Versioned_typed_tcp] | |
E | |
Error [Tcp_file.Client] | |
Error [File_tail] | |
F | |
File [Tcp_file.Server] | |
File_tail [Std] | |
File_tail | File_replaced occurs if the inode of the file changed and the file tail was
configured with ignore_inode_change = false .
|
File_writer [Std] | |
File_writer | create file opens file , creating it if it doesn't exist.
|
Five_versions [Versioned_typed_tcp.Datumable_of_binable] | |
Four_versions [Versioned_typed_tcp.Datumable_of_binable] | |
G | |
Global [Log] | |
I | |
Id [Rpc.State_rpc] | |
Id [Rpc.Pipe_rpc] | |
Implementation [Rpc] | |
Import | |
Inline_tests | |
L | |
Level [Log] | |
Lock_file [Std] | |
Lock_file | create ?message path tries to create a file at path containing the text message ,
pid if none provided.
|
Log [Std] | |
Log | create f returns a t, given a function that actually performs the final output
work.
|
M | |
Make [Versioned_typed_tcp] | |
Make [Versioned_rpc.Callee_converts] |
Given a model of the types involved in a family of RPCs, this
functor provides a single multi-version implementation function
implement_multi in terms of that model and a mechanism for
registering the individual versions that implement_multi knows
about.
|
Make [Versioned_rpc.Caller_converts.Pipe_rpc] |
Given a model of the types involved in a family of Pipe_RPCs,
this functor provides a single Pipe_RPC versioned dispatch
function
dispatch_multi in terms of that model and a mechanism
for registering the individual versions that dispatch_multi
knows about.
|
Make [Versioned_rpc.Caller_converts.Rpc] |
Given a model of the types involved in a family of RPCs, this functor
provides a single RPC versioned dispatch function
dispatch_multi
in terms of that model and a mechanism for registering the individual
versions that dispatch_multi knows about.
|
Make [Typed_tcp] | |
Make [Persistent_singleton] | |
Make_datumable5 [Versioned_typed_tcp.Datumable_of_binable] | |
Make_global [Log] | |
Menu [Versioned_rpc] |
machinery for communicating names and versions of supported rpcs from
within the rpc protocol itself.
|
Message [Tcp_file.Client] | |
Message [Log] | |
Mode [Versioned_typed_tcp.Arg] | |
My_name [Versioned_typed_tcp.Arg] | |
O | |
One_version [Versioned_typed_tcp.Datumable_of_binable] | |
Output [Log.Blocking] | |
Output [Log] | |
P | |
Persistent_singleton [Std] | |
Persistent_singleton |
Implements a value that is either in a file, or in memory, but not both.
|
Pipe_rpc [Versioned_rpc.Caller_converts] | |
Pipe_rpc [Rpc] | |
R | |
Read_result [Versioned_typed_tcp] | |
Reader [Log] | |
Recv [Versioned_typed_tcp.Arg] | |
Register [Versioned_rpc.Callee_converts.Make] |
add a new version to the set of versions implemented by
implement_multi .
|
Register [Versioned_rpc.Caller_converts.Pipe_rpc.Make] |
add a new version to the set of versions available via
dispatch_multi .
|
Register [Versioned_rpc.Caller_converts.Rpc.Make] |
add a new version to the set of versions available via
dispatch_multi .
|
Remote_name [Versioned_typed_tcp.Arg] | |
Response [Tcp_file.Client] | |
Result [Unpack_sequence] | |
Rotation [Log] | |
Rpc [Versioned_rpc.Caller_converts] | |
Rpc [Std] | |
Rpc | |
Rpc |
A library for building asynchronous RPC-style protocols.
|
Rpc_intf |
Initiate an Rpc connection on the given reader/writer pair.
|
S | |
Send [Versioned_typed_tcp.Arg] | |
Server [Versioned_typed_tcp.S] | |
Server [Versioned_typed_tcp.Make] | |
Server [Tcp_file] | |
Server [Tcp] |
A
Server.t represents a TCP server listening on a socket.
|
Server [Rpc_intf.Connection] | |
Server [Rpc] | |
Server_message [Typed_tcp_intf.Arg] | |
Server_message [Typed_tcp_intf.S] | |
Server_msg [Versioned_typed_tcp] | |
Server_read_result [Typed_tcp_intf.S] | |
Simple [Typed_tcp] | |
State_rpc [Rpc] | |
Std | |
T | |
Tcp | with_connection ~host ~port f looks up host from a string (using DNS as needed),
connects, then calls f passing in a reader and a writer for the connected socket.
|
Tcp [Std] | |
Tcp_file | serve ~port () must be called before clients will be able to connect.
|
Tcp_file [Std] | |
Three_versions [Versioned_typed_tcp.Datumable_of_binable] | |
Transport [Typed_tcp_intf.Arg] | |
Two_versions [Versioned_typed_tcp.Datumable_of_binable] | |
Typed_tcp | |
Typed_tcp [Std] | |
Typed_tcp_intf | |
U | |
Unpack_sequence | Unpack_sequence implements a way to take an unpack_one function that can unpack a
value from a character buffer, and use it to unpack a sequence of packed values
coming via a string pipe into a pipe of upacked values.
|
Unpack_sequence [Std] | |
Update [File_tail] | |
V | |
V [Versioned_typed_tcp.Datumable_of_binable] | |
Version [Versioned_typed_tcp] | |
Versioned_rpc |
Infrastructure code for managing RPCs which evolve over time to use
different types at different versions
|
Versioned_rpc [Std] | |
Versioned_typed_tcp |
This module describes the type of a given direction of message
flow.
|
Versioned_typed_tcp [Std] | |
W | |
Warning [File_tail] | |
Weak_hashtbl | Weak_hashtbl requires that all values in the table be boxed, which ensures that
weak pointers and finalization work as expected.
|
Weak_hashtbl [Std] | |
Where_to_listen [Tcp] |
A
Where_to_listen describes the socket that a tcp server should listen on.
|