Skip to main content

DnsQueryEmitter

cellos_supervisor::dns_proxy

Trait DnsQueryEmitter 

Source 
pub trait DnsQueryEmitter: Send + Sync {
    // Required method
    fn emit(&self, event: CloudEventV1);
}
Expand description

Sink the proxy uses to publish per-query events. Trait-erased so unit tests can plug in an in-memory collector and the supervisor can adapt the production EventSink to a synchronous-fire-and-forget shape.

Required Methods§

Source

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.

Implementors§