Plasma GitLab Archive
Projects Blog Knowledge

sig
  type mset
  type mset_policy = [ `Balance_load | `Failover ]
  type mset_config = {
    mset_mclient_config : Rpc_proxy.ManagedClient.mclient_config;
    mset_policy : Rpc_proxy.ManagedSet.mset_policy;
    mset_pending_calls_max : int;
    mset_pending_calls_norm : int;
    mset_idempotent_max : int;
    mset_idempotent_wait : float;
  }
  exception Cluster_service_unavailable
  val create_mset_config :
    ?mclient_config:Rpc_proxy.ManagedClient.mclient_config ->
    ?policy:Rpc_proxy.ManagedSet.mset_policy ->
    ?pending_calls_max:int ->
    ?pending_calls_norm:int ->
    ?idempotent_max:int ->
    ?idempotent_wait:float -> unit -> Rpc_proxy.ManagedSet.mset_config
  val create_mset :
    Rpc_proxy.ManagedSet.mset_config ->
    (Rpc_client.connector * int) array ->
    Unixqueue.event_system -> Rpc_proxy.ManagedSet.mset
  val mset_pick :
    ?from:int list ->
    Rpc_proxy.ManagedSet.mset -> Rpc_proxy.ManagedClient.mclient * int
  val mset_services :
    Rpc_proxy.ManagedSet.mset -> (Rpc_client.connector * int) array
  val mset_load : Rpc_proxy.ManagedSet.mset -> int array
  val event_system : Rpc_proxy.ManagedSet.mset -> Unixqueue.event_system
  val shut_down : Rpc_proxy.ManagedSet.mset -> unit
  val sync_shutdown : Rpc_proxy.ManagedSet.mset -> unit
  val trigger_shutdown : Rpc_proxy.ManagedSet.mset -> (unit -> unit) -> unit
  val idempotent_async_call :
    ?from:int list ->
    Rpc_proxy.ManagedSet.mset ->
    (Rpc_proxy.ManagedClient.mclient -> '-> ((unit -> 'b) -> unit) -> unit) ->
    '-> ((unit -> 'b) -> unit) -> unit
  val idempotent_sync_call :
    ?from:int list ->
    Rpc_proxy.ManagedSet.mset ->
    (Rpc_proxy.ManagedClient.mclient -> '-> ((unit -> 'b) -> unit) -> unit) ->
    '-> 'b
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml