package ocluster-api

  1. Overview
  2. Docs
package ocluster-api
Legend:
Library
Module
Module type
Parameter
Class
Class type
type worker_info = {
  1. name : string;
  2. active : bool;
  3. connected : bool;
}
val pp_worker_info : Stdlib.Format.formatter -> worker_info -> unit
val local : show:(unit -> string) -> workers:(unit -> worker_info list) -> worker: (string -> [ `Worker_e06eedcf95bf7905 ] Capnp_rpc_lwt.Capability.t option) -> set_active: (auto_create:bool -> string -> bool -> (unit, [< `Unknown_worker ]) Stdlib.result) -> drain: (?progress:[ `Progress_d7529e2702cd958a ] Capnp_rpc_lwt.Capability.t -> string -> ((Capnp__MessageSig.rw, [ `Drain_f66636042afca0d6 ]) Capnp_rpc_lwt.StructStorage.t Capnp_rpc_lwt.Service.Response.t, [< `Capnp of Capnp_rpc.Error.t ]) Stdlib.result Lwt.t) -> update: (?progress:[ `Progress_d7529e2702cd958a ] Capnp_rpc_lwt.Capability.t -> string -> ((Capnp__MessageSig.rw, [ `Update_b4b276698d845933 ]) Capnp_rpc_lwt.StructStorage.t Capnp_rpc_lwt.Service.Response.t, [< `Capnp of Capnp_rpc.Error.t ]) Stdlib.result Lwt.t) -> forget: (string -> (Capnp__MessageSig.rw, [ `Forget_b706558828ef0e92 ]) Capnp_rpc_lwt.StructStorage.t Capnp_rpc_lwt.StructRef.t) -> set_rate: (client_id:string -> float -> (unit, [< `No_such_user ]) Stdlib.result) -> [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t
val show : [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> string Lwt.t
val workers : [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> worker_info list Lwt.t
val worker : [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> string -> [ `Worker_e06eedcf95bf7905 ] Capnp_rpc_lwt.Capability.t
val set_active : ?auto_create:bool -> [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> string -> bool -> unit Lwt.t
val drain : ?progress:[ `Progress_d7529e2702cd958a ] Capnp_rpc_lwt.Capability.t -> [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> string -> unit Lwt.t
val update : ?progress:[ `Progress_d7529e2702cd958a ] Capnp_rpc_lwt.Capability.t -> [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> string -> (unit, [> `Capnp of Capnp_rpc.Error.t ]) Lwt_result.t
val forget : [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> string -> (unit, [> `Capnp of Capnp_rpc.Error.t ]) Lwt_result.t
val set_rate : [ `PoolAdmin_d906b771b4082451 ] Capnp_rpc_lwt.Capability.t -> client_id:string -> float -> unit Lwt.t