Struct PolicyReporter 

pub struct PolicyReporter<T> { /* private fields */ }

Adapter that wraps a FallibleObserver and applies a FailurePolicy.

This turns any fallible reporter into a LoopObserver suitable for passing to the agent loop.

Example

use agentkit_reporting::{ChannelReporter, FailurePolicy, PolicyReporter};

let (reporter, rx) = ChannelReporter::pair();
let reporter = PolicyReporter::new(reporter, FailurePolicy::Log);
// `reporter` now implements `LoopObserver` and logs send failures to stderr.

Implementations

impl<T: FallibleObserver> PolicyReporter<T>

pub fn new(inner: T, policy: FailurePolicy) -> Self

Creates a new PolicyReporter wrapping the given observer with the specified failure policy.

pub fn inner(&self) -> &T

Returns a reference to the inner observer.

pub fn inner_mut(&mut self) -> &mut T

Returns a mutable reference to the inner observer.

pub fn policy(&self) -> FailurePolicy

Returns the configured failure policy.

pub fn take_errors(&mut self) -> Vec<ReportError>

Drains and returns all accumulated errors.

Only meaningful when the policy is FailurePolicy::Accumulate. Subsequent calls return an empty Vec until new errors occur.

Trait Implementations

impl<T: FallibleObserver> LoopObserver for PolicyReporter<T>

fn handle_event(&mut self, event: AgentEvent)

Called synchronously for every AgentEvent emitted by the loop driver.