Struct PersistConfig 

pub struct PersistConfig {
    pub queue_max: usize,
    pub batch_max: usize,
    pub batch_wait: Duration,
    pub batch_enabled: bool,
    pub overflow: PersistOverflow,
}

Queue and batch settings for crate::StoragePersistSink.

Set via crate::SpectraBuilder::persist. Defaults match the previous in-process behavior (batching on, overflow drop). Callers raise batch_max for high-throughput DW ingest.

Fields

queue_max: usize

Max queued persist jobs before overflow policy applies. Default 8192.

batch_max: usize

Max jobs collected into one batch flush. Default 32.

batch_wait: Duration

Extra wait when the first collected job is alone, to coalesce. Default 5ms.

batch_enabled: bool

When true, use record_metrics_batch / append_rows_batch. Default true.

overflow: PersistOverflow

Overflow policy when queue_max is reached. Default PersistOverflow::Drop.

Trait Implementations

impl Clone for PersistConfig

fn clone(&self) -> PersistConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PersistConfig

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

Formats the value using the given formatter.

impl Default for PersistConfig

fn default() -> PersistConfig

Returns the “default value” for a type.