Struct EpisodeRetentionPolicy 

pub struct EpisodeRetentionPolicy {
    pub max_age_days: i64,
    pub min_reward_threshold: f64,
    pub max_episodes: usize,
    pub cleanup_interval_secs: u64,
    pub cleanup_batch_size: usize,
    pub criterion: RetentionCriterion,
    pub keep_pattern_sources: bool,
    pub keep_heuristic_sources: bool,
    pub dry_run: bool,
}

Policy for episode retention and garbage collection

Fields

max_age_days: i64

Maximum age in days before episode is eligible for cleanup

min_reward_threshold: f64

Minimum reward score to keep (episodes below this are candidates)

max_episodes: usize

Maximum number of episodes to retain

cleanup_interval_secs: u64

Cleanup interval in seconds

cleanup_batch_size: usize

Batch size for cleanup operations (prevents long-running deletes)

criterion: RetentionCriterion

Which criterion to use for cleanup decisions

keep_pattern_sources: bool

Keep episodes that have derived patterns

keep_heuristic_sources: bool

Keep episodes that have derived heuristics

dry_run: bool

Keep successful episodes (reward >= 0.7) keep_high_reward: bool, // Removed as unused Dry run mode (report what would be deleted without actually deleting)

Implementations

impl EpisodeRetentionPolicy

pub fn new() -> Self

Create a new retention policy with defaults

pub fn storage_limited() -> Self

Create a policy optimized for limited storage

pub fn archival() -> Self

Create a policy for archival mode (keep everything)

pub fn aggressive() -> Self

Create a policy for aggressive cleanup

pub fn with_max_age_days(self, days: i64) -> Self

Builder: set maximum age in days

pub fn with_min_reward_threshold(self, threshold: f64) -> Self

Builder: set minimum reward threshold

pub fn with_max_episodes(self, max: usize) -> Self

Builder: set maximum episodes

pub fn with_cleanup_interval(self, interval: StdDuration) -> Self

Builder: set cleanup interval

pub fn with_cleanup_batch_size(self, size: usize) -> Self

Builder: set cleanup batch size

pub fn with_criterion(self, criterion: RetentionCriterion) -> Self

Builder: set retention criterion

pub fn with_dry_run(self, dry_run: bool) -> Self

Builder: enable dry run mode

pub fn validate(&self) -> Result<(), RetentionPolicyError>

Validate policy configuration

pub fn should_retain(&self, episode: &Episode, now: DateTime<Utc>) -> bool

Check if an episode should be retained based on policy

Arguments

• episode - Episode to evaluate
• now - Current timestamp

Returns

true if episode should be kept, false if eligible for cleanup

pub fn cleanup_interval(&self) -> StdDuration

Get cleanup interval as Duration

Trait Implementations

impl Clone for EpisodeRetentionPolicy

fn clone(&self) -> EpisodeRetentionPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EpisodeRetentionPolicy

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

Formats the value using the given formatter.

impl Default for EpisodeRetentionPolicy

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EpisodeRetentionPolicy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EpisodeRetentionPolicy

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

where __S: Serializer,

Serialize this value into the given Serde serializer.