sig
type inetspec =
[ `Sock_inet of Unix.socket_type * Unix.inet_addr * int
| `Sock_inet_byname of Unix.socket_type * string * int ]
type sockspec =
[ `Sock_inet of Unix.socket_type * Unix.inet_addr * int
| `Sock_inet_byname of Unix.socket_type * string * int
| `Sock_unix of Unix.socket_type * string ]
val sockspec_of_sockaddr :
Unix.socket_type -> Unix.sockaddr -> Uq_client.sockspec
val sockspec_of_socksymbol :
Unix.socket_type -> Netsockaddr.socksymbol -> Uq_client.sockspec
type connect_address =
[ `Command of string * (int -> Unixqueue.event_system -> unit)
| `Socket of Uq_client.sockspec * Uq_client.connect_options
| `W32_pipe of Netsys_win32.pipe_mode * string ]
and connect_options =
Uq_engines.connect_options = {
conn_bind : Uq_client.sockspec option;
}
val default_connect_options : Uq_client.connect_options
type connect_status =
[ `Command of Unix.file_descr * int
| `Socket of Unix.file_descr * Uq_client.sockspec
| `W32_pipe of Unix.file_descr ]
val client_endpoint : Uq_client.connect_status -> Unix.file_descr
val client_channel :
Uq_engines.connect_status -> float -> Netchannels.raw_io_channel
class type client_endpoint_connector =
object
method connect :
Uq_client.connect_address ->
Unixqueue.event_system -> Uq_client.connect_status Uq_engines.engine
end
val connect_e :
?proxy:#Uq_engines.client_endpoint_connector ->
Uq_engines.connect_address ->
Unixqueue.event_system -> Uq_engines.connect_status Uq_engines.engine
val connect :
?proxy:#Uq_engines.client_endpoint_connector ->
Uq_engines.connect_address -> float -> Uq_engines.connect_status
end
