Struct RetentionPolicy 

pub struct RetentionPolicy {
    pub max_per_thread: Option<usize>,
    pub max_age: Option<Duration>,
}

Available on crate feature graph only.

How many checkpoints to keep for a thread, and for how long.

A long-running thread accumulates one checkpoint per super-step. Without a policy that grows without bound, which costs storage and slows a list.

The newest checkpoint is never removed, whatever the policy says: it is the one a resume loads, so discarding it would end the thread.

Example

use adk_graph::checkpoint::RetentionPolicy;
use std::time::Duration;

// Keep the last 50 steps, and nothing older than a week.
let policy = RetentionPolicy::keep_last(50).with_max_age(Duration::from_secs(7 * 24 * 3600));

Fields

max_per_thread: Option<usize>

Keep at most this many checkpoints per thread, newest first.

max_age: Option<Duration>

Remove checkpoints older than this.

Implementations

impl RetentionPolicy

pub fn keep_last(count: usize) -> RetentionPolicy

Keeps the newest count checkpoints for a thread.

A count of zero is raised to one, because the newest is always kept.

pub fn max_age(age: Duration) -> RetentionPolicy

Removes checkpoints older than age.

pub fn with_max_age(self, age: Duration) -> RetentionPolicy

Adds an age limit to a count limit.

pub fn with_max_per_thread(self, count: usize) -> RetentionPolicy

Adds a count limit to an age limit.

pub fn is_unlimited(&self) -> bool

Whether this policy would remove anything.

pub fn expired(&self, checkpoints: &[Checkpoint]) -> Vec<String>

Selects the checkpoint ids this policy discards, newest always kept.

Shared by every backend so they cannot disagree about what to keep.

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<(), Error>

Formats the value using the given formatter.

impl Default for RetentionPolicy

fn default() -> RetentionPolicy

Returns the “default value” for a type.

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