Struct VersioningTransformer 

pub struct VersioningTransformer { /* private fields */ }

A context transformer that captures dropped messages as versioned snapshots.

Wraps an inner ContextTransformer (typically a sliding window) and stores evicted messages via a ContextVersionStore. An optional ContextSummarizer produces summaries for each version.

Example

use swink_agent::{
    SlidingWindowTransformer, VersioningTransformer,
    InMemoryVersionStore,
};
use std::sync::Arc;

let store = Arc::new(InMemoryVersionStore::new());
let inner = SlidingWindowTransformer::new(100_000, 50_000, 2);
let transformer = VersioningTransformer::new(inner, store);

let agent = AgentOptions::new(/* ... */)
    .with_transform_context(transformer);

Implementations

impl VersioningTransformer

pub fn new( inner: impl ContextTransformer + 'static, store: Arc<dyn ContextVersionStore>, ) -> Self

Create a new versioning transformer wrapping an inner transformer.

pub fn with_summarizer(self, summarizer: Arc<dyn ContextSummarizer>) -> Self

Attach a summarizer that produces summaries for each version.

pub fn store(&self) -> &Arc<dyn ContextVersionStore>

Access the underlying version store.

Trait Implementations

impl ContextTransformer for VersioningTransformer

fn transform( &self, messages: &mut Vec<AgentMessage>, overflow: bool, ) -> Option<CompactionReport>

Transform the context messages in-place.