Struct QueryTelemetry 

pub struct QueryTelemetry {
    pub query_id: String,
    pub query_class: String,
    pub start_time: Option<Instant>,
    pub total_duration_us: u64,
    pub routing: RoutingMetrics,
    pub scan: ScanMetrics,
    pub rerank: RerankMetrics,
    pub cache: CacheMetrics,
    pub error_envelope: ErrorEnvelopeMetrics,
    pub termination: TerminationMetrics,
    pub cost: Option<CostSummaryJson>,
    pub tags: HashMap<String, String>,
}

Comprehensive per-query telemetry

Fields

query_id: String

Query identifier (for correlation)

query_class: String

Query class (e.g., “low_latency”, “high_recall”)

start_time: Option<Instant>

Timestamp when query started

total_duration_us: u64

Total query duration

routing: RoutingMetrics

Routing phase metrics

scan: ScanMetrics

Scan phase metrics

rerank: RerankMetrics

Rerank phase metrics

cache: CacheMetrics

Cache metrics

error_envelope: ErrorEnvelopeMetrics

Error envelope metrics

termination: TerminationMetrics

Termination metrics

cost: Option<CostSummaryJson>

Cost summary (if budget tracking enabled)

tags: HashMap<String, String>

Custom tags for filtering/grouping

Implementations

impl QueryTelemetry

pub fn new(query_class: &str) -> Self

Create new telemetry for a query

pub fn with_id(query_id: &str, query_class: &str) -> Self

Create with specific query ID

pub fn record_routing( &mut self, duration: Duration, lists_considered: u32, lists_scanned: u32, )

Record routing phase

pub fn record_routing_full( &mut self, duration: Duration, lists_considered: u32, lists_scanned: u32, centroid_comparisons: u32, used_compressed: bool, strategy: &str, )

Record routing with full details

pub fn record_scan(&mut self, codes_evaluated: u64, ram_bytes: u64)

Record scan phase

pub fn record_scan_full( &mut self, duration: Duration, codes_evaluated: u64, ram_bytes: u64, simd_ops: u64, candidates_stage1: u32, distance_metric: &str, quant_level: &str, )

Record scan with full details

pub fn record_rerank( &mut self, duration: Duration, candidates_in: u32, candidates_out: u32, ssd_random_reads: u32, ssd_sequential_bytes: u64, )

Record rerank phase

pub fn record_io_coalescing(&mut self, coalesced: bool, ranges: u32)

Record IO coalescing details

pub fn record_cache_hit(&mut self, cache_type: CacheType)

Record cache hits/misses

pub fn record_cache_miss(&mut self, cache_type: CacheType)

Record cache miss

pub fn set_guarantee_mode(&mut self, mode: &GuaranteeMode)

Set guarantee mode

pub fn record_error_bounds(&mut self, max_error: f32, mean_error: f32)

Record error bounds observed

pub fn set_stop_reason( &mut self, reason: StopReason, probes: u32, max_probes: u32, )

Set stop reason

pub fn set_miss_probability(&mut self, prob: f32)

Set miss probability

pub fn set_result_count(&mut self, count: u32)

Set result count

pub fn attach_cost(&mut self, summary: CostSummary)

Attach cost summary

pub fn add_tag(&mut self, key: &str, value: &str)

Add a custom tag

pub fn finalize(&mut self)

Finalize telemetry (compute total duration)

pub fn to_json(&self) -> String

Serialize to JSON

pub fn to_json_pretty(&self) -> String

Serialize to pretty JSON

Trait Implementations

impl Clone for QueryTelemetry

fn clone(&self) -> QueryTelemetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryTelemetry

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueryTelemetry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueryTelemetry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.