Struct ProcessingMetrics 

pub struct ProcessingMetrics { /* private fields */ }

Metrics collector for tracking processing performance and statistics

Thread-safe metrics tracking for queries, document processing, batches, rate limiting, and system resource usage. Uses atomic operations for counters and locks for duration collections.

Implementations

impl ProcessingMetrics

pub fn new() -> Self

Creates a new metrics collector with all counters initialized to zero

pub fn increment_query_started(&self)

Increments the counter for queries started

pub fn increment_query_success(&self)

Increments the counter for successfully completed queries

pub fn increment_query_error(&self)

Increments the counter for failed queries

pub fn record_query_duration(&self, duration: Duration)

Records the execution duration of a query

Keeps only the most recent 1000 measurements to prevent unbounded memory growth.

Parameters

• duration: Time taken to execute the query

pub fn increment_document_processing_started(&self)

Increments the counter for document processing operations started

pub fn increment_document_processing_success(&self)

Increments the counter for successfully processed documents

pub fn increment_document_processing_error(&self)

Increments the counter for failed document processing operations

pub fn record_document_processing_duration(&self, duration: Duration)

Records the processing duration of a document

Keeps only the most recent 1000 measurements to prevent unbounded memory growth.

Parameters

• duration: Time taken to process the document

pub fn increment_batch_processing_started(&self)

Increments the counter for batch processing operations started

pub fn record_batch_processing_duration(&self, duration: Duration)

Records the processing duration of a batch

Keeps only the most recent 100 measurements to prevent unbounded memory growth.

Parameters

• duration: Time taken to process the batch

pub fn increment_rate_limit_errors(&self)

Increments the counter for rate limiting errors

pub fn update_peak_memory_usage(&self, memory_bytes: u64)

Updates peak memory usage if the new value exceeds the current peak

Parameters

• memory_bytes: Current memory usage in bytes

pub fn get_queries_started(&self) -> usize

Returns the number of queries started

pub fn get_queries_succeeded(&self) -> usize

Returns the number of queries that succeeded

pub fn get_queries_failed(&self) -> usize

Returns the number of queries that failed

pub fn get_documents_started(&self) -> usize

Returns the number of document processing operations started

pub fn get_documents_succeeded(&self) -> usize

Returns the number of documents processed successfully

pub fn get_documents_failed(&self) -> usize

Returns the number of document processing operations that failed

pub fn get_batches_started(&self) -> usize

Returns the number of batch processing operations started

pub fn get_rate_limit_errors(&self) -> usize

Returns the number of rate limiting errors encountered

pub fn get_peak_memory_usage(&self) -> u64

Returns the peak memory usage observed in bytes

pub fn get_uptime(&self) -> Duration

Returns the time elapsed since metrics tracking started

pub fn get_average_query_duration(&self) -> Option<Duration>

Calculates the average query execution duration

Returns

Average duration if queries have been recorded, None otherwise

pub fn get_average_document_duration(&self) -> Option<Duration>

Calculates the average document processing duration

Returns

Average duration if documents have been processed, None otherwise

pub fn get_query_success_rate(&self) -> f64

Calculates the query success rate

Returns

Ratio of successful queries to total queries (0.0-1.0), or 1.0 if no queries

pub fn get_document_success_rate(&self) -> f64

Calculates the document processing success rate

Returns

Ratio of successful documents to total documents (0.0-1.0), or 1.0 if no documents

pub fn get_summary(&self) -> MetricsSummary

Generates a comprehensive summary of all metrics

Returns

Structured summary containing query, document, and system metrics

pub fn print_summary(&self)

Prints a formatted summary of all metrics to the log

Trait Implementations

impl Debug for ProcessingMetrics

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

Formats the value using the given formatter.

impl Default for ProcessingMetrics

fn default() -> Self

Returns the “default value” for a type.