@baldim/plugin-eventual-consistency

Eventually consistent counters and aggregations for Baldim resources. The plugin supports synchronous and asynchronous updates, coordinated ticket workers, consolidation, recalculation, retention, and time-series analytics.

pnpm add @baldim/core @baldim/plugin-eventual-consistency

import { Baldim } from '@baldim/core';
import { EventualConsistencyPlugin } from '@baldim/plugin-eventual-consistency';

const database = new Baldim({ connectionString: 'memory://analytics' });
await database.connect();
const posts = await database.createResource({
  name: 'posts',
  attributes: { views: 'number|default:0' },
});

await database.usePlugin(new EventualConsistencyPlugin({
  mode: 'async',
  resources: { posts: ['views'] },
}));

await posts.insert({ id: 'post-1', views: 0 });
await posts.add('post-1', 'views', 1);

// Applies pending transactions for post-1 only.
await posts.consolidate('post-1', 'views');

The plugin adds add, sub, set, increment, decrement, consolidate, getConsolidatedValue, and recalculate helpers to configured resources. It restores any previous methods when stopped. Background consolidation and garbage collection use Baldim's plugin storage and coordinator contracts, so the plugin does not depend on a specific storage adapter.