Struct ScopedEmitter 

pub struct ScopedEmitter { /* private fields */ }

Run-scoped event emitter. Subsystems (tools, memory, middleware) receive one of these so they don’t need to know about run_id or the monotonic seq counter — they just call .emit(span_id, kind).

The plan’s context types show events: Arc<dyn EventSink> alone; in practice the envelope needs a seq and run_id that the loop owns. This wrapper closes that gap without changing the EventSink trait.

Implementations

impl ScopedEmitter

pub fn new(sink: Arc<dyn EventSink>, run_id: RunId, seq: Arc<AtomicU64>) -> Self

pub fn sink(&self) -> &Arc<dyn EventSink>

pub fn run_id(&self) -> RunId

pub fn next_seq(&self) -> u64

pub fn emit( &self, span_id: impl Into<SpanId>, kind: EventKind, parent: Option<u64>, ) -> u64

Build and emit a stamped event (blocks on backpressure per EventSink::emit). Returns the event’s seq so spans can be linked.

pub fn try_emit( &self, span_id: impl Into<SpanId>, kind: EventKind, parent: Option<u64>, ) -> Result<u64, u64>

Non-blocking emit. On backpressure, the event is dropped and Err(seq) is returned so the caller can log or retry.

Trait Implementations

impl Clone for ScopedEmitter

fn clone(&self) -> ScopedEmitter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.