Struct SummarizingCompactor 

pub struct SummarizingCompactor { /* private fields */ }

Summarization-aware context compactor.

Combines the core sliding_window strategy with an optional summary that replaces dropped messages. The summary is stored externally via set_summary and injected after the anchor messages during the next compaction pass.

Usage

let compactor = SummarizingCompactor::new(100_000, 50_000, 2);
let agent = Agent::new()
    .with_transform_context(compactor.compaction_fn());

// After each turn, if messages were dropped:
compactor.set_summary("Summary of earlier conversation...");

Implementations

impl SummarizingCompactor

pub fn new(normal_budget: usize, overflow_budget: usize, anchor: usize) -> Self

Create a new compactor with the given budget parameters.

pub fn compaction_fn( &self, ) -> impl Fn(&mut Vec<AgentMessage>, bool) + Send + Sync

Returns a closure compatible with Agent::with_transform_context().

Behaves like sliding_window but injects a stored summary after the anchor messages when compaction occurs. If no summary is stored, behaves identically to sliding_window.

The summary is consumed after injection — it will not be re-injected on subsequent compaction passes.

pub fn set_summary(&self, text: impl Into<String>)

Store a summary to be injected on the next compaction pass.

This should be called after each turn where context was compacted, passing a summary of the messages that were dropped. In the future this will be generated via an LLM call; for now callers provide the text directly.

pub fn clear_summary(&self)

Clear the stored summary.

pub fn has_summary(&self) -> bool

Returns true if a summary is currently stored.