cloudi 2.0.7 (latest) · OCaml Package

type request_type =

| ASYNC
| SYNC

type source = Erlang.Pid.t

type response =

| Response of string
| ResponseInfo of string * string
| Forward of string * string * string
| Forward_ of string * string * string * int * int
| Null
| NullError of string

module Instance : sig ... end

type !'s callback =
  request_type ->
  string ->
  string ->
  string ->
  string ->
  int ->
  int ->
  string ->
  source ->
  's ->
  's Instance.t ->
  response

val trans_id_null : string

val invalid_input_error : string

val message_decoding_error : string

val terminate_error : string

exception ReturnSync

exception ReturnAsync

exception ForwardSync

exception ForwardAsync

exception Terminate

exception FatalError

val api : 
  ?terminate_return_value:bool ->
  int ->
  's ->
  ('s Instance.t, string) result

val thread_count : unit -> (int, string) result

val subscribe : 's Instance.t -> string -> 's callback -> (unit, string) result

val subscribe_count : 's Instance.t -> string -> (int, string) result

val unsubscribe : 's Instance.t -> string -> (unit, string) result

val send_async : 
  ?timeout:int ->
  ?request_info:string ->
  ?priority:int ->
  's Instance.t ->
  string ->
  string ->
  (string, string) result

val send_sync : 
  ?timeout:int ->
  ?request_info:string ->
  ?priority:int ->
  's Instance.t ->
  string ->
  string ->
  (string * string * string, string) result

val mcast_async : 
  ?timeout:int ->
  ?request_info:string ->
  ?priority:int ->
  's Instance.t ->
  string ->
  string ->
  (string array, string) result

val forward_async : 
  's Instance.t ->
  string ->
  string ->
  string ->
  int ->
  int ->
  string ->
  source ->
  (unit, string) result

val forward_sync : 
  's Instance.t ->
  string ->
  string ->
  string ->
  int ->
  int ->
  string ->
  source ->
  (unit, string) result

val forward_ : 
  's Instance.t ->
  request_type ->
  string ->
  string ->
  string ->
  int ->
  int ->
  string ->
  source ->
  (unit, string) result

val return_async : 
  's Instance.t ->
  string ->
  string ->
  string ->
  string ->
  int ->
  string ->
  source ->
  (unit, string) result

val return_sync : 
  's Instance.t ->
  string ->
  string ->
  string ->
  string ->
  int ->
  string ->
  source ->
  (unit, string) result

val return_ : 
  's Instance.t ->
  request_type ->
  string ->
  string ->
  string ->
  string ->
  int ->
  string ->
  source ->
  (unit, string) result

val recv_async : 
  ?timeout:int ->
  ?trans_id:string ->
  ?consume:bool ->
  's Instance.t ->
  (string * string * string, string) result

val process_index : 's Instance.t -> int

val process_index_ : unit -> (int, string) result

val process_count : 's Instance.t -> int

val process_count_max : 's Instance.t -> int

val process_count_max_ : unit -> (int, string) result

val process_count_min : 's Instance.t -> int

val process_count_min_ : unit -> (int, string) result

val prefix : 's Instance.t -> string

val timeout_initialize : 's Instance.t -> int

val timeout_initialize_ : unit -> (int, string) result

val timeout_async : 's Instance.t -> int

val timeout_sync : 's Instance.t -> int

val timeout_terminate : 's Instance.t -> int

val timeout_terminate_ : unit -> (int, string) result

val priority_default : 's Instance.t -> int

val poll : 's Instance.t -> int -> (bool, string) result

val shutdown : ?reason:string -> 's Instance.t -> (unit, string) result

val info_key_value_parse : string -> (string, string list) Hashtbl.t

val info_key_value_new : 
  ?response:bool ->
  (string, string list) Hashtbl.t ->
  string

package cloudi