Struct CleanupPolicy 

pub struct CleanupPolicy {
    pub scope: BTreeMap<String, Value>,
    pub key: Vec<String>,
    pub max_keys: usize,
}

A compiled cleanup instruction for one invocation.

Fields

scope: BTreeMap<String, Value>

The completeness claim, in destination column terms: the rows this invocation is authoritative for. Every entry is an equality predicate, AND-ed together.

Destination terms rather than source terms because the DELETE executes against destination columns, and a transform chain may rename fields between the two.

key: Vec<String>

Key columns identifying a row — mirrors the sink’s key.

max_keys: usize

Ceiling on accumulated keys before the cleanup refuses (see module docs).

Implementations

impl CleanupPolicy

pub fn new( scope: BTreeMap<String, Value>, key: Vec<String>, max_keys: usize, ) -> Result<Self, FaucetError>

Build a policy, validating it is actionable.

Trait Implementations

impl Clone for CleanupPolicy

fn clone(&self) -> CleanupPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CleanupPolicy

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

Formats the value using the given formatter.