Struct ObservationLog 

pub struct ObservationLog {
    pub max_age_secs: u64,
    /* private fields */
}

Append-only, TTL-pruned observation log backed by redb.

Fields

max_age_secs: u64

Implementations

impl ObservationLog

pub fn open(path: &Path, max_age_secs: u64) -> Result<Self, ObsLogError>

Open or create an observation log at the given path.

pub fn append( &self, source: &str, value: f64, metadata: BTreeMap<String, String>, ) -> Result<(), ObsLogError>

Append a single observation.

pub fn append_batch( &self, observations: &[(String, f64, BTreeMap<String, String>)], ) -> Result<(), ObsLogError>

Append a batch of observations in a single transaction.

pub fn query( &self, source: &str, since_ts_ms: u64, ) -> Result<Vec<Observation>, ObsLogError>

Query observations for a source since a given timestamp.

pub fn query_latest( &self, source: &str, ) -> Result<Option<Observation>, ObsLogError>

Get the most recent observation for a source.

pub fn sources(&self) -> Result<Vec<String>, ObsLogError>

List distinct sources that have observations.

pub fn truncate(&self, before_ts_ms: u64) -> Result<u64, ObsLogError>

Delete all observations older than before_ts_ms. Returns count deleted.

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

Total number of observations.

pub fn size_bytes(&self) -> u64

Size of the redb file in bytes.