Struct StatsManager 

pub struct StatsManager { /* private fields */ }

Statistics Manager

Unified management of query metrics, query profiling and error statistics.

Implementations

impl StatsManager

pub fn record_aggregated_query(&self, profile: &QueryProfile, is_slow: bool)

Record aggregated query statistics

pub fn get_top_n_slow_query_patterns( &self, limit: usize, ) -> Vec<AggregatedQueryStats>

Get top N slow query patterns by average duration

pub fn pattern_snapshot(&self, limit: usize) -> Vec<QueryPatternSnapshot>

pub fn get_top_n_patterns_by_total_duration( &self, limit: usize, ) -> Vec<AggregatedQueryStats>

Get top N slow query patterns by total duration

pub fn get_top_n_patterns_by_execution_count( &self, limit: usize, ) -> Vec<AggregatedQueryStats>

Get top N slow query patterns by execution count

pub fn get_pattern_stats( &self, normalized_query: &str, ) -> Option<AggregatedQueryStats>

Get statistics for a specific query pattern

pub fn get_all_aggregated_stats(&self) -> Vec<AggregatedQueryStats>

Get all aggregated statistics

pub fn get_total_aggregated_queries(&self) -> u64

Get total number of queries processed

pub fn get_total_aggregated_slow_queries(&self) -> u64

Get total number of slow queries

pub fn get_current_qps(&self) -> u64

Get current queries per second

pub fn get_pattern_count(&self) -> usize

Get number of query patterns

pub fn clear_aggregated_stats(&self)

Clear all aggregated statistics

pub fn cleanup_aggregated_stats(&self)

Cleanup expired aggregated statistics

impl StatsManager

pub fn record_checkpoint_success( &self, duration: Duration, bytes_flushed: u64, wal_files_truncated: u64, )

Record a successful checkpoint operation.

pub fn record_checkpoint_failure(&self)

Record a failed checkpoint operation.

pub fn record_checkpoint_trigger( &self, reason: CheckpointTriggerReason, age: Duration, )

Record a checkpoint trigger event.

pub fn record_checkpoint_deduplicated(&self)

Record a deduplicated checkpoint request.

pub fn record_checkpoint_blocked(&self)

Record a checkpoint request that found another checkpoint in progress.

pub fn checkpoint_snapshot(&self) -> CheckpointSnapshot

pub fn get_checkpoint_metrics(&self) -> HashMap<MetricType, u64>

Get all checkpoint-related metrics.

pub fn record_dirty_pages(&self, dirty: u64, total: u64)

pub fn record_checkpoint_strategy_by_name(&self, strategy: &str)

pub fn record_incremental_checkpoint(&self, duration: Duration, bytes: u64)

pub fn get_dirty_page_metrics(&self) -> HashMap<MetricType, u64>

impl StatsManager

pub fn space_key(space_id: u64) -> String

Single key rule: space_{id} for numeric spaces, space_name:{name} for named collections, target:{name} for sync targets, rebuild:{target}:{phase} for rebuild phases, and space_{id}.{index} for per-space indexes. Distinct prefixes keep same-named entities in different subsystems from polluting each other while identical spaces share one key.

pub fn space_key_for_name(name: &str) -> String

pub fn target_key(target: &str) -> String

pub fn rebuild_key(target: &str, phase: &str) -> String

pub fn index_key(space_id: u64, index_name: &str) -> String

pub fn unknown_index_key(index_name: &str) -> String

pub fn new() -> StatsManager

pub fn with_config( monitoring_enabled: bool, profile_cache_size: usize, slow_query_threshold_us: u64, ) -> StatsManager

pub fn with_slow_query_logger( monitoring_enabled: bool, profile_cache_size: usize, slow_query_threshold_us: u64, slow_query_config: SlowQueryConfig, ) -> Result<StatsManager, Error>

Create StatsManager with slow query logger

pub fn slow_query_threshold_us(&self) -> u64

pub fn timeseries_capacity(&self) -> usize

pub fn set_timeseries_capacity(&self, capacity: usize)

pub fn set_histogram_max_samples(&self, max_samples: usize)

pub fn record_resource_sample( &self, memory_used_bytes: u64, memory_total_bytes: u64, cpu_usage_percent: f64, )

pub fn query_timeseries(&self, window_secs: u64) -> Vec<TimeseriesBucket>

pub fn resource_timeseries(&self, window_secs: u64) -> Vec<ResourceSample>

impl StatsManager

pub fn add_value(&self, metric_type: MetricType)

pub fn add_value_with_amount(&self, metric_type: MetricType, amount: u64)

pub fn dec_value(&self, metric_type: MetricType)

pub fn set_value(&self, metric_type: MetricType, value: u64)

pub fn add_space_metric(&self, space_name: &str, metric_type: MetricType)

pub fn add_space_metric_with_amount( &self, space_name: &str, metric_type: MetricType, amount: u64, )

pub fn set_space_metric_with_amount( &self, space_name: &str, metric_type: MetricType, amount: u64, )

pub fn add_index_metric(&self, index_name: &str, metric_type: MetricType)

pub fn add_index_metric_with_amount( &self, index_name: &str, metric_type: MetricType, amount: u64, )

pub fn dec_space_metric(&self, space_name: &str, metric_type: MetricType)

pub fn get_value(&self, metric_type: MetricType) -> Option<u64>

pub fn get_space_value( &self, space_name: &str, metric_type: MetricType, ) -> Option<u64>

pub fn get_index_value( &self, index_name: &str, metric_type: MetricType, ) -> Option<u64>

pub fn get_all_index_metrics( &self, index_name: &str, ) -> Option<HashMap<MetricType, u64>>

pub fn get_all_metrics(&self) -> HashMap<MetricType, u64>

pub fn get_all_space_metrics( &self, space_name: &str, ) -> Option<HashMap<MetricType, u64>>

pub fn all_space_metrics(&self) -> HashMap<String, HashMap<MetricType, u64>>

Every space-scoped metric set, keyed by space key.

pub fn reset_metric(&self, metric_type: MetricType)

pub fn reset_all_metrics(&self)

pub fn reset_space_metrics(&self, space_name: &str)

impl StatsManager

pub fn record_error(&self, error_type: ErrorType, phase: QueryPhase)

pub fn get_error_count(&self, error_type: ErrorType) -> u64

pub fn get_error_count_by_phase(&self, phase: QueryPhase) -> u64

pub fn get_all_error_counts(&self) -> HashMap<ErrorType, u64>

pub fn get_all_error_counts_by_phase(&self) -> HashMap<QueryPhase, u64>

pub fn reset_error_counts(&self)

pub fn record_failed_query(&self, profile: QueryProfile, error_info: ErrorInfo)

pub fn get_error_summary(&self) -> ErrorSummary

pub fn get_recent_errors(&self, limit: usize) -> Vec<RecentError>

pub fn error_snapshot(&self) -> ErrorSnapshot

pub fn recent_errors_snapshot(&self, limit: usize) -> Vec<RecentErrorView>

impl StatsManager

pub fn record_migration_start(&self)

pub fn record_migration_success(&self, rows: u64, duration_ms: u64)

pub fn record_migration_failure(&self, duration_ms: u64)

pub fn get_migration_metrics(&self) -> HashMap<MetricType, u64>

impl StatsManager

pub fn record_query_profile(&self, profile: QueryProfile)

pub fn get_recent_queries(&self, limit: usize) -> Vec<QueryProfile>

pub fn get_slow_queries(&self, limit: usize) -> Vec<QueryProfile>

pub fn get_all_slow_queries(&self, limit: usize) -> SlowQueryStats

pub fn get_query_profile(&self, trace_id: &str) -> Option<QueryProfile>

pub fn get_session_queries( &self, session_id: i64, limit: usize, ) -> Vec<QueryProfile>

pub fn get_executor_stats_summary(&self) -> HashMap<String, (u64, u64, usize)>

pub fn executor_summary_snapshot(&self) -> Vec<ExecutorSummary>

pub fn profiles_in_window( &self, from_secs: Option<u64>, to_secs: Option<u64>, limit: usize, ) -> Vec<QueryProfile>

pub fn clear_query_cache(&self)

pub fn query_cache_size(&self) -> usize

impl StatsManager

pub fn record_query_metrics(&self, metrics: &QueryMetrics)

pub fn get_latency_percentiles(&self) -> (u64, u64, u64, u64)

Get latency percentiles (avg, p50, p95, p99) in microseconds

pub fn query_latency_snapshot(&self) -> QueryLatencySnapshot

pub fn get_search_latency_percentiles(&self) -> (u64, u64, u64, u64)

Get search latency percentiles (avg, p50, p95, p99) in microseconds

pub fn get_latency_report(&self) -> String

Get latency histogram report

pub fn clear_latency_histogram(&self)

Clear latency histogram

pub fn get_last_query_metrics(&self) -> Option<QueryMetrics>

pub fn get_query_metrics_history(&self) -> Vec<QueryMetrics>

Recent per-instance query metrics (up to 1000), newest last.

pub fn get_query_metrics(&self) -> Option<QueryMetrics>

impl StatsManager

pub fn record_search( &self, space_id: u64, index_name: &str, latency_ms: u64, success: bool, )

Record a search query operation. Index metrics are keyed per-space (space_{id}.{index}) so same-named indexes in different spaces no longer pollute each other.

pub fn record_index_operation( &self, space_id: u64, index_name: &str, latency_ms: u64, success: bool, )

Record an index operation

pub fn record_index_operation_unknown_space( &self, index_name: &str, latency_ms: u64, success: bool, )

Record an index operation without a known space. Used by storage paths that lack space context; records global and unknown.{index} buckets only, never polluting real space_{id} keys.

pub fn record_delete_operation( &self, space_id: u64, index_name: &str, latency_ms: u64, success: bool, )

Record a delete operation

pub fn record_search_result_count(&self, space_id: u64, count: u64)

Record search result count

pub fn record_cache_hit_global(&self, hit: bool)

Record cache hit or miss (global only).

pub fn record_vector_disabled_skips(&self, count: u64)

pub fn record_vector_embedding( &self, prompt_tokens: u64, total_tokens: u64, latency_ms: u64, success: bool, )

Record one embedding call (global bucket only).

The embedding path has no space context, so only global counters are updated; per-space keys are never synthesized here. Failed calls carry zero token usage.

pub fn record_vector_rerank(&self, latency_ms: u64, success: bool)

Record one issued rerank call (global bucket only).

Skipped reranks (no service, no query text, thin coverage) are not recorded; only actual provider calls land here.

pub fn search_index_breakdown(&self) -> Vec<SearchIndexBreakdown>

impl StatsManager

pub fn record_storage_read(&self, latency_us: u64)

pub fn record_storage_write(&self, latency_us: u64)

Record a storage write with latency so means are computable.

pub fn record_storage_error(&self)

Record a storage error.

pub fn record_bloom_query(&self, hit: bool)

Record a bloom pre-check query and whether it was positive. Hit rate derives from BloomHits / BloomQueries; permille is exported for dashboards via BloomHitRatePermille. The triple update holds bloom_lock so queries/hits/permille stay atomic under concurrency.

pub fn record_bloom_snapshot(&self, queries: u64, hits: u64)

Snapshot-export bloom counters from a shard runtime. Holds bloom_lock for the same atomicity as record_bloom_query. Callers must pass deltas since the last export, not cumulative totals, to avoid double counting.

pub fn set_index_memory_usage(&self, bytes: u64)

pub fn storage_snapshot(&self) -> StorageSnapshot

pub fn record_tombstone_stats( &self, count: u64, memory_bytes: u64, oldest_ts_min: Option<u32>, newest_ts_max: Option<u32>, active_snapshots: u64, )

Record tombstone statistics for MVCC observability

pub fn record_fragmentation_stats(&self, ratio: f32, wasted_bytes: u64)

Record storage fragmentation on the single wasted-share caliber.

pub fn record_ttl_purge(&self, cycles: u64, removed_rows: u64)

Record one background TTL-purge sweep: how many sweep cycles ran and how many expired rows each cycle physically deleted.

impl StatsManager

pub fn record_sync_operation(&self, latency_ms: u64, success: bool)

pub fn record_sync_error(&self)

pub fn set_sync_queue_depth(&self, depth: u64)

pub fn record_outbox_state(&self, state: OutboxState)

pub fn record_target_frontier_lag(&self, target: &str, lag: u64)

pub fn record_generation_build(&self)

pub fn record_generation_publish(&self)

pub fn record_generation_rebuild_failure(&self)

pub fn record_inconsistent_index_count(&self, count: u64)

pub fn record_rebuild_phase_latency( &self, target: &str, phase: &str, latency_ms: u64, )

pub fn record_split(&self, success: bool)

pub fn record_reclaimed_index_files(&self, count: u64)

pub fn set_manifest_state(&self, active_readers: u64, retired_generations: u64)

pub fn record_fence_failure(&self)

pub fn record_transport_latency(&self, latency_ms: u64)

pub fn record_materializer_latency(&self, latency_ms: u64)

pub fn set_snapshot_lag(&self, lag: u64)

impl StatsManager

pub fn record_txn_begin(&self)

Record transaction begin

pub fn record_txn_commit(&self)

Record transaction commit

pub fn record_txn_rollback(&self)

Record transaction rollback

pub fn record_txn_conflict(&self)

Record transaction conflict

pub fn record_txn_timeout(&self)

Record transaction timeout.

pub fn record_txn_disconnect(&self)

Record transaction disconnect.

pub fn record_txn_recovery_abort(&self)

Record transaction recovery abort.

pub fn record_txn_cleanup_failure(&self)

Record transaction cleanup failure.

pub fn transaction_snapshot(&self) -> TransactionSnapshot

pub fn set_txn_resource_metrics(&self, metrics: TxnResourceMetrics)

Transaction resource metrics

Trait Implementations

impl Debug for StatsManager

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

Formats the value using the given formatter.

impl Default for StatsManager

fn default() -> StatsManager

Returns the “default value” for a type.