sig
type rcache
type rcache_policy =
[ `Any_failing_port_disables_host
| `Failing_port_disables_host of int
| `Independent
| `None ]
type rcache_config = {
rcache_policy : Rpc_proxy.ReliabilityCache.rcache_policy;
rcache_disable_timeout_min : float;
rcache_disable_timeout_max : float;
rcache_threshold : int;
rcache_availability :
Rpc_proxy.ReliabilityCache.rcache -> Unix.sockaddr -> bool;
}
val create_rcache_config :
?policy:Rpc_proxy.ReliabilityCache.rcache_policy ->
?disable_timeout_min:float ->
?disable_timeout_max:float ->
?threshold:int ->
?availability:(Rpc_proxy.ReliabilityCache.rcache -> Unix.sockaddr -> bool) ->
unit -> Rpc_proxy.ReliabilityCache.rcache_config
val create_rcache :
Rpc_proxy.ReliabilityCache.rcache_config ->
Rpc_proxy.ReliabilityCache.rcache
val rcache_config :
Rpc_proxy.ReliabilityCache.rcache ->
Rpc_proxy.ReliabilityCache.rcache_config
val global_rcache_config : unit -> Rpc_proxy.ReliabilityCache.rcache_config
val set_global_rcache_config :
Rpc_proxy.ReliabilityCache.rcache_config -> unit
val global_rcache : unit -> Rpc_proxy.ReliabilityCache.rcache
val derive_rcache :
Rpc_proxy.ReliabilityCache.rcache ->
Rpc_proxy.ReliabilityCache.rcache_config ->
Rpc_proxy.ReliabilityCache.rcache
val incr_rcache_error_counter :
Rpc_proxy.ReliabilityCache.rcache -> Unix.sockaddr -> unit
val reset_rcache_error_counter :
Rpc_proxy.ReliabilityCache.rcache -> Unix.sockaddr -> unit
val sockaddr_is_enabled :
Rpc_proxy.ReliabilityCache.rcache -> Unix.sockaddr -> bool
val host_is_enabled :
Rpc_proxy.ReliabilityCache.rcache -> Unix.inet_addr -> bool
end
