Struct CompactionProvider 

pub struct CompactionProvider { /* private fields */ }

A ContextProvider that compacts the accumulated message list — typically the run’s history, once a HistoryProvider has prepended it in before_run — down to fit a CompactionStrategy’s constraint before it reaches the model. Rust equivalent of (a subset of) upstream’s CompactionProvider (see module docs and UPSTREAM_DRIFT.md §9).

Register it via AgentBuilder::with_compaction, which attaches it as one of the agent’s own context providers — those run after the session’s (which is where a history provider, auto-attached or explicit, lives — see Agent::combined_providers), so compaction always sees the full, history-prepended message list for the run.

Implementations

impl CompactionProvider

pub fn new(strategy: impl CompactionStrategy + 'static) -> Self

A compaction provider using strategy with the default ApproxTokenizer.

pub fn with_tokenizer( strategy: impl CompactionStrategy + 'static, tokenizer: impl Tokenizer + 'static, ) -> Self

A compaction provider using strategy and an explicit tokenizer.

Trait Implementations

impl ContextProvider for CompactionProvider

fn before_run<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut SessionContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Replace ctx.messages (the accumulated history + any earlier provider-injected messages) with the strategy’s compacted subset.

fn after_run<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _request_messages: &'life1 [Message], _response_messages: &'life2 [Message], _error: Option<&'life3 Error>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Called after an invocation completes, on BOTH success and failure. On success, error is None and response_messages holds the output. On failure, error is Some and response_messages is empty.

fn is_history_provider(&self) -> bool

Whether this provider manages conversation history (a HistoryProvider). Agent and WorkflowAgent use this to detect an already-attached history provider among a session’s context_providers and avoid auto-attaching a redundant InMemoryHistoryProvider. Defaults to false; history providers override it to true.