Docs GODI Archive
Projects Blog Link DB

Search GODI:


More options
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
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml