Timestreamdb NPM

timestreamdb

Super early alpha version!

Docs coming, there is a LOT in there. Uses timestream for a query engine.

Supports joins, aggregates, map operations, filters...

var TsDB = require("timestreamdb")
var level = require("level")

var orig = level("./testdb", {valueEncoding: "json"})

var statware = require("statware")

// Using statware to make some numbers to look at...
var stats = statware()
stats.registerHelper(statware.memstats)
stats.registerHelper(statware.procstats)
stats.registerHelper(statware.sysstats)

var db = TsDB(orig)

setInterval(function () {
  stats.getStats(function (s) {
    db.put("foo", s)
  })
}, 100)

setInterval(function () {
  db.ts("foo")
    .flatten()
    .numbers()
    .mean(1000)
    .toArray(console.log)
}, 1000)