Enum CapacityPolicy 

pub enum CapacityPolicy {
    RejectIncoming,
    OverwriteOldest,
}

Policy for handling new appends when the WAL is at capacity.

RejectIncoming propagates backpressure. For a transient source (e.g., HTTP webhook), this typically means returning 503 to the external producer, which should retry. This preserves data safety but will cause the source to appear “stuck” if the producer stops retrying or the consumer is permanently stalled.

OverwriteOldest favors availability — keeps accepting new events by evicting the oldest. Slow consumers may see gaps and trigger their recovery policy. Choose this when availability matters more than no-loss replay.

Sources should choose based on their backpressure contract with upstream producers.

Variants

RejectIncoming

Reject the incoming event with WalError::CapacityExhausted.

OverwriteOldest

Evict the oldest event(s) to make room for the new one.

Trait Implementations

impl Clone for CapacityPolicy

fn clone(&self) -> CapacityPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CapacityPolicy

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

Formats the value using the given formatter.

impl PartialEq for CapacityPolicy

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for CapacityPolicy

impl Eq for CapacityPolicy

impl StructuralPartialEq for CapacityPolicy