package rpc_parallel

You can search for identifiers within the package.

in-package search v0.2.0

rpc_parallel
- Rpc_parallel
  - Fd_redirection
  - How_to_run
  - Managed
    
    Make
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Diff
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    S
    
    Connection_state
    
    Functions
    
    C
    
    Worker_state
    
    Worker
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Diff
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
  - Map_reduce
    
    Config
    
    Make_map_function
    
    S
    
    Worker
    
    Make_map_function_with_init
    
    S
    
    Worker
    
    Make_map_reduce_function
    
    S
    
    Worker
    
    Make_map_reduce_function_with_init
    
    S
    
    Worker
    
    Map_function
    
    Worker
    
    Map_function_spec
    
    Map_function_with_init_spec
    
    Map_reduce_function
    
    Worker
    
    Map_reduce_function_spec
    
    Map_reduce_function_with_init_spec
    
    Worker
  - Parallel
    
    Backend
    
    Settings
    
    Backend_and_settings
    
    Creator
    
    Expert
    
    Worker_env
    
    For_testing
    
    Function
    
    Direct_pipe
    
    Id
    
    For_internal_testing
    
    Functions
    
    Make
    
    Connection
    
    Deprecated
    
    For_internal_testing
    
    Spawn_in_foreground_result
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Diff
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    S
    
    Connection_state
    
    Functions
    
    C
    
    Worker_state
    
    Shutdown_on
    
    Spawn_in_foreground_exn_result
    
    Spawn_in_foreground_result
    
    State
    
    Worker
    
    Connection
    
    Deprecated
    
    For_internal_testing
    
    Spawn_in_foreground_result
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Diff
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Shutdown_on
    
    Spawn_in_foreground_exn_result
    
    Spawn_in_foreground_result
    
    Worker_spec
    
    Connection_state
    
    Functions
    
    C
    
    Worker_state
  - Prog_and_args
  - Remote_executable
  - Rpc_settings
    
    For_internal_testing
  - Utils
    
    Internal_connection_state
    
    Worker_id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Diff
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Worker_type_id
    
    For_testing
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Diff
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Diff
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
rpc_parallel.unauthenticated
- Rpc_parallel_unauthenticated
  - Expert
  - For_testing

Legend:
Library
Module
Module type
Parameter
Class
Class type

type t = {

max_message_size : int option;
buffer_age_limit : Async.Writer.buffer_age_limit option;
handshake_timeout : Core.Time_float.Span.t option;
heartbeat_config : Async.Rpc.Connection.Heartbeat_config.t option;

}

include Core.Bin_prot.Binable.S with type t := t

val bin_size_t : t Bin_prot__.Size.sizer

val bin_write_t : t Bin_prot__.Write.writer

val bin_read_t : t Bin_prot__.Read.reader

val __bin_read_t__ : (int -> t) Bin_prot__.Read.reader

val bin_shape_t : Bin_prot__.Shape.t

val bin_writer_t : t Bin_prot__.Type_class.writer

val bin_reader_t : t Bin_prot__.Type_class.reader

val bin_t : t Bin_prot__.Type_class.t

include Sexplib0.Sexpable.S with type t := t

val t_of_sexp : Sexplib0__.Sexp.t -> t

val sexp_of_t : t -> Sexplib0__.Sexp.t

val env_var : string

env_var is the name of the environment variable read by rpc-parallel on start-up to inject additional rpc-settings for the application.

val default : t

Use all the default rpc settings. This is the record with None in every field.

val to_string_for_env_var : 
  ?max_message_size:int ->
  ?buffer_age_limit:Async.Writer.buffer_age_limit ->
  ?handshake_timeout:Core.Time_float.Span.t ->
  ?heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ->
  unit ->
  string

to_string_for_env_var generates the expected string format from the arguments matching the start_app function to be used with the env_var above.

val create_with_env_override : 
  max_message_size:int option ->
  buffer_age_limit:Async.Writer.buffer_age_limit option ->
  handshake_timeout:Core.Time_float.Span.t option ->
  heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t option ->
  t

module For_internal_testing : sig ... end