Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Vector Clocks in LevelDB
JavaScript
branch: master

Fetching latest commit…

Cannot retrieve the latest commit at this time

Failed to load latest commit information.
tests
.gitignore
.travis.yml
README.md
index.js
package.json
read_repair.js
vector_clocked.js

README.md

Level Vector Clock

LevelDB + Vector Clocks

Build Status

Install

$ npm install level-vectorclock --save

Use

Import

var LVC   = require('level-vectorclock');

Initialize Database

var level = require('level');

var nodeId = 'node-44';
var db = LVC(level('/path/to/my/db'), nodeId);

put(key, value[, meta], cb);

Without metadata (may create sibilings):

db.put('key', 'value', function(err, meta) {
  if (err) throw err;
  console.log('wrote, and here is meta: %j', meta);
});

With metadata:

db.put('key', 'value', meta, function(err, meta) {
  if (err) throw err;
  console.log('wrote, and here is new meta: %j', meta);
});

get(key, cb);

db.get('key', function(err, records) {
  if (err) throw err;

  records.forEach(function(record) {
    console.log('value:', record.value);
    console.log('meta:',  record.meta);
  });
});

Merge two sibilings

Since you may have had two conflicting writes, when you read you may get more than one record.

To resolve the conflict you need to provide all the metadatas of the records you want to resolve into a put call like this:

var metas = [meta1, meta2];
db.put('key', 'value', metas, function(err, meta) {
  if (err) throw err;
  console.log('new meta: %j', meta);
});

createReadStream(options)

Without options, streams all the data:

var s = db.createReadStream();

s.on('data', function(recs) {

  // each record on a data event has one or more sibilings
  recs.forEach(function(rec) {
    console.log('key:', rec.key);
    console.log('value:', rec.value);
    console.log('meta:', rec.meta);
  });
});

With options:

var options = {
  start: 'C',
  end: 'A',
  reverse: true,
  values: false,
  keys: true
};

var s = db.createReadStream(options);

createValueStream(options)

Alias for createReadStream({values: true, keys: false}).

createKeyStream(options)

Returns only the keys. Alias for createReadStream({values: false, keys: true}).

createWriteStream(options)

Creates a writable stream.

Supports the same options as levelup.

License

MIT

Something went wrong with that request. Please try again.