Struct BufferedCollector 

pub struct BufferedCollector { /* private fields */ }

Thread-safe log collector with a bounded ring buffer.

Implementations

impl BufferedCollector

pub fn new(capacity: usize) -> Self

Create a new collector with the given capacity.

pub fn with_default_capacity() -> Self

Create a collector with default capacity.

pub fn with_filter(self, filter: LogFilter) -> Self

Set a filter for incoming events.

pub fn subscribe(&self, callback: Arc<dyn Fn(&LogEvent) + Send + Sync>)

Add a subscriber for real-time event notifications.

pub fn query(&self, filter: &LogFilter) -> Vec<LogEvent>

Get events matching a filter.

pub fn recent(&self, limit: usize) -> Vec<LogEvent>

Get the most recent N events.

pub fn by_trace(&self, trace_id: TraceId) -> Vec<LogEvent>

Get events for a specific trace.

pub fn by_trace_node(&self, trace_id: TraceId, node_id: NodeId) -> Vec<LogEvent>

Get events for a specific node within a trace.

pub fn by_pipeline(&self, pipeline_id: &str) -> Vec<LogEvent>

Get events for a specific pipeline.

pub fn by_level(&self, min_level: LogLevel) -> Vec<LogEvent>

Get events at or above a certain level.

pub fn all(&self) -> Vec<LogEvent>

Get all events (up to capacity).

pub fn clear(&self)

Clear all events.

pub fn capacity(&self) -> usize

Get buffer capacity.

pub fn since(&self, after_id: u64) -> Vec<LogEvent>

Get events since a given event ID.

pub fn time_range(&self, start_ns: u64, end_ns: u64) -> Vec<LogEvent>

Get events within a time range (nanoseconds since epoch).

Trait Implementations

impl Default for BufferedCollector

fn default() -> Self

Returns the “default value” for a type.

impl LogCollector for BufferedCollector

fn collect(&self, event: LogEvent)

Collect a log event.

fn len(&self) -> usize

Get the number of collected events.

fn is_empty(&self) -> bool

Check if the collector is empty.