Struct FlushGuard 

pub struct FlushGuard { /* private fields */ }

Guard that flushes its observer on drop — the telemetry analogue of AgentTurnGuard. Held for the lifetime of a short-lived agent invocation (today: the CLI one-shot, zeroclaw agent -m ...), whose process exits before the OTLP batch exporter / metric PeriodicReader’s background interval fires. Without this flush all buffered telemetry — including the never-ended gen_ai.agent.invoke span, which is only .end()’d inside Observer::flush — is lost when the runtime is torn down.

Long-lived callers (daemon heartbeat/cron, channel process_message, subagent spawns) pass interactive = false and skip this guard: they rely on the periodic export firing on its own cadence, and a flush per turn would add a synchronous OTLP HTTP POST to every invocation.

Backend-agnostic: calls Observer::flush(), which is a no-op for synchronous backends (Log/Verbose/Noop) and meaningless-but- harmless for pull backends (Prometheus — see startup warning).

Implementations

impl FlushGuard

pub fn new(observer: Arc<dyn Observer>) -> Self

Construct a guard that will flush observer when dropped.

pub fn fire(&mut self)

Flush immediately and mark the guard spent so a later Drop is a no-op.

Trait Implementations

impl Drop for FlushGuard

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.