Index of modules


B
Blocking [Log]

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]
Implementations [Rpc_intf.Connection]
Implementations [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_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 [Std]
Where_to_listen [Tcp]
A Where_to_listen describes the socket that a tcp server should listen on.