Index of modules


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
Wrapper around Core.Std.User_and_group with a deferred for_this_process / for_this_process_exn.
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.