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
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Elt
    
    Provide_bin_io
    
    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
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Elt
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
  - Map_reduce
    
    Config
    
    Make_map_function
    
    Input
    
    Output
    
    Param
    
    S
    
    Input
    
    Output
    
    Worker
    
    Make_map_function_with_init
    
    Input
    
    Output
    
    Param
    
    S
    
    Input
    
    Output
    
    Param
    
    Worker
    
    Make_map_reduce_function
    
    Accum
    
    Input
    
    Param
    
    S
    
    Accum
    
    Input
    
    Worker
    
    Make_map_reduce_function_with_init
    
    Accum
    
    Input
    
    Param
    
    S
    
    Accum
    
    Input
    
    Param
    
    Worker
    
    Map_function
    
    Input
    
    Output
    
    Param
    
    Worker
    
    Map_function_spec
    
    Input
    
    Output
    
    Map_function_with_init_spec
    
    Input
    
    Output
    
    Param
    
    Map_reduce_function
    
    Accum
    
    Input
    
    Param
    
    Worker
    
    Map_reduce_function_spec
    
    Accum
    
    Input
    
    Map_reduce_function_with_init_spec
    
    Accum
    
    Input
    
    Param
    
    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
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Elt
    
    Provide_bin_io
    
    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
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Elt
    
    Provide_bin_io
    
    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
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Elt
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Worker_type_id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_bin_io
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Set
    
    Elt
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
rpc_parallel.krb
- Rpc_parallel_krb_public
  - Expert
  - For_testing
  - Mode
    
    Kerberized
rpc_parallel.unauthenticated
- Rpc_parallel_unauthenticated
  - Expert
  - For_testing

Legend:
Library
Module
Module type
Parameter
Class
Class type

module Elt : sig ... end

include Core.Set_intf.S with module Elt := Elt

include Core.Set_intf.S_plain with module Elt := Elt

type t = (Elt.t, Elt.comparator_witness) Base.Set.t

include Ppx_compare_lib.Comparable.S with type t := t

val compare : t Base__Ppx_compare_lib.compare

include Ppx_compare_lib.Equal.S with type t := t

val equal : t Base__Ppx_compare_lib.equal

include Core.Set_intf.Creators_generic
  with type ('a, 'b) set := ('a, 'b) Core__.Set_intf.Set.t
  with type ('a, 'b) t := t
  with type ('a, 'b) tree :=
         (Elt.t, Elt.comparator_witness) Core__.Set_intf.Tree.t
  with type 'a elt := Elt.t
  with type 'c cmp := Elt.comparator_witness
  with type ('a, 'b, 'c) create_options :=
         ('a, 'b, 'c) Core__.Set_intf.Without_comparator.t

val empty : ('a, 'cmp, t) Core__.Set_intf.Without_comparator.t

val singleton : ('a, 'cmp, Elt.t -> t) Core__.Set_intf.Without_comparator.t

val union_list : ('a, 'cmp, t list -> t) Core__.Set_intf.Without_comparator.t

val of_list : ('a, 'cmp, Elt.t list -> t) Core__.Set_intf.Without_comparator.t

val of_sequence : 
  ('a, 'cmp, Elt.t Base__.Sequence.t -> t) Core__.Set_intf.Without_comparator.t

val of_array : 
  ('a, 'cmp, Elt.t array -> t) Core__.Set_intf.Without_comparator.t

val of_sorted_array : 
  ('a, 'cmp, Elt.t array -> t Base__.Or_error.t)
    Core__.Set_intf.Without_comparator.t

val of_sorted_array_unchecked : 
  ('a, 'cmp, Elt.t array -> t) Core__.Set_intf.Without_comparator.t

val of_increasing_iterator_unchecked : 
  ('a, 'cmp, len:int -> f:(int -> Elt.t) -> t)
    Core__.Set_intf.Without_comparator.t

val stable_dedup_list : 
  ('a, 'b, Elt.t list -> Elt.t list) Core__.Set_intf.Without_comparator.t

val map : 
  ('b, 'cmp, ('a, 'c) Core__.Set_intf.Set.t -> f:('a -> Elt.t) -> t)
    Core__.Set_intf.Without_comparator.t

val filter_map : 
  ('b, 'cmp, ('a, 'c) Core__.Set_intf.Set.t -> f:('a -> Elt.t option) -> t)
    Core__.Set_intf.Without_comparator.t

val of_tree : 
  ('a, 'cmp, (Elt.t, Elt.comparator_witness) Core__.Set_intf.Tree.t -> t)
    Core__.Set_intf.Without_comparator.t

val of_hash_set : 
  ('a, 'cmp, Elt.t Core.Hash_set.t -> t) Core__.Set_intf.Without_comparator.t

val of_hashtbl_keys : 
  ('a, 'cmp, (Elt.t, _) Core.Hashtbl.t -> t)
    Core__.Set_intf.Without_comparator.t

val of_map_keys : (Elt.t, _, Elt.comparator_witness) Base.Map.t -> t

Never requires a comparator because it can get one from the input Map.t.

val quickcheck_generator : 
  ('a,
    'cmp,
    Elt.t Core.Quickcheck.Generator.t ->
    t Core.Quickcheck.Generator.t)
    Core__.Set_intf.Without_comparator.t

module Provide_of_sexp (Elt : sig ... end) : sig ... end

module Provide_bin_io
  (Elt : sig ... end) : 
  Core.Set_intf.Binable.S with type t := t

module Provide_hash (Elt : sig ... end) : sig ... end

val quickcheck_observer : 
  Elt.t Core.Quickcheck.Observer.t ->
  t Core.Quickcheck.Observer.t

val quickcheck_shrinker : 
  Elt.t Core.Quickcheck.Shrinker.t ->
  t Core.Quickcheck.Shrinker.t

val t_of_sexp : Sexplib0__.Sexp.t -> t

val sexp_of_t : t -> Sexplib0__.Sexp.t

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

include Bin_prot.Binable.S_only_functions 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

This function only needs implementation if t exposed to be a polymorphic variant. Despite what the type reads, this does *not* produce a function after reading; instead it takes the constructor tag (int) before reading and reads the rest of the variant t afterwards.

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