mod process

module process

process command: create marker depth table from demultiplexed reads.

Single-phase concurrent merge: rayon threads insert directly into a DashMap during file processing. No sequential merge bottleneck. Sequences stored as 2-bit packed DNA (4x memory reduction).

Functions

fn run(params: &ProcessParams) -> Result<(), Box<dyn std::error::Error>>

Run the process command.

Structs and Unions

struct ProcessParams

Parameters for the process command.

input_dir_path: String
output_file_path: String
n_threads: u32
min_depth: u16
kmer_dedup: Option<usize>

If set, group markers by min-hash of canonical k-mers of this size. Heuristic (not exact) collapse of sequencing error variants. Optional (default: disabled). See kmer.rs docs for limitations.