type protocol_violation =
    [ `BadMessageType
    | `CompressionNotSupported
    | `MessageFormatViolation of string ]
exception Protocol_violation of protocol_violation
exception Marshal_error of string
exception Unmarshal_error of string
type limitation =
    [ `UnsupportedEncodingVersion
    | `UnsupportedEndpointType of int
    | `UnsupportedProtocolVersion ]
exception Limitation of limitation
type proxy_error =
    [ `NoCallableEndpointFound
    | `NoEndpointIsReachable
    | `NoLocatorIsReachable
    | `ProxyIsDown ]
exception Proxy_error of proxy_error
exception Domain_not_found of string
exception Unbound_exception of exn
exception Unimplemented_operation of string
type noreturn = Hydro_types.noreturn
type value =
    [ `Bool of bool
    | `Byte of int
    | `Byteseq of string
    | `Class of class_repr ref
    | `Dictionary of (value * value) array
    | `DirectWriter of Netbuffer.t -> unit
    | `Double of float
    | `Enum of int
    | `Float of float
    | `Int of int
    | `Int32 of int32
    | `Long of int64
    | `Nothing
    | `Null
    | `Proxy of proxy_addr
    | `Sequence of value array
    | `Short of int
    | `String of string
    | `Struct of value array ]
and class_repr = [ `Placeholder of int32 | `Value of object_value ]
and sliced_value = < hydro_effective_id : string; hydro_slices : slice list >
and object_value =
    < hydro_effective_id : string; hydro_inflate : string -> noreturn;
      hydro_invoke_operation : string -> value array -> session -> unit;
      hydro_slices : slice list >
and slice = [ `Decoded of string * value array | `Opaque of string * string ]
and proxy_addr =
    < facet : string option; id : identity; mode : proxy_mode;
      parameters : proxy_parameters; secure : bool >
and proxy_mode =
    [ `Batch_datagram | `Batch_oneway | `Datagram | `Oneway | `Twoway ]
and proxy_parameters = [ `Endpoints of endpoint array | `Indirect of string ]
and endpoint =
    [ `SSL of ssl_endpoint
    | `TCP of tcp_endpoint
    | `UDP of udp_endpoint
    | `Unknown of int * string ]
and endpoint_type = [ `SSL | `TCP | `UDP | `Unknown of int ]
and tcp_endpoint =
    < compress : bool; host : string; port : int; timeout : int32 >
and udp_endpoint =
    < compress : bool; enc_major : int; enc_minor : int; host : string;
      port : int; proto_major : int; proto_minor : int >
and ssl_endpoint = tcp_endpoint
and identity = < category : string; name : string >
and htype =
    [ `Bool
    | `Byte
    | `Byteseq
    | `Class of string
    | `Dictionary of htype * htype
    | `Double
    | `Enum of string array
    | `Float
    | `Int
    | `Int32
    | `Long
    | `Proxy of string
    | `Sequence of htype
    | `Short
    | `String
    | `Struct of (string * htype) array
    | `Void ]
and hexn =
    < elements : (string * htype) array; name : string; super : hexn option >
and hintf = < elements : hfunction list; name : string; super : hintf list >
and hfunction =
    < in_args : (string * htype) array; in_classes : bool; mode : op_mode;
      name : string; out_args : (string * htype) array; out_classes : 
      bool; result : htype >
and hclass =
    < elements : (string * htype) array; name : string;
      super : hclass option >
and system =
    < classes : hclass Hydro_prelim.CiHashtbl.t;
      ctors : (sliced_value -> object_value) Hydro_prelim.CiHashtbl.t;
      exceptions : hexn Hydro_prelim.CiHashtbl.t;
      interfaces : hintf Hydro_prelim.CiHashtbl.t;
      types : htype Hydro_prelim.CiHashtbl.t >
and op_mode = [ `Idempotent | `Nonmutating | `Normal ]
and msg_type =
    [ `Batch_request
    | `Close_connection
    | `Reply
    | `Request
    | `Validate_connection ]
and compression_status =
    [ `Compressed | `Compression_unsupported | `Uncompressed ]
and msg_header =
    < body_size : int; compression : compression_status; enc_major : 
      int; enc_minor : int; msg_type : msg_type; proto_major : int;
      proto_minor : int >
and encap_buffer =
  Hydro_types.encap_buffer = {
  encap_buf : Netbuffer.t;
  encap_pos : int;
  encap_len : int;
  encap_enc_minor : int;
}
and msg_buffer = msg_header * encap_buffer list
and msg =
    [ `Batch_request of batch_request_msg list
    | `Close_connection
    | `Reply of reply_msg
    | `Request of request_msg
    | `Validate_connection ]
and request_msg =
    < context : (string * string) array; facet : string option;
      id : identity; mode : op_mode; operation : string;
      params : encap_buffer; request_id : int32 >
and batch_request_msg =
    < context : (string * string) array; facet : string option;
      id : identity; mode : op_mode; operation : string;
      params : encap_buffer >
and reply_msg = < request_id : int32; result : result >
and result =
    [ `Facet_does_not_exist of identity * string option * string
    | `Object_does_not_exist of identity * string option * string
    | `Operation_does_not_exist of identity * string option * string
    | `Success of encap_buffer
    | `Unknown_exception of string
    | `Unknown_local_exception of string
    | `Unknown_user_exception of string
    | `User_exception of encap_buffer ]
and call_params =
    < context : (string * string) list option;
      destination : Unix.sockaddr option; msg_timeout : float option >
and exn_handler = < handle : exn -> unit >
and client_params =
    < exception_handler : exn_handler; idle_timeout : float;
      max_enc_minor : int option; max_proto_minor : int option;
      msg_timeout : float; trans_timeout : float >
and server_params = < trans_timeout : float >
and server_ops =
    < abort_connection : unit -> unit; endpoint : endpoint;
      event_system : Unixqueue.event_system; server_id : int;
      server_params : server_params; shutdown_connection : unit -> unit;
      system : system >
and session =
    < context : (string * string) list;
      emit_result : value -> value array -> unit;
      emit_unknown_exception : string -> unit;
      emit_unknown_local_exception : string -> unit;
      emit_unknown_user_exception : string -> unit;
      emit_user_exception : sliced_value -> unit; is_responded : bool;
      request_id : int32; response : reply_msg option;
      server_ops : server_ops >
and operation_dispatcher =
    < hydro_effective_id : string;
      hydro_invoke_operation : string -> value array -> session -> unit >
and facet_dispatcher =
    < invoke_facet : string option -> operation_dispatcher >
and object_dispatcher =
    < get_identity : operation_dispatcher -> identity;
      invoke_object : identity -> facet_dispatcher >
and client_condition =
    [ `Client_is_down
    | `Connect_error of exn
    | `Connect_timeout
    | `Error of exn
    | `Facet_does_not_exist of identity * string option * string
    | `Message_lost of bool
    | `Message_timeout
    | `Object_does_not_exist of identity * string option * string
    | `Operation_does_not_exist of identity * string option * string
    | `Transport_timeout
    | `Unknown_exception of string
    | `Unknown_local_exception of string
    | `Unknown_user_exception of string
    | `User_exception of sliced_value ]
exception Client_condition of client_condition
type transport_protocol_type = [ `Datagram | `Stream ]
class type descriptor =
  object
    method file_descr : Unix.file_descr
    method is_master : bool
    method proto_type : transport_protocol_type
    method shutdown : unit -> unit
  end
type network_port =
    [ `TCP of Unix.inet_addr * int | `UDP of Unix.inet_addr * int ]