package ocamlnet

  1. Overview
  2. Docs
package ocamlnet
Legend:
Library
Module
Module type
Parameter
Class
Class type
type mclient
type mclient_config = {
  1. mclient_rcache : ReliabilityCache.rcache;
  2. mclient_socket_config : Rpc_client.socket_config;
  3. mclient_idle_timeout : float;
  4. mclient_programs : Rpc_program.t list;
  5. mclient_msg_timeout : float;
  6. mclient_msg_timeout_is_fatal : bool;
  7. mclient_exception_handler : (exn -> unit) option;
  8. mclient_auth_methods : Rpc_client.auth_method list;
  9. mclient_user_name : string option;
  10. mclient_initial_ping : bool;
  11. mclient_max_response_length : int option;
  12. mclient_mstring_factories : Netxdr_mstring.named_mstring_factories option;
}
exception Service_unavailable
val create_mclient_config : ?rcache:ReliabilityCache.rcache -> ?socket_config:Rpc_client.socket_config -> ?idle_timeout:float -> ?programs:Rpc_program.t list -> ?msg_timeout:float -> ?msg_timeout_is_fatal:bool -> ?exception_handler:(exn -> unit) -> ?auth_methods:Rpc_client.auth_method list -> ?user_name:string option -> ?initial_ping:bool -> ?max_response_length:int -> ?mstring_factories:Netxdr_mstring.named_mstring_factories -> unit -> mclient_config
type state = [
  1. | `Connecting
  2. | `Down
  3. | `Up of Unix.sockaddr option
]
val mclient_state : mclient -> state
val mclient_serial : mclient -> int
val pending_calls : mclient -> int
val event_system : mclient -> Unixqueue.event_system
val shut_down : mclient -> unit
val sync_shutdown : mclient -> unit
val trigger_shutdown : mclient -> (unit -> unit) -> unit
val record_unavailability : mclient -> unit
val enforce_unavailability : mclient -> unit
val set_batch_call : mclient -> unit
val rpc_engine : mclient -> (mclient -> 'a -> ((unit -> 'b) -> unit) -> unit) -> 'a -> 'b Uq_engines.engine
val compare : mclient -> mclient -> int
type t = mclient
val use : t -> Rpc_program.t -> unit
val unbound_sync_call : t -> Rpc_program.t -> string -> Netxdr.xdr_value -> Netxdr.xdr_value
val unbound_async_call : t -> Rpc_program.t -> string -> Netxdr.xdr_value -> ((unit -> Netxdr.xdr_value) -> unit) -> unit
val xdr_ctx : t -> Netxdr.ctx