| File lib/ocaml/pkg-lib/netplex/netplex_types.cmi_pretty | GODI Package godi-ocamlnet |
| Library netplex |
| Netplex_types.html | netplex_types.cmi_pretty | netplex_types.mli | Sources |
type param_value = [ `Bool of bool | `Float of float | `Int of int | `String of string ] type param_value_or_any = [ `Any of exn | `Bool of bool | `Float of float | `Int of int | `String of string ] type level = [ `Alert | `Crit | `Debug | `Emerg | `Err | `Info | `Notice | `Warning ] class type logger = object method log : component:string -> level:level -> message:string -> unit method max_level : level method reopen : unit -> unit method set_max_level : level -> unit end type parallelization_type = [ `Controller_attached | `Multi_processing | `Multi_threading ] type socket_state = [ `Disabled | `Down | `Enabled | `Restarting of bool ] type container_id = < > type container_state = [ `Accepting of int * float | `Busy | `Shutting_down | `Starting of float ] type capacity = [ `Low_quality of int | `Normal_quality of int | `Unavailable ] class type controller = object method add_admin : (Rpc_server.t -> unit) -> unit method add_service : socket_service -> workload_manager -> unit method controller_config : controller_config method event_system : Unixqueue.unix_event_system method logger : logger method ptype : parallelization_type method restart : unit -> unit method services : (socket_service * socket_controller * workload_manager) list method shutdown : unit -> unit end and controller_config = object method create_logger : controller -> logger method socket_directory : string end and socket_service = object method create_container : parallelization_type -> socket_service -> container method name : string method processor : processor method socket_service_config : socket_service_config method sockets : (string * Unix.file_descr array) list end and socket_service_config = object method change_user_to : (int * int) option method name : string method protocols : protocol list end and protocol = object method addresses : Unix.sockaddr array method configure_slave_socket : Unix.file_descr -> unit method lstn_backlog : int method lstn_reuseaddr : bool method name : string method so_keepalive : bool end and socket_controller = object method container_state : (container_id * container_state * bool) list method disable : unit -> unit method enable : unit -> unit method restart : unit -> unit method shutdown : unit -> unit method start_containers : int -> unit method state : socket_state method stop_containers : container_id list -> unit end and processor_hooks = object method global_exception_handler : exn -> bool method post_add_hook : socket_service -> unit method post_finish_hook : socket_service -> controller -> container_id -> unit method post_rm_hook : socket_service -> unit method post_start_hook : container -> unit method pre_finish_hook : container -> unit method pre_start_hook : socket_service -> controller -> container_id -> unit method receive_admin_message : container -> string -> string array -> unit method receive_message : container -> string -> string array -> unit method shutdown : unit -> unit end and processor = object method global_exception_handler : exn -> bool method post_add_hook : socket_service -> unit method post_finish_hook : socket_service -> controller -> container_id -> unit method post_rm_hook : socket_service -> unit method post_start_hook : container -> unit method pre_finish_hook : container -> unit method pre_start_hook : socket_service -> controller -> container_id -> unit method process : when_done:(unit -> unit) -> container -> Unix.file_descr -> string -> unit method receive_admin_message : container -> string -> string array -> unit method receive_message : container -> string -> string array -> unit method shutdown : unit -> unit method supported_ptypes : parallelization_type list end and container = object method event_system : Unixqueue.unix_event_system method log : level -> string -> unit method lookup : string -> string -> string option method ptype : parallelization_type method send_message : string -> string -> string array -> unit method set_var : string -> param_value_or_any -> unit method shutdown : unit -> unit method socket_service : socket_service method start : Unix.file_descr -> Unix.file_descr -> unit method system : Rpc_client.t method var : string -> param_value_or_any end and workload_manager = object method adjust : socket_service -> socket_controller -> unit method capacity : container_id -> container_state -> capacity method hello : controller -> unit method shutdown : unit -> unit end class type par_thread = object method info_string : string method parallelizer : parallelizer method ptype : parallelization_type method sys_id : [ `Process of int | `Thread of int ] method watch_shutdown : Unixqueue.unix_event_system -> unit end and parallelizer = object method create_mem_mutex : unit -> (unit -> unit) * (unit -> unit) method current_sys_id : [ `Process of int | `Thread of int ] method init : unit -> unit method ptype : parallelization_type method start_thread : (par_thread -> unit) -> Unix.file_descr list -> string -> logger -> par_thread end type config_tree = [ `Parameter of address * string * param_value | `Section of address * string * config_tree list ] and address = < > class type config_file = object method bool_param : address -> bool method filename : string method float_param : address -> float method int_param : address -> int method print : address -> string method resolve_parameter : address -> string -> address method resolve_section : address -> string -> address list method restrict_parameters : address -> string list -> unit method restrict_subsections : address -> string list -> unit method root_addr : address method root_name : string method string_param : address -> string method tree : config_tree end class type processor_factory = object method create_processor : controller_config -> config_file -> address -> processor method name : string end class type workload_manager_factory = object method create_workload_manager : controller_config -> config_file -> address -> workload_manager method name : string end class type logger_factory = object method create_logger : config_file -> address -> controller -> logger method name : string end class type netplex_config = object method controller_config : controller_config method ptype : parallelization_type method services : (socket_service_config * (address * processor_factory) * (address * workload_manager_factory)) list end