Struct IntraInvocationCompactor 

pub struct IntraInvocationCompactor { /* private fields */ }

Intra-invocation compactor that monitors token usage during a single invocation and triggers summarization when the context exceeds a threshold.

The compactor enforces at-most-once compaction per LLM call cycle via an AtomicBool guard. Call reset_cycle at the start of each LLM call to re-arm the guard.

Example

use adk_runner::IntraInvocationCompactor;
use adk_core::IntraCompactionConfig;

let compactor = IntraInvocationCompactor::new(
    IntraCompactionConfig::default(),
    summarizer,
);

// Before each LLM call:
compactor.reset_cycle();
if let Some(compacted) = compactor.maybe_compact(&events).await? {
    events = compacted;
}

Implementations

impl IntraInvocationCompactor

pub fn new( config: IntraCompactionConfig, summarizer: Arc<dyn BaseEventsSummarizer>, ) -> Self

Create a new compactor with the given config and summarizer.

pub async fn maybe_compact( &self, events: &[Event], ) -> Result<Option<Vec<Event>>>

Check if compaction is needed and perform it if so.

Returns Some(compacted_events) if compaction was triggered, or None if no compaction was needed (below threshold or already compacted this cycle).

On summarizer error, logs a warning and returns None (uncompacted history is used).

pub fn reset_cycle(&self)

Reset the per-cycle guard. Call this at the start of each LLM call.