Index of modules

Async.Command is Core.Command with additional async functions.

Helpers to make your types Datumable if they are binable.

File_replaced occurs if the inode of the file changed and the file tail was configured with ignore_inode_change = false.

File_writer is a thin wrapper around Writer with a couple of extra features:

Async.Lock_file is a wrapper that provides async equivalents for Core.Lock_file.

A library for general logging.

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.

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.

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.

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.

Implements a value that is either in a file, or in memory, but not both.

add a new version to the set of versions available via implement_multi.

add a new version to the set of versions implemented by implement_multi.

add a new version to the set of versions available via dispatch_multi.

add a new version to the set of versions available via dispatch_multi.

A library for building asynchronous RPC-style protocols.

Initiate an Rpc connection on the given reader/writer pair.

A table of sequencers indexed by key, so that at any moment for each key there is at most one job running.

A Server.t represents a TCP server listening on a socket.

A state rpc is an easy way for two processes to synchronize a data structure by sending updates over the wire.

Tcp supports connection to inet sockets and unix sockets.

Access to on-disk files in parallel with serving them over a TCP connection.

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.

Wrapper around Core.Std.User_and_group with a deferred for_this_process / for_this_process_exn.

Infrastructure code for managing RPCs which evolve over time to use different types at different versions

This module describes the type of a given direction of message flow.

A Weak_hashtbl.t is a hashtable that will drop a key and value if the value is no longer referenced (by any non-weak pointers).

A Where_to_listen describes the socket that a tcp server should listen on.