Struct StreamRetention 

pub struct StreamRetention {
    pub max_events: Option<usize>,
    pub max_age_ms: Option<u64>,
}

Retention contract for a single stream. Both fields are independently optional; pass StreamRetention::default() for an unbounded stream (no retention pruning).

Fields

max_events: Option<usize>

Maximum number of events retained. Oldest events past the cap are dropped on append. None means unbounded.

max_age_ms: Option<u64>

Maximum age in milliseconds. Events older than now - max_age_ms are dropped on append. None means unbounded.

Trait Implementations

impl Clone for StreamRetention

fn clone(&self) -> StreamRetention

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamRetention

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

Formats the value using the given formatter.

impl Default for StreamRetention

fn default() -> StreamRetention

Returns the “default value” for a type.

impl PartialEq for StreamRetention

fn eq(&self, other: &StreamRetention) -> 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 Eq for StreamRetention

impl StructuralPartialEq for StreamRetention