Struct MetricsCollector 

pub struct MetricsCollector {
    pub cache_hits: AtomicU64,
    pub cache_misses: AtomicU64,
    pub total_requests: AtomicU64,
    pub provider_usage: Arc<RwLock<HashMap<String, ProviderUsage>>>,
    pub method_stats: Arc<RwLock<HashMap<String, MethodStats>>>,
    pub metrics_history: Arc<RwLock<VecDeque<HistoricalMetric>>>,
    pub request_timestamps: Arc<RwLock<VecDeque<u64>>>,
    pub total_errors: AtomicU64,
    pub rate_limit_errors: AtomicU64,
    pub user_errors: AtomicU64,
}

Comprehensive metrics collector for the RPC proxy

Thread-safe metrics collection system that tracks cache performance, provider usage, method-level statistics, and historical trends. Uses atomic operations and read-write locks for concurrent access.

Fields

cache_hits: AtomicU64

Total number of cache hits across all methods (served from cache)

cache_misses: AtomicU64

Total number of cache misses that required checking the cache (excludes non-cacheable)

total_requests: AtomicU64

Total number of requests processed (all requests)

provider_usage: Arc<RwLock<HashMap<String, ProviderUsage>>>

Per-provider usage statistics and performance metrics

method_stats: Arc<RwLock<HashMap<String, MethodStats>>>

Per-method performance statistics and cache effectiveness

metrics_history: Arc<RwLock<VecDeque<HistoricalMetric>>>

Time-series data for trend analysis and monitoring dashboards

request_timestamps: Arc<RwLock<VecDeque<u64>>>

Recent request timestamps for calculating requests-per-minute

total_errors: AtomicU64

Total number of errors across all request types

rate_limit_errors: AtomicU64

Number of rate limiting errors encountered

user_errors: AtomicU64

Number of user-caused errors (4xx responses)

Implementations

impl MetricsCollector

pub fn new() -> Self

Create a new metrics collector

pub fn record_cache_hit(&self, method: &str, response_time_ms: u64)

Record a cache hit for a specific method

pub fn record_cache_miss(&self)

Record a cache miss for a specific method

pub fn record_request( &self, method: &str, provider_url: &str, response_time_ms: u64, success: bool, )

Record a request that was forwarded to an upstream provider This includes both cache misses and non-cacheable requests

pub fn record_error(&self, error_type: ErrorType)

Record an error by type

pub fn requests_per_minute(&self) -> u64

Calculate requests per minute based on recent timestamps

pub fn cache_hit_rate(&self) -> f64

Get overall cache hit rate as percentage

pub fn error_rate(&self) -> f64

Get error rate as percentage

pub fn add_historical_point( &self, cache_size: u64, healthy_providers: u64, total_providers: u64, active_instances: usize, )

Add a historical data point

pub fn get_method_stats(&self) -> HashMap<String, MethodStats>

Get method statistics as a cloned HashMap

pub fn get_provider_usage(&self) -> HashMap<String, ProviderUsage>

Get provider usage statistics as a cloned HashMap

pub fn get_metrics_history(&self) -> VecDeque<HistoricalMetric>

Get historical metrics as a cloned VecDeque

Trait Implementations

impl Debug for MetricsCollector

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

Formats the value using the given formatter.

impl Default for MetricsCollector

fn default() -> Self

Returns the “default value” for a type.