Struct TsDb

pub struct TsDb {
    pub data: HashMap<String, Trace>,
    /* private fields */
}

A time series database which can be used as a library. Note that this struct is not usable in multiple threads. To make it accessible from multiple threads, use the TsDbHandle wrapper.

Fields

data: HashMap<String, Trace>

Implementations

impl TsDb

Database for time series.

pub fn new() -> Self

Examples found in repository

examples/perf.rs (line 9)

fn main() {
    let mut db = TsDb::new();

    insertions(&mut db);
    do_query(&db);
}

pub fn into_handle(self) -> TsDbHandle

pub fn add_values(&mut self, name: &str, samples: Vec<Observation<Sample>>)

Add a batch of values

pub fn new_trace(&mut self, name: &str)

Examples found in repository

examples/perf.rs (line 22)

fn insertions(db: &mut TsDb) {
    let num_insertions = 1_000_000;
    println!(
        "Created database, now inserting {} data points into a signal.",
        num_insertions
    );

    db.new_trace("fu");
    let t1 = Instant::now();
    for i in 0..num_insertions {
        let ts = TimeStamp::new(i as f64);
        let sample = Sample::new(i as f64);
        let observation = Observation::new(ts, sample);
        db.add_value("fu", observation);
    }
    let t2 = Instant::now();
    let time_delta = t2 - t1;
    let time_delta = time_delta.as_secs_f64();

    println!(
        "Inserted {} points in {} seconds.",
        num_insertions, time_delta
    );
    let rate = num_insertions as f64 / time_delta;
    println!("That means {} mega-points per second.", rate / 1.0e6);
}

pub fn add_value(&mut self, name: &str, observation: Observation<Sample>)

Examples found in repository

examples/perf.rs (line 28)

fn insertions(db: &mut TsDb) {
    let num_insertions = 1_000_000;
    println!(
        "Created database, now inserting {} data points into a signal.",
        num_insertions
    );

    db.new_trace("fu");
    let t1 = Instant::now();
    for i in 0..num_insertions {
        let ts = TimeStamp::new(i as f64);
        let sample = Sample::new(i as f64);
        let observation = Observation::new(ts, sample);
        db.add_value("fu", observation);
    }
    let t2 = Instant::now();
    let time_delta = t2 - t1;
    let time_delta = time_delta.as_secs_f64();

    println!(
        "Inserted {} points in {} seconds.",
        num_insertions, time_delta
    );
    let rate = num_insertions as f64 / time_delta;
    println!("That means {} mega-points per second.", rate / 1.0e6);
}

pub fn query(&self, name: &str, query: Query) -> QueryResult

Query the given trace for data.

Examples found in repository

examples/perf.rs (line 50)

fn do_query(db: &TsDb) {
    // Query the data
    println!("Querying the database!");

    let query = Query::create()
        .start(TimeStamp::new(0.0))
        .end(TimeStamp::new(1000.0))
        .build();
    let result = db.query("fu", query);

    println!("Got result: {:?}", result.query);
    println!("Num result: {:?}", result.len());
    // let raw_samples = result.into_vec();
    // println!("Raw samples: {}", raw_samples.len());
}

pub fn summary(&self, name: &str) -> Option<Aggregation<Sample, SampleMetrics>>

Get a summary for the given trace.

Trait Implementations

impl Debug for TsDb

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

Formats the value using the given formatter.

impl Display for TsDb

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

Formats the value using the given formatter.