Struct RetentionPolicy 

pub struct RetentionPolicy {
    pub terminal_max_age: Duration,
    pub batch_size: u32,
    pub max_batches: Option<u32>,
}

How long terminal tasks are kept, and how aggressively they are removed.

Fields

terminal_max_age: Duration

Terminal tasks whose last update is older than this are eligible.

Measured against updated_at, which the store maintains, and evaluated by the database rather than the caller — an application clock that runs fast would otherwise delete work that is younger than it looks.

batch_size: u32

Rows per DELETE. Default 1,000.

The point of batching is the lock, not the throughput. One statement deleting a million rows holds locks and grows a transaction for as long as it takes; a thousand statements deleting a thousand rows each let every other query through in between.

max_batches: Option<u32>

Stop after this many batches, leaving the rest for the next call. None runs until nothing is left.

Set it to bound how long one sweep can run when the first sweep after switching retention on has years of backlog to work through.

Implementations

impl RetentionPolicy

pub const fn new(terminal_max_age: Duration) -> Self

A policy keeping terminal tasks for terminal_max_age, with default batching.

pub const fn with_batch_size(self, batch_size: u32) -> Self

Sets the rows-per-DELETE batch size. Zero is treated as one.

pub const fn with_max_batches(self, max_batches: u32) -> Self

Bounds how many batches a single sweep runs.

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 Debug for RetentionPolicy

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

Formats the value using the given formatter.