Struct CompactorMutator 

pub struct CompactorMutator<C> { /* private fields */ }

Adapts any Compactor to a LoopMutator so it can be registered directly via AgentBuilder::mutator. Most callers reach this through AgentBuilderCompactorExt::compactor rather than constructing it directly.

CompactorMutator owns the telemetry contract: it emits AgentEvent::MutationStarted before calling Compactor::compact and AgentEvent::MutationFinished after, populating metadata with the compaction reason and replaced item count.

Implementations

impl<C: Compactor> CompactorMutator<C>

pub fn new(compactor: C) -> Self

Wrap compactor with the default mutator label "compactor".

pub fn with_name(self, name: impl Into<String>) -> Self

Override the mutator label that appears in AgentEvent::MutationStarted/AgentEvent::MutationFinished.

Trait Implementations

impl<C: Compactor + 'static> LoopMutator for CompactorMutator<C>

fn mutate<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, cursor: &'life1 mut TranscriptCursor<'life2>, ctx: LoopCtx<'life3>, ) -> Pin<Box<dyn Future<Output = Result<(), LoopError>> + Send + 'async_trait>>

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

Run this mutator. Returning without writing to cursor is a no-op. Errors abort the loop; protocol-violating mutations (orphaned tool uses or results) are detected by validation and turned into LoopError::Mutator.