Struct ExecutionEventEmitter 

pub struct ExecutionEventEmitter<'sink, S = dyn ExecutionEventSink>
where
    S: ExecutionEventSink + ?Sized,
{ /* private fields */ }

Implementations

impl<'sink, S> ExecutionEventEmitter<'sink, S>

where S: ExecutionEventSink + ?Sized,

pub fn new(sink: &'sink S, run_id: RunId, request_id: RequestIdentity) -> Self

impl ExecutionEventEmitter<'static, dyn ExecutionEventSink>

pub fn from_shared( sink: Arc<dyn ExecutionEventSink>, run_id: RunId, request_id: RequestIdentity, ) -> ExecutionEventEmitter<'static>

Creates a durable emitter that may be owned by a request/session.

The borrowed constructor remains useful for bounded validation. Product runtimes use this form so event authority cannot outlive its sink.

pub fn from_shared_with_capture_policy( sink: Arc<dyn ExecutionEventSink>, run_id: RunId, request_id: RequestIdentity, capture_policy: ExecutionEventCapturePolicy, ) -> ExecutionEventEmitter<'static>

impl<'sink, S> ExecutionEventEmitter<'sink, S>

where S: ExecutionEventSink + ?Sized,

pub fn emit( &mut self, event: ExecutionEvent, context: &TrustedExecutionEventContext<'_>, ) -> Result<(), ExecutionEventSinkError>

pub fn emit_batch( &mut self, events: Vec<ExecutionEvent>, contexts: &[TrustedExecutionEventContext<'_>], ) -> Result<(), ExecutionEventSinkError>

pub fn cursor(&self) -> &ExecutionEventCursor

pub const fn sink_failed(&self) -> bool