B | |
Blocking [Log] | |
Both_convert [Versioned_rpc] | |
Bus | create creates a new, unstarted, bus.
|
Bus_debug | |
Bus_unit_tests |
This signature is deliberately empty.
|
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_implementations [Rpc_intf.Connection] | |
Client_message [Typed_tcp_intf.Arg] | |
Client_message [Typed_tcp_intf.S] | |
Client_msg [Versioned_typed_tcp] | |
Command [Std] | |
Command | Async.Command is Core.Command with additional async functions.
|
Config [Udp] |
A typical receive loop calls
before before calling its callback to prepare a packet
buffer for reading and after afterwards to prepare for writing (for the next
iteration).
|
Connection [Rpc] | |
Connection_with_menu [Versioned_rpc] | |
Control [Versioned_typed_tcp.Client_msg] | |
Control [Versioned_typed_tcp.Server_msg] | |
Cpu_usage [Std] | |
Cpu_usage |
Simple cpu usage statistics.
|
D | |
Datumable_of_binable [Versioned_typed_tcp] |
Helpers to make your types Datumable if they are binable.
|
Debug [Bus_debug] | |
Description [Rpc.Implementation] | |
Direct [Udp.Config.Fields] | |
Dont_care_about_mode [Versioned_typed_tcp] | |
Dynamic_port_writer [Std] | |
Dynamic_port_writer |
For communicating a dynamically chosen TCP port from a child process to its parent.
|
E | |
Error [Tcp_file.Client] | |
Error [File_tail] | |
F | |
Fields [Udp.Config] | |
File [Tcp_file.Server] | |
File_tail [Std] | |
File_tail |
Errors are written to the pipe, and are nonrecoverable.
|
File_writer [Std] | |
File_writer | File_writer is a thin wrapper around Writer with a couple of extra features:
|
Five_versions [Versioned_typed_tcp.Datumable_of_binable] | |
Four_versions [Versioned_typed_tcp.Datumable_of_binable] | |
G | |
Global [Log] |
Programs that want simplistic single-channel logging can open this module.
|
I | |
Id [Rpc.State_rpc] | |
Id [Rpc.Pipe_rpc] | |
Implementation [Rpc] | |
Implementations [Rpc_intf.Connection] | |
Implementations [Rpc] | |
Import | |
L | |
Level [Log] | |
Lock_file [Std] | |
Lock_file | Async.Lock_file is a wrapper that provides async equivalents for
Core.Lock_file .
|
Log [Std] | |
Log |
A library for general logging.
|
M | |
Make [Versioned_typed_tcp] | |
Make [Versioned_rpc.Both_convert.Plain] | |
Make [Versioned_rpc.Callee_converts.Pipe_rpc] |
Given a model of the types involved in a family of Pipe_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.Callee_converts.Rpc] |
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 [Sequencer_table] | |
Make [Persistent_singleton] | |
Make_datumable5 [Versioned_typed_tcp.Datumable_of_binable] | |
Make_global [Log] |
This functor can be called to generate "singleton" logging modules
|
Menu [Versioned_rpc] | |
Message [Tcp_file.Client] | |
Message [Log] | |
Mode [Versioned_typed_tcp.Arg] | |
My_name [Versioned_typed_tcp.Arg] | |
N | |
Nfs [Lock_file] | Nfs has analogs of functions in Core.Lock_file.Nfs ; see there for documentation.
|
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.Callee_converts] | |
Pipe_rpc [Versioned_rpc.Caller_converts] | |
Pipe_rpc [Rpc] | |
Plain [Versioned_rpc.Both_convert] | |
R | |
Read_result [Versioned_typed_tcp] | |
Reader [Log] | |
Recv [Versioned_typed_tcp.Arg] | |
Register [Versioned_rpc.Both_convert.Plain.Make] | |
Register [Versioned_rpc.Callee_converts.Pipe_rpc.Make] |
add a new version to the set of versions available via
implement_multi .
|
Register [Versioned_rpc.Callee_converts.Rpc.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.Callee_converts] | |
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] | |
Sequencer_table [Std] | |
Sequencer_table |
A table of sequencers indexed by key, so that at any moment for each key there is at
most one job running.
|
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] |
A state rpc is an easy way for two processes to synchronize a data structure by
sending updates over the wire.
|
Std | |
Subscriber [Bus] | subscribe_exn t ~f causes f to be applied to all values subsequently written to
t (or if t is unstarted, to prior values as well).
|
Summary [Cpu_usage] | |
T | |
Tcp | Tcp supports connection to inet sockets and unix sockets.
|
Tcp [Std] | |
Tcp_file |
Access to on-disk files in parallel with serving them over a TCP connection.
|
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 |
default is
false
|
U | |
Udp |
A grab-bag of performance-oriented, UDP-oriented network tools.
|
Udp [Std] | |
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] | |
User_and_group | |
User_and_group [Std] | |
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 |
Like
Core.Weak_hashtbl , but automatically collects keys with unused data, rather
than requiring user code to call remove_keys_with_unused_data .
|
Weak_hashtbl [Std] | |
Where_to_listen [Tcp] |
A
Where_to_listen describes the socket that a tcp server should listen on.
|