Struct StreamingQueueConfig 

pub struct StreamingQueueConfig {
    pub k: usize,
    pub segment_size: usize,
    pub min_match_len: usize,
    pub compression_level: i32,
    pub num_threads: usize,
    pub queue_capacity: usize,
    pub verbosity: usize,
    pub adaptive_mode: bool,
    pub fallback_frac: f64,
    pub batch_size: usize,
    pub pack_size: usize,
    pub concatenated_genomes: bool,
}

Configuration for the streaming queue-based compressor

Fields

k: usize

K-mer length for splitters

segment_size: usize

Segment size for splitting contigs

min_match_len: usize

Minimum match length for LZ encoding

compression_level: i32

ZSTD compression level (1-22)

num_threads: usize

Number of worker threads

queue_capacity: usize

Queue capacity in bytes (default: 2 GB, like C++ AGC)

verbosity: usize

Verbosity level

adaptive_mode: bool

Adaptive mode: find new splitters for samples that can’t be segmented well (matches C++ AGC -a flag)

fallback_frac: f64

Fallback fraction: fraction of minimizers to use for fallback grouping (matches C++ AGC –fallback-frac parameter, default 0.0)

batch_size: usize

Batch size: number of samples to accumulate before sorting and distributing (matches C++ AGC pack_cardinality parameter, default 50) Segments from batch_size samples are sorted by (sample, contig, seg_part_no) before distribution to groups, ensuring consistent pack boundaries with C++ AGC.

pack_size: usize

Pack size: number of segments per pack (matches C++ AGC contigs_in_pack) When a group reaches this many segments, write a pack immediately (default: 50, matching PACK_CARDINALITY)

concatenated_genomes: bool

Concatenated genomes mode: if true, send sync tokens every pack_size contigs If false (multiple input files), only send sync tokens at sample boundaries Matches C++ AGC’s concatenated_genomes behavior

Trait Implementations

impl Clone for StreamingQueueConfig

fn clone(&self) -> StreamingQueueConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamingQueueConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamingQueueConfig

fn default() -> Self

Returns the “default value” for a type.