package rpc_parallel

You can search for identifiers within the package.

in-package search v0.2.0

On This Page

Parameters
Signature

rpc_parallel.core
- Rpc_parallel_core_deprecated
  - Parallel
    
    Fd_redirection
    
    Make
    
    M
    
    Remote_executable
  - Std
  - Worker_id
    
    Hash_queue
    
    Key
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key

Legend:
Library
Module
Module type
Parameter
Class
Class type

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