sig
class type virtual v_processor =
object
method global_exception_handler : exn -> bool
method post_add_hook :
Netplex_types.socket_service -> Netplex_types.controller -> unit
method post_finish_hook :
Netplex_types.socket_service ->
Netplex_types.controller -> Netplex_types.container_id -> unit
method post_rm_hook :
Netplex_types.socket_service -> Netplex_types.controller -> unit
method post_start_hook : Netplex_types.container -> unit
method pre_finish_hook : Netplex_types.container -> unit
method pre_start_hook :
Netplex_types.socket_service ->
Netplex_types.controller -> Netplex_types.container_id -> unit
method virtual process :
when_done:(unit -> unit) ->
Netplex_types.container -> Unix.file_descr -> string -> unit
method receive_admin_message :
Netplex_types.container -> string -> string array -> unit
method receive_message :
Netplex_types.container -> string -> string array -> unit
method shutdown : unit -> unit
method virtual supported_ptypes :
Netplex_types.parallelization_type list
method system_shutdown : unit -> unit
end
class empty_processor_hooks : unit -> Netplex_types.processor_hooks
class processor_hooks_delegation :
Netplex_types.processor_hooks -> Netplex_types.processor_hooks
class virtual processor_base : Netplex_types.processor_hooks -> v_processor
class protocol_switch_processor :
(string * Netplex_types.processor) list -> Netplex_types.processor
class protocol_switch_factory :
string ->
(string * Netplex_types.processor_factory) list ->
Netplex_types.processor_factory
val add_helper_service :
Netplex_types.controller ->
string -> Netplex_types.processor_hooks -> unit
val create_protocol :
?lstn_backlog:int ->
?lstn_reuseaddr:bool ->
?so_keepalive:bool ->
?configure_slave_socket:(Unix.file_descr -> unit) ->
string -> Netplex_types.extended_address array -> Netplex_types.protocol
val create_socket_service_config :
?startup_timeout:float ->
?change_user_to:int * int ->
string ->
Netplex_types.protocol list ->
Netplex_types.controller_config -> Netplex_types.socket_service_config
end
