Struct SqliteQualityTelemetryReader 

pub struct SqliteQualityTelemetryReader { /* private fields */ }

Read-only query adapter for the shareable local quality journal.

Implementations

impl SqliteQualityTelemetryReader

pub fn open(data_dir: &Path) -> Result<SqliteQualityTelemetryReader, PortError>

pub fn count(&self) -> Result<u64, PortError>

pub fn query_since( &self, since_millis: u64, rpc: Option<&str>, limit: usize, ) -> Result<Vec<QualityTelemetryObservation>, PortError>

pub fn query_between( &self, since_millis: u64, until_millis: u64, rpc: Option<&str>, limit: usize, ) -> Result<Vec<QualityTelemetryObservation>, PortError>

pub fn latest( &self, limit: usize, ) -> Result<Vec<QualityTelemetryObservation>, PortError>

Trait Implementations

impl Clone for SqliteQualityTelemetryReader

fn clone(&self) -> SqliteQualityTelemetryReader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteQualityTelemetryReader

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

Formats the value using the given formatter.

impl ObservabilityQueryPort for SqliteQualityTelemetryReader

fn available_series(&self) -> Vec<String>

Exact series names this reader can resolve without inventing aliases. Readers backed by a dynamic remote catalog may leave this empty until they can expose that capability explicitly.

fn query<'a>( &'a self, query: ObservabilityQuery, ) -> Pin<Box<dyn Future<Output = Result<ObservabilityProjection, PortError>> + Send + 'a>>