Enum FlushPolicy 

#[non_exhaustive]
pub enum FlushPolicy {
    Batch(usize),
    Interval(Duration),
    BatchOrInterval {
        batch_size: usize,
        interval: Duration,
    },
    Manual,
}

When to auto-flush pending items from memory to a segment file.

Passed to SegmentConfig via its flush_policy field. Replaces the pre-v0.4.0 silent combination of two separate fields (max_batch_events and flush_interval_secs) that OR’d together without telling the caller which trigger fired.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Batch(usize)

Flush as soon as batch_size items are buffered. No interval trigger.

Interval(Duration)

Flush as soon as interval has elapsed since the last flush. No batch trigger.

BatchOrInterval

Flush when EITHER batch_size items are buffered OR interval has elapsed since the last flush — whichever fires first. This is the pre-v0.4.0 default behavior.

Fields

batch_size: usize

In-memory item count threshold.

interval: Duration

Max time between flushes.

Manual

Never auto-flush. The caller must call SegmentBuffer::flush explicitly to make appends durable. Useful for tests and for callers that want absolute control over write amplification.

Trait Implementations

impl Clone for FlushPolicy

fn clone(&self) -> FlushPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlushPolicy

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

Formats the value using the given formatter.

impl Default for FlushPolicy

fn default() -> Self

Returns the “default value” for a type.

impl Eq for FlushPolicy

impl PartialEq for FlushPolicy

fn eq(&self, other: &FlushPolicy) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for FlushPolicy