Package async_extra v0.9.0

async_extra

Async_extra
Async_extra__BusAn Async extension of Core_kernel.Bus. Functions that share the same name and types as those in Core_kernel.Bus are direct calls to the same.
Async_extra__CommandAsync.Command is Core.Command with additional Async functions.
Async_extra__Cpu_usageSimple cpu usage statistics.
Async_extra__Dynamic_port_writerFor communicating a dynamically chosen TCP port from a child process to its parent.
Async_extra__File_tailFile_tail is useful for pulling data from a file that is being appended to by another process. Creating a file tail returns the reader half of a pipe whose writer half is populated by a background process that roughly does the following loop.
Async_extra__File_writerFile_writer is a thin wrapper around Writer with a couple of extra features:
Async_extra__Import
Async_extra__Lock_fileAsync.Lock_file is a wrapper that provides Async equivalents for Core.Lock_file.
Async_extra__Persistent_connection
Async_extra__Persistent_connection_intfAn actively maintained connection to some service that eagerly and repeatedly attempts to reconnect whenever the underlying connection is lost, until a new one can be established.
Async_extra__Persistent_singletonImplements a value that is either in a file, or in memory, but not both. Is used by live and the friend to store sequence numbers and counters. If the value is moved to memory, changed, and then the process crashes, the file will correctly reflect that the value has been lost.
Async_extra__RpcThis module just re-exports lots of modules from Async_rpc_kernel and adds some Unix-specific wrappers in Connection (for using Reader, Writer, and Tcp). For documentation, see Rpc and Connection_intf in the Async_rpc_kernel library.
Async_extra__Rpc_transport
Async_extra__Rpc_transport_low_latencyThis module implements a RPC transport optimized for low-latency.
Async_extra__Schedule
Async_extra__Schedule_unit_tests
Async_extra__Sequencer_tableA table of sequencers indexed by key, so that at any moment for each key there is at most one job running.
Async_extra__Std
Async_extra__TcpTcp supports connection to inet sockets and unix sockets. These are two different types. We use 'a where_to_connect to specify a socket to connect to, where the 'a identifies the type of socket.
Async_extra__Tcp_fileAccess to on-disk files in parallel with serving them over a TCP connection.
Async_extra__Typed_tcp
Async_extra__Typed_tcp_intf
Async_extra__UdpA grab-bag of performance-oriented, UDP-oriented network tools. These provide some convenience, but they are more complex than basic applications require.
Async_extra__Unpack_sequenceUnpack_sequence uses an Unpack_buffer.t to unpack a sequence of packed values coming from a string Pipe.Reader.t or a Reader.t. It can produce a pipe of upacked values or iterate a user-supplied function over the unpacked values.
Async_extra__User_and_groupWrapper around Core.User_and_group with a deferred for_this_process / for_this_process_exn.
Async_extra__Versioned_typed_tcp
Async_extra__Versioned_typed_tcp_intf
Async_extra__Weak_hashtblLike Core.Weak_hashtbl, but automatically collects keys with unused data, rather than requiring user code to call remove_keys_with_unused_data.

Info

authors
  • Jane Street Group, LLC <opensource@janestreet.com>
change log
deps
homepage
issues
licenses
  • Apache-2.0
licenses
maintainers
  • opensource@janestreet.com
versionv0.9.0