Struct TelemetryStore 

pub struct TelemetryStore { /* private fields */ }

Thread-safe in-memory telemetry store.

Stores recently-received OTLP data in bounded collections. The OTLP receiver writes to this store, and the OTLP client trait implementations read from it.

Implementations

impl TelemetryStore

pub fn new(config: StoreConfig) -> Arc<Self>

Create a new telemetry store with the given configuration.

pub fn insert_trace(&self, trace: Trace)

Insert or update a trace in the store.

pub fn get_trace(&self, trace_id: &str) -> Option<Trace>

Get a trace by its ID.

pub fn search_traces( &self, service_name: Option<&str>, operation_name: Option<&str>, min_duration_us: Option<u64>, max_duration_us: Option<u64>, start_time_us: Option<u64>, end_time_us: Option<u64>, limit: usize, ) -> Vec<TraceSummary>

Search traces matching the given criteria. Returns summaries.

pub fn trace_count(&self) -> usize

Get the number of stored traces.

pub fn insert_logs(&self, entries: Vec<LogEntry>)

Insert log entries into the store.

pub fn query_logs( &self, start_ns: i64, end_ns: i64, labels: &FxHashMap<String, String>, contains: Option<&str>, limit: usize, ) -> Vec<LogEntry>

Query logs matching the given filters.

pub fn known_log_labels(&self) -> Vec<String>

Get all known label keys from stored logs.

pub fn log_count(&self) -> usize

Get the number of stored log entries.

pub fn insert_metric_point(&self, point: MetricDataPoint)

Insert a metric data point into the store.

pub fn insert_metric_points(&self, points: Vec<MetricDataPoint>)

Insert a batch of metric data points.

pub fn metric_names(&self) -> Vec<String>

Get all known metric names.

pub fn metric_label_names(&self, metric: &str) -> Vec<String>

Get all known label names for a specific metric.

pub fn metric_label_values(&self, metric: &str, label: &str) -> Vec<String>

Get all known label values for a specific metric and label name.

pub fn query_metric( &self, metric: &str, labels: &FxHashMap<String, String>, start_ns: u64, end_ns: u64, step_ns: u64, ) -> QueryResponse

Query a metric and return a QueryResponse compatible with the Prometheus format.

pub fn metric_series_count(&self) -> usize

Get the number of stored metric time series.

pub fn metric_point_count(&self) -> usize

Get the total number of stored metric data points.