Index of modules

Weak_hashtbl requires that all values in the table be boxed, which ensures that weak pointers and finalization work as expected.

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.

create file opens file, creating it if it doesn't exist.

create ?message path tries to create a file at path containing the text message, pid if none provided.

create f returns a t, given a function that actually performs the final output work.

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.

machinery for communicating names and versions of supported rpcs from within the rpc protocol itself.

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

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 Server.t represents a TCP server listening on a socket.

with_connection ~host ~port f looks up host from a string (using DNS as needed), connects, then calls f passing in a reader and a writer for the connected socket.

serve ~port () must be called before clients will be able to connect.

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.

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.

Weak_hashtbl requires that all values in the table be boxed, which ensures that weak pointers and finalization work as expected.

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