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 DnsQueryEmitter trait to the supervisor’s async cellos_core::ports::EventSink pipeline.

Tokio-context constraint: runtime_handle MUST be captured on a thread that already has a tokio runtime context (i.e. inside an async block on the multi-thread runtime, OR inside spawn_blocking). The proxy thread itself is a bare std::thread and has no tokio context; the captured handle is what lets it spawn work back onto the runtime.

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.

Call from inside an async block (or spawn_blocking) — never from a bare std thread. Panics with a clear message if no tokio runtime is reachable, which is a programming error: this struct exists specifically to bridge from sync threads, but the bridge itself must be constructed where a runtime is available.

Trait Implementations

impl DnsQueryEmitter for EventSinkEmitter

fn emit(&self, event: CloudEventV1)

Publish a single CloudEvent. Implementations should not block — the proxy’s recv loop runs synchronously and any blocking emit will directly increase per-query latency for the workload.