Struct EventSinkEmitter 

pub struct EventSinkEmitter {
    pub runtime_handle: Handle,
    pub sink: Arc<dyn EventSink>,
    pub jsonl_sink: Option<Arc<dyn EventSink>>,
}

Adapter from the proxy’s synchronous L7DecisionEmitter trait to the supervisor’s async cellos_core::ports::EventSink pipeline. Mirrors crate::dns_proxy::spawn::EventSinkEmitter one-for-one.

Fields

runtime_handle: Handle

sink: Arc<dyn EventSink>

jsonl_sink: Option<Arc<dyn EventSink>>

Implementations

impl EventSinkEmitter

pub fn capture_current( sink: Arc<dyn EventSink>, jsonl_sink: Option<Arc<dyn EventSink>>, ) -> Self

Build an emitter capturing the current tokio runtime handle. MUST be called from inside an async context (the supervisor satisfies this by constructing the emitter from inside run()).

Trait Implementations

impl L7DecisionEmitter for EventSinkEmitter

fn emit(&self, event: CloudEventV1)

Publish a single CloudEvent. Implementations should not block.