type extended_proxy_addr =
    < facet : string option; id : Hydro_types.identity;
      mode : Hydro_types.proxy_mode; parameters : extended_proxy_parameters;
      secure : bool >
and extended_proxy_parameters =
    [ `Connectors of
        (Hydro_connector.client_connector * Hydro_types.client_params) list
    | `Endpoints of Hydro_types.endpoint array
    | `Indirect of string ]
type multiplicity = [ `Concurrent of int | `Failover ]
type shared_or_private = [ `Private of <  > | `Shared ]
type domain_resolver =
    Unixqueue.unix_event_system ->
    string -> (Unix.inet_addr option -> unit) -> unit
class type proxy_conf_t =
  object
    method context : (string * string) list
    method deactivation_period : float
    method max_reconnections : int
    method multiplicity : multiplicity
    method resolution_period : float
    method shared_connections : bool
  end
class type proxy_env_t =
  object
    method client_pool : pool_t
    method default_proxy_conf : proxy_conf_t
    method event_system : Unixqueue.event_system
    method proxy_resolver : proxy_resolver_t
    method system : Hydro_types.system
  end
and proxy_resolver_t =
  object
    method resolve :
      extended_proxy_addr ->
      ((Hydro_connector.client_connector * Hydro_types.client_params) list
       Lazy.t -> unit) ->
      proxy_env_t -> unit
  end
and proxy_t =
  object
    method hydro_env : proxy_env_t
    method hydro_facet : string option
    method hydro_id : Hydro_types.identity
    method hydro_proxy_conf : proxy_conf_t
    method hydro_reset : unit -> unit
    method hydro_set_proxy_conf : proxy_conf_t -> unit
    method hydro_shutdown : unit -> unit
    method hydro_twoway_call :
      Hydro_types.hintf ->
      string ->
      Hydro_types.value array ->
      Hydro_types.call_params ->
      (Hydro_endpoint.Client.response -> unit) -> unit
  end
and pool_t =
  object
    method abort : unit -> unit
    method deactivate_host : Unix.inet_addr -> float -> unit
    method deactivate_port : Hydro_types.network_port -> float -> unit
    method is_available :
      Unix.inet_addr ->
      Hydro_types.network_port option -> shared_or_private -> float -> bool
    method request_clients :
      Hydro_types.system ->
      shared_or_private ->
      int ->
      (Hydro_connector.client_connector * Hydro_types.client_params) list ->
      managed_client_t list
    method reset : unit -> unit
    method set_esys : Unixqueue.event_system -> unit
    method shutdown : unit -> unit
    method trigger_shutdown : unit -> unit
  end
and managed_client_t =
  object
    method abort : unit -> unit
    method available : float -> bool
    method clear_error : unit -> unit
    method client : Hydro_endpoint.Client.t
    method client_incarnation : int
    method deactivate : float -> unit
    method error_count : int
    method record_error : float -> unit
    method trigger_shutdown : ?ondown:(unit -> unit) -> unit -> unit
    method unused_since : float option
  end
val proxy_conf :
  ?shared_connections:bool ->
  ?multiplicity:multiplicity ->
  ?max_reconnections:int ->
  ?deactivation_period:float ->
  ?resolution_period:float ->
  ?context:(string * string) list -> unit -> proxy_conf_t
val modify_proxy_conf :
  ?shared_connections:bool ->
  ?multiplicity:multiplicity ->
  ?max_reconnections:int ->
  ?deactivation_period:float ->
  ?resolution_period:float ->
  ?context:(string * string) list -> proxy_conf_t -> proxy_conf_t
val proxy_resolver :
  ?domain_resolver:domain_resolver ->
  Hydro_types.client_params -> proxy_resolver_t
val shuffle : Random.State.t -> proxy_resolver_t -> proxy_resolver_t
val proxy : env:proxy_env_t -> addr:extended_proxy_addr -> unit -> proxy_t
val pool : unit -> pool_t
class proxy_delegation : proxy_t -> proxy_t
class proxy_env_delegation : proxy_env_t -> proxy_env_t
class proxy_resolver_delegation : proxy_resolver_t -> proxy_resolver_t
class pool_delegation : pool_t -> pool_t