Struct StandardObserverBuilder 

pub struct StandardObserverBuilder { /* private fields */ }

Builder for StandardObserver.

Implementations

impl StandardObserverBuilder

pub fn service( self, name: impl Into<String>, version: impl Into<String>, ) -> Self

Set service identity.

pub fn instance(self, instance: impl Into<String>) -> Self

Set instance id.

pub fn sink_for(self, tier: Tier, sink: Arc<dyn Sink>) -> Self

Wire a sink for a specific tier. Calling twice replaces the prior sink.

pub fn sink_fallback(self, sink: Arc<dyn Sink>) -> Self

Wire a fallback sink.

pub fn config(self, cfg: EventsConfig) -> Self

Set an explicit config.

pub fn filter(self, spec: impl Into<String>) -> Self

Set the filter spec (overrides anything in config.filter).

pub fn registry(self, registry: Arc<SchemaRegistry>) -> Self

Use a specific schema registry.

pub fn spawn_workers(self, yes: bool) -> Self

Spawn per-tier mpsc workers when a tokio runtime is available (default true). Disable for synchronous tests that want in-emit-thread delivery.

pub fn build(self) -> Result<StandardObserver, BuildError>

Finalise.

Errors

Returns BuildError when config validation or filter parsing fails.

Trait Implementations

impl Debug for StandardObserverBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StandardObserverBuilder

fn default() -> Self

Returns the “default value” for a type.