module Hydro_connector: sig
.. end
Establish connections between a local endpoint and a remote endpoint
Managing connections
class type multiplexed_descriptor = object
.. end
This is a multiplexed connection, used for both clients and
servers
type
client_connector = [ `Endpoint of Hydro_types.endpoint * Hydro_types.network_port option ]
`Endpoint(ep,port)
: port
is the DNS-resolved port of the
port mentioned in ep
(if a DNS resolution happened)
val client_endpoint_type : client_connector -> Hydro_types.endpoint_type
type
master_connector = [ `Anon_endpoint_IPv4 of Hydro_types.endpoint_type
| `Anon_endpoint_IPv6 of Hydro_types.endpoint_type
| `Named_endpoint of Unix.sockaddr * Hydro_types.endpoint_type ]
val master_endpoint_type : master_connector -> Hydro_types.endpoint_type
class type transporter = object
.. end
val register_transporter : transporter -> unit
Registers new transporters. For `TCP
and `UDP
transporters are
pre-registered.
val get_transporter : Hydro_types.endpoint_type -> transporter
Get transporter or raise Limitation `UnsupportedEndpointType
val descriptor : Unix.file_descr ->
bool -> Hydro_types.transport_protocol_type -> Hydro_types.descriptor
descriptor fd is_master tpt
: Create a hydro descriptor
val tcp_endpoint_of_file_descr : Unix.sockaddr -> float -> bool -> Hydro_types.tcp_endpoint
Returns the TCP endpoint for the TCP address, the timeout
value, and the compression flag.