Struct RetentionGarbageCollector 

pub struct RetentionGarbageCollector<I: IndexBackend> {
    index: Arc<I>,
    config: RetentionConfig,
}

Garbage collector for expired memories based on retention policy.

Identifies memories that have exceeded their retention period and marks them as tombstoned. Supports per-namespace retention policies.

Thread Safety

The garbage collector holds an Arc reference to the index backend, making it safe to share across threads.

Fields

index: Arc<I>

Reference to the index backend for querying and updating memories.

config: RetentionConfig

Retention policy configuration.

Implementations

impl<I: IndexBackend> RetentionGarbageCollector<I>

pub fn new(index: Arc<I>, config: RetentionConfig) -> Self

Creates a new retention garbage collector.

Arguments

• index - Shared reference to the index backend.
• config - Retention policy configuration.

pub fn gc_expired_memories(&self, dry_run: bool) -> Result<RetentionGcResult>

Performs garbage collection on expired memories.

This method:

1. Iterates through all namespaces
2. For each namespace, calculates the retention cutoff
3. Queries for memories older than the cutoff
4. Tombstones expired memories (unless dry_run)

Arguments

• dry_run - If true, only report what would be done without making changes

Returns

A RetentionGcResult containing statistics about the operation.

Errors

Returns an error if index backend operations fail.

fn process_namespace( &self, namespace: Namespace, cutoff: u64, now: u64, dry_run: bool, result: &mut RetentionGcResult, ) -> Result<usize>

Processes a single namespace for expired memories.

pub const fn config(&self) -> &RetentionConfig

Returns the current retention configuration.