sig
exception Not_in_container_thread
val log : Netplex_types.level -> string -> unit
val logf :
Netplex_types.level -> ('a, unit, string, unit) Pervasives.format4 -> 'a
val report_connection_string : Unix.file_descr -> string -> string
type timer
val create_timer :
(Netplex_cenv.timer -> bool) -> float -> Netplex_cenv.timer
val cancel_timer : Netplex_cenv.timer -> unit
val cancel_all_timers : unit -> unit
val timer_id : Netplex_cenv.timer -> int
exception Container_variable_not_found of string
exception Container_variable_type_mismatch of string
val int_var : string -> int
val string_var : string -> string
val float_var : string -> float
val bool_var : string -> bool
val set_int_var : string -> int -> unit
val set_string_var : string -> string -> unit
val set_float_var : string -> float -> unit
val set_bool_var : string -> bool -> unit
val make_var_type :
('a -> Netplex_types.encap) ->
(Netplex_types.encap -> 'a) -> (string -> 'a) * (string -> 'a -> unit)
module type TYPE = sig type t end
module type VAR_TYPE =
sig
type t
val get : string -> Netplex_cenv.VAR_TYPE.t
val set : string -> Netplex_cenv.VAR_TYPE.t -> unit
end
module Make_var_type :
functor (T : TYPE) ->
sig
type t = T.t
val get : string -> t
val set : string -> t -> unit
end
val system_shutdown : unit -> unit
val system_restart : unit -> unit
val send_message : string -> string -> string array -> unit
val lookup : string -> string -> string option
val lookup_container_sockets : string -> string -> string array
val self_cont : unit -> Netplex_types.container
val self_obj :
unit ->
[ `Container of Netplex_types.container
| `Controller of Netplex_types.controller ]
val current_sys_id : unit -> [ `Process of int | `Thread of int ]
val admin_connector : unit -> Rpc_client.mode2
val run_in_controller_context :
Netplex_types.controller -> (unit -> unit) -> unit
val run_in_container_context :
Netplex_types.container -> (unit -> unit) -> unit
module type FUN_TYPE = sig type s type r end
module type LEVER =
sig
type s
type r
type t = Netplex_cenv.LEVER.s -> Netplex_cenv.LEVER.r
val register :
Netplex_types.controller ->
(Netplex_types.controller -> Netplex_cenv.LEVER.t) ->
Netplex_cenv.LEVER.t
end
module Make_lever :
functor (T : FUN_TYPE) ->
sig
type s = T.s
type r = T.r
type t = s -> r
val register :
Netplex_types.controller -> (Netplex_types.controller -> t) -> t
end
val pmanage : unit -> Netsys_pmanage.pmanage
module Debug : sig val enable : bool Pervasives.ref end
val register_par : Netplex_types.parallelizer -> unit
val register_cont :
Netplex_types.container -> Netplex_types.par_thread -> unit
val unregister_cont :
Netplex_types.container -> Netplex_types.par_thread -> unit
val register_ctrl : Netplex_types.controller -> unit
val unregister_ctrl : Netplex_types.controller -> unit
end
