Struct FileObservationSink 

pub struct FileObservationSink { /* private fields */ }

Cloneable non-blocking observation sink backed by a bounded worker queue.

Implementations

impl FileObservationSink

pub fn new(config: FileObservationSinkConfig) -> Result<Self>

Creates the active file and starts the bounded writer worker.

pub fn flush(&self) -> Result<()>

Flushes all events accepted before this call.

pub fn flush_timeout(&self, timeout: Duration) -> Result<()>

Flushes accepted events within one deadline covering queue admission and worker acknowledgement.

pub fn stats(&self) -> FileObservationSinkStats

Returns worker, backpressure and failure counters.

pub fn pressure(&self) -> FileObservationSinkPressure

Returns aggregate byte pressure for queued and currently written events.

Trait Implementations

impl Clone for FileObservationSink

fn clone(&self) -> FileObservationSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FileObservationSink

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

Formats the value using the given formatter.

impl ObservationSink for FileObservationSink

fn emit(&self, event: ObservationEvent)

Emits one event without blocking on external tooling.

fn emit_shared(&self, event: &SharedObservationEvent)

Emits an already validated shared event.