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

For communicating a dynamically chosen TCP port from a child process to its parent.

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.

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

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.

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).