package rpc_parallel

  1. Overview
  2. Docs

Parameters

module M : sig ... end

Signature

type worker_id
val spawn_worker : ?where:[ `Local | `Remote of _ Remote_executable.t ] -> ?disown:bool -> ?env:(string * string) list -> ?rpc_max_message_size:int -> ?rpc_handshake_timeout:Core.Time.Span.t -> ?rpc_heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t -> ?connection_timeout:Core.Time.Span.t -> ?cd:string -> ?umask:int -> redirect_stdout:Fd_redirection.t -> redirect_stderr:Fd_redirection.t -> M.worker_arg -> on_failure:(Core.Error.t -> unit) -> (M.worker_ret * worker_id) Core.Or_error.t Async.Deferred.t
val spawn_worker_exn : ?where:[ `Local | `Remote of _ Remote_executable.t ] -> ?disown:bool -> ?env:(string * string) list -> ?rpc_max_message_size:int -> ?rpc_handshake_timeout:Core.Time.Span.t -> ?rpc_heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t -> ?connection_timeout:Core.Time.Span.t -> ?cd:string -> ?umask:int -> redirect_stdout:Fd_redirection.t -> redirect_stderr:Fd_redirection.t -> M.worker_arg -> on_failure:(Core.Error.t -> unit) -> (M.worker_ret * worker_id) Async.Deferred.t
val kill_worker : worker_id -> unit Core.Or_error.t Async.Deferred.t
val run : ?rpc_max_message_size:int -> ?rpc_handshake_timeout:Core.Time.Span.t -> ?rpc_heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t -> ?where_to_listen:Async.Tcp.Where_to_listen.inet -> Async.Command.t -> unit
OCaml

Innovation. Community. Security.