Skip to main content

CompositeReporter

Struct CompositeReporter 

Source
pub struct CompositeReporter { /* private fields */ }
Expand description

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§

Source§

impl CompositeReporter

Source

pub fn new() -> Self

Creates an empty CompositeReporter with no child observers.

Source

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

Adds an observer and returns self (builder pattern).

§Arguments
Source

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

Trait Implementations§

Source§

impl Default for CompositeReporter

Source§

fn default() -> CompositeReporter

Returns the “default value” for a type. Read more
Source§

impl LoopObserver for CompositeReporter

Source§

fn handle_event(&mut self, event: AgentEvent)

Called synchronously for every AgentEvent emitted by the loop driver.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.