Index of modules

create creates a new, unstarted, bus.

This signature is deliberately empty.

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

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

Simple cpu usage statistics.

Helpers to make your types Datumable if they are binable.

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

Errors are written to the pipe, and are nonrecoverable.

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

Programs that want simplistic single-channel logging can open this module.

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.

This functor can be called to generate "singleton" logging modules

Nfs has analogs of functions in Core.Lock_file.Nfs; see there for documentation.

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.

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

Tcp supports connection to inet sockets and unix sockets.

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

default is false

A grab-bag of performance-oriented, UDP-oriented network tools.

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.

Like Core.Weak_hashtbl, but automatically collects keys with unused data, rather than requiring user code to call remove_keys_with_unused_data.

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