Enum RetentionPolicy 

#[non_exhaustive]
pub enum RetentionPolicy {
    MirrorLog,
    Keep,
    KeepUntilSourceDeleted,
    TimeToLive {
        ttl_micros: u64,
    },
    MaxRows {
        rows: u64,
    },
    Unknown,
}

How long a binding’s materialized rows live, decoupled from the source topic’s Iggy message_expiry. Lets a projection outlive (or undershoot) the log it was built from.

The canonical case: a topic with aggressive expiry (short-lived partitions for cheap storage and fast replay) whose derived index must survive forever. Set the binding to RetentionPolicy::Keep.

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.

MirrorLog

Follow the log: rows are pruned once Iggy drops the messages that produced them. The default, and the only policy that also deletes the projection when the source topic is deleted.

Keep

Keep rows forever, regardless of the source log or its deletion.

KeepUntilSourceDeleted

Keep rows forever while the source topic exists, but drop the whole projection when the source topic is deleted. Ignores message expiry like Keep, but is tied to the topic’s existence like MirrorLog.

TimeToLive

Keep rows for ttl_micros after they were materialized, independent of the log. Older rows are swept, and survivors outlive an expired source.

Fields

ttl_micros: u64

MaxRows

Keep the newest rows rows for the target table, independent of the log.

Fields

rows: u64

Unknown

A policy kind a newer server named that this build does not know. The decode degrades to this rather than failing the whole reply, so an older client keeps reading bindings it cannot fully interpret (it must not re-apply one: re-serializing loses the original kind and its fields). The same forward-compat shape the ResultCode and u8 dictionaries use.

Trait Implementations

impl Clone for RetentionPolicy

fn clone(&self) -> RetentionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RetentionPolicy

impl Debug for RetentionPolicy

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

Formats the value using the given formatter.

impl Default for RetentionPolicy

fn default() -> RetentionPolicy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RetentionPolicy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RetentionPolicy

impl PartialEq for RetentionPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RetentionPolicy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RetentionPolicy