Struct AdaptiveCompressor 

pub struct AdaptiveCompressor { /* private fields */ }

Adaptive compressor: buffers samples, then chooses and applies the best algorithm when finish is called.

Example

let mut comp = AdaptiveCompressor::new();
for (ts, val) in sensor_data {
    comp.push(ts, val);
}
let block = comp.finish()?;
println!("Used: {}, ratio: {:.1}", block.algorithm, block.compression_ratio());

Implementations

impl AdaptiveCompressor

pub fn new() -> Self

Create a new adaptive compressor.

pub fn with_algorithm(self, algo: CompressionAlgorithm) -> Self

Force use of a specific algorithm regardless of data characteristics.

pub fn push(&mut self, timestamp: i64, value: f64)

Add a (timestamp_ms, value) sample.

pub fn extend(&mut self, samples: &[(i64, f64)])

Add multiple samples at once.

pub fn finish(self) -> TsdbResult<CompressedBlock>

Compress the buffered samples and return a self-describing block.

After calling finish, the compressor is consumed.

Trait Implementations

impl Default for AdaptiveCompressor

fn default() -> Self

Returns the “default value” for a type.