Struct CompositeReporter 

pub struct CompositeReporter { /* private fields */ }

Fan-out reporter that forwards every AgentEvent to multiple child observers.

CompositeReporter itself implements LoopObserver, so it can be handed directly to the agent loop. Each event is cloned once per child observer.

Example

use agentkit_reporting::{
    CompositeReporter, JsonlReporter, StdoutReporter, UsageReporter,
};

// Build a reporter that writes to JSONL, prints to stdout, and tracks usage.
let reporter = CompositeReporter::new()
    .with_observer(JsonlReporter::new(Vec::new()))
    .with_observer(StdoutReporter::new(std::io::stdout()))
    .with_observer(UsageReporter::new());

Implementations

impl CompositeReporter

pub fn new() -> Self

Creates an empty CompositeReporter with no child observers.

pub fn with_observer(self, observer: impl LoopObserver + 'static) -> Self

Adds an observer and returns self (builder pattern).

Arguments

• observer - Any type implementing LoopObserver.

pub fn push(&mut self, observer: impl LoopObserver + 'static) -> &mut Self

Adds an observer by mutable reference.

Use this when you need to add observers after initial construction rather than in a builder chain.

Arguments

• observer - Any type implementing LoopObserver.

Trait Implementations

impl Default for CompositeReporter

fn default() -> CompositeReporter

Returns the “default value” for a type.

impl LoopObserver for CompositeReporter

fn handle_event(&self, event: AgentEvent)

Called synchronously for every AgentEvent emitted by the loop driver. Observers store mutable state behind interior mutability (Mutex, atomics, channels) so the driver can share an Arc<dyn LoopObserver> across reusable Agent starts.