package cloudi

  1. Overview
  2. Docs
package cloudi
Legend:
Library
Module
Module type
Parameter
Class
Class type
type request_type =
  1. | ASYNC
  2. | SYNC
type source = Erlang.Pid.t
type response =
  1. | Response of string
  2. | ResponseInfo of string * string
  3. | Forward of string * string * string
  4. | Forward_ of string * string * string * int * int
  5. | Null
  6. | 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) Stdlib.result
val thread_count : unit -> (int, string) Stdlib.result
val subscribe : 's Instance.t -> string -> 's callback -> (unit, string) Stdlib.result
val subscribe_count : 's Instance.t -> string -> (int, string) Stdlib.result
val unsubscribe : 's Instance.t -> string -> (unit, string) Stdlib.result
val send_async : ?timeout:int -> ?request_info:string -> ?priority:int -> 's Instance.t -> string -> string -> (string, string) Stdlib.result
val send_sync : ?timeout:int -> ?request_info:string -> ?priority:int -> 's Instance.t -> string -> string -> (string * string * string, string) Stdlib.result
val mcast_async : ?timeout:int -> ?request_info:string -> ?priority:int -> 's Instance.t -> string -> string -> (string array, string) Stdlib.result
val forward_async : 's Instance.t -> string -> string -> string -> int -> int -> string -> source -> (unit, string) Stdlib.result
val forward_sync : 's Instance.t -> string -> string -> string -> int -> int -> string -> source -> (unit, string) Stdlib.result
val forward_ : 's Instance.t -> request_type -> string -> string -> string -> int -> int -> string -> source -> (unit, string) Stdlib.result
val return_async : 's Instance.t -> string -> string -> string -> string -> int -> string -> source -> (unit, string) Stdlib.result
val return_sync : 's Instance.t -> string -> string -> string -> string -> int -> string -> source -> (unit, string) Stdlib.result
val return_ : 's Instance.t -> request_type -> string -> string -> string -> string -> int -> string -> source -> (unit, string) Stdlib.result
val recv_async : ?timeout:int -> ?trans_id:string -> ?consume:bool -> 's Instance.t -> (string * string * string, string) Stdlib.result
val process_index : 's Instance.t -> int
val process_count : 's Instance.t -> int
val process_count_max : 's Instance.t -> int
val process_count_min : 's Instance.t -> int
val prefix : 's Instance.t -> string
val timeout_initialize : 's Instance.t -> int
val timeout_async : 's Instance.t -> int
val timeout_sync : 's Instance.t -> int
val timeout_terminate : 's Instance.t -> int
val priority_default : 's Instance.t -> int
val poll : 's Instance.t -> int -> (bool, string) Stdlib.result
val shutdown : ?reason:string -> 's Instance.t -> (unit, string) Stdlib.result
val info_key_value_parse : string -> (string, string list) Stdlib.Hashtbl.t
val info_key_value_new : ?response:bool -> (string, string list) Stdlib.Hashtbl.t -> string