kvstore: add experimental node:kvstore module

benchmark/kvstore/kvstore-get.js

@@ -0,0 +1,28 @@
+'use strict';
+const common = require('../common.js');
+const { openKv } = require('node:kvstore');
+
+const DATASET_SIZE = 5000;
+
+const bench = common.createBenchmark(main, {
+  n: [20000],
+});
+
+function main(conf) {
+  const kv = openKv();
+
+  for (let i = 0; i < DATASET_SIZE; i++) {
+    kv.set(['bench', i], { id: i, name: `item-${i}`, active: i % 2 === 0 });
+  }
+
+  let result;
+  bench.start();
+  for (let i = 0; i < conf.n; i++) {
+    result = kv.get(['bench', i % DATASET_SIZE]);
+  }
+  bench.end(conf.n);
+
+  kv.close();
+  // Prevent dead-code elimination.
+  if (result === undefined) throw new Error('unexpected undefined');
+}

benchmark/kvstore/kvstore-getmany.js

@@ -0,0 +1,34 @@
+'use strict';
+const common = require('../common.js');
+const { openKv } = require('node:kvstore');
+
+const DATASET_SIZE = 5000;
+const BATCH_SIZE = 100;
+
+const bench = common.createBenchmark(main, {
+  n: [2000],
+  batch: [BATCH_SIZE],
+});
+
+function main(conf) {
+  const kv = openKv();
+
+  for (let i = 0; i < DATASET_SIZE; i++) {
+    kv.set(['bench', i], { id: i, name: `item-${i}`, active: i % 2 === 0 });
+  }
+
+  function batchAt(offset) {
+    return Array.from({ length: conf.batch }, (_, j) =>
+      ['bench', (offset + j) % DATASET_SIZE]);
+  }
+
+  let result;
+  bench.start();
+  for (let i = 0; i < conf.n; i++) {
+    result = kv.getMany(batchAt(i * conf.batch));
+  }
+  bench.end(conf.n);
+
+  kv.close();
+  if (result === undefined) throw new Error('unexpected undefined');
+}

benchmark/kvstore/kvstore-range-scan.js

@@ -0,0 +1,43 @@
+'use strict';
+const common = require('../common.js');
+const assert = require('node:assert');
+const { openKv } = require('node:kvstore');
+
+const DATASET_SIZE = 5000;
+
+const bench = common.createBenchmark(main, {
+  n: [200],
+  selector: ['prefix', 'range'],
+});
+
+function main(conf) {
+  const kv = openKv();
+
+  for (let i = 0; i < DATASET_SIZE; i++) {
+    kv.set(['bench', i], { id: i, name: `item-${i}` });
+  }
+
+  let count;
+
+  if (conf.selector === 'prefix') {
+    bench.start();
+    for (let i = 0; i < conf.n; i++) {
+      count = 0;
+      for (const _ of kv.keys({ prefix: ['bench'] })) count++;
+    }
+    bench.end(conf.n);
+  } else {
+    // Range scan: ['bench', 0] inclusive to ['bench', DATASET_SIZE - 1] inclusive.
+    const start = ['bench', 0];
+    const end = ['bench', DATASET_SIZE - 1];
+    bench.start();
+    for (let i = 0; i < conf.n; i++) {
+      count = 0;
+      for (const _ of kv.keys({ start, end })) count++;
+    }
+    bench.end(conf.n);
+  }
+
+  kv.close();
+  assert.strictEqual(count, DATASET_SIZE);
+}

benchmark/kvstore/kvstore-set.js

@@ -0,0 +1,20 @@
+'use strict';
+const common = require('../common.js');
+const { openKv } = require('node:kvstore');
+
+const bench = common.createBenchmark(main, {
+  n: [20000],
+});
+
+function main(conf) {
+  const kv = openKv();
+  const value = { id: 0, name: 'item', tags: ['a', 'b', 'c'], active: true };
+
+  bench.start();
+  for (let i = 0; i < conf.n; i++) {
+    kv.set(['bench', i], value);
+  }
+  bench.end(conf.n);
+
+  kv.close();
+}

doc/api/index.md

@@ -36,6 +36,7 @@
 * [Inspector](inspector.md)
 * [Internationalization](intl.md)
 * [Iterable Streams API](stream_iter.md)
+* [KV store](kvstore.md)
 * [Modules: CommonJS modules](modules.md)
 * [Modules: ECMAScript modules](esm.md)
 * [Modules: `node:module` API](module.md)