We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4dd11c1 commit a374f84Copy full SHA for a374f84
test/fixtures/transaction-log-worker.mts
@@ -0,0 +1,19 @@
1
+import { RocksDatabase } from '../../src/index.js';
2
+import { parentPort, workerData } from 'node:worker_threads';
3
+
4
+const db = RocksDatabase.open(workerData.path);
5
6
+parentPort?.on('message', event => {
7
+ if (event.addManyEntries) {
8
+ for (let i = 0; i < event.count; i++) {
9
+ const log = db.useLog('foo');
10
+ log.addEntry(Date.now(), Buffer.from('hello'));
11
+ }
12
+ parentPort?.postMessage({ done: true });
13
+ } else if (event.close) {
14
+ db.close();
15
+ process.exit(0);
16
17
+});
18
19
+parentPort?.postMessage({ started: true });
0 commit comments