package obatcher

  1. Overview
  2. Docs
type t = Sequential.t
type cfg = {
  1. size : int;
}
type 'a op =
  1. | Insert : V.t -> unit op
  2. | Member : V.t -> bool op
  3. | Size : int op
type wrapped_op =
  1. | Mk : 'a op * 'a Picos.Computation.t -> wrapped_op
val init : ?cfg:cfg -> unit -> Sequential.t
type intermediate = {
  1. batch_size : int;
  2. maxinsertlevel : int Stdlib.ref;
  3. level_arr : int array;
  4. new_node_arr : Sequential.node array;
  5. new_node_back_arr : Sequential.node array;
  6. prev_node_idx : int array;
}
val build_node : Sequential.t -> int -> V.t -> intermediate -> unit
val relate_nodes : Sequential.t -> int -> intermediate -> unit
val merge_list : Sequential.t -> int -> intermediate -> unit
val remove_duplicates : 'a array -> int -> int
val par_insert : Sequential.t -> V.t array -> unit
val par_size : Sequential.t -> int array -> int array
val run : Sequential.t -> wrapped_op array -> unit
OCaml

Innovation. Community. Security.