Struct QueryLog 

pub struct QueryLog {
    pub total_recorded: u64,
    /* private fields */
}

Query log for tracking routing history and computing statistics

Fields

total_recorded: u64

Total entries ever recorded (including evicted)

Implementations

impl QueryLog

pub fn new() -> Self

Create a new query log with the default capacity

pub fn with_capacity(max_size: usize) -> Self

Create a new query log with given capacity

pub fn record_routing( &mut self, query_id: u64, source_id: impl Into<String>, confidence: f32, ml_used: bool, feature_vector: Option<Vec<f32>>, )

Record a routing decision (before execution result is known).

feature_vector is the ML feature vector used for this routing decision; stored so that learn_from_outcome can retrieve it for online model updates.

pub fn find_entry_features( &self, query_id: u64, source_id: &str, ) -> Option<Vec<f32>>

Find the feature vector stored for a given routing decision.

Returns None if the entry doesn’t exist or has no feature vector.

pub fn record_outcome( &mut self, query_id: u64, source_id: &str, success: bool, latency_ms: u32, result_count: u32, reward: f32, )

Record the outcome of a routing decision

Matches by query_id + source_id (most recent match).

pub fn source_stats(&self, source_id: &str) -> Option<&SourceLogStats>

Get aggregated statistics for a source

pub fn routing_score(&self, source_id: &str) -> Option<f32>

Get the routing score for a source based on log history

Returns a value in 0.0–1.0 representing how well this source has performed historically. Returns None if no history.

pub fn best_source(&self) -> Option<&str>

Get the best source ID based on log history

pub fn ranked_sources(&self) -> Vec<(String, f32)>

Get all source IDs that have log history, sorted by score (descending)

pub fn recent_entries(&self, limit: usize) -> &[RoutingLogEntry]

Get recent log entries (up to limit)

pub fn len(&self) -> usize

Get the number of entries in the log

pub fn is_empty(&self) -> bool

Check if the log is empty

pub fn clear_entries(&mut self)

Clear the log (preserves source statistics)

pub fn clear_all(&mut self)

Clear everything including statistics

pub fn evict_older_than(&mut self, max_age_ms: u64) -> usize

Remove entries older than max_age_ms milliseconds

Returns the number of entries removed.

pub fn tracked_source_count(&self) -> usize

Get the number of sources with log history

pub fn combined_reliability(&self, source_id: &str, current_rate: f32) -> f32

Compute a reliability score for a source: combines log stats and the provided current success_rate from SourceStats.

current_rate should be source.stats.success_rate. If no log history, falls back to current_rate.

Trait Implementations

impl Clone for QueryLog

fn clone(&self) -> QueryLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryLog

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

Formats the value using the given formatter.

impl Default for QueryLog

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for QueryLog

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueryLog

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

where __S: Serializer,

Serialize this value into the given Serde serializer.