MicroPlumberd.Migration by: Rafal Maciag

Offline event-store migration / rewrite tool for KurrentDB (EventStore). Copies a source store to a fresh destination in $all commit order, applying raw (non-typed) migration rules — drop streams, drop events, rename event types, transform JSON payload/metadata, rename streams — with applied-migration history that travels with the store.

MicroPlumberd.Migration.Scripting by: Rafal Maciag

JavaScript rule scripting for MicroPlumberd.Migration: loads a Kurrent-Replicator-compatible rewrite script (function transform(original) plus dropStream/dropEvent/update/updateById/renameType/renameStream helpers) into a sandboxed Jint engine and compiles it to a Migration.

MicroPlumberd.ProcessManager.Abstractions by: MicroPlumberd.ProcessManager.Abstractions

Package Description

MicroPlumberd.Protobuf by: MicroPlumberd.Protobuf

CQRS/EventSourcing made eXtreamly simple. Protobuf serialization support.

MicroPlumberd.Rewrite by: Rafal Maciag

mp-rewrite — rewrites the history of a KurrentDB running in docker into a NEW store and swaps it in place, optionally through a JavaScript rule script. The old data directory is kept as a backup and never edited.

MicroPlumberd.Services by: MicroPlumberd.Services

CQRS/EventSourcing made eXtreamly simple. Application-Layer: Command-Handlers, Command-Bus

MicroPlumberd.Services.BatchOperations by: ModelingEvolution

Long-running operation tracking for MicroPlumberd event-sourced applications. Provides progress reporting, ETA calculation, and cancellation support.

MicroPlumberd.Services.Cron by: MicroPlumberd.Services.Cron

CQRS/EventSourcing made eXtreamly simple. Application-Layer: Command-Handlers, Command-Bus

MicroPlumberd.Services.Cron.Ui by: MicroPlumberd.Services.Cron.Ui

CQRS/EventSourcing made eXtreamly simple. Application-Layer: Command-Handlers, Command-Bus

MicroPlumberd.Services.EventAggregator by: MicroPlumberd.Services.EventAggregator

EventAggregator integration for MicroPlumberd event handlers. Enables low-latency in-process event delivery as an alternative to EventStore subscriptions.

MicroPlumberd.Services.Grpc.DirectConnect by: MicroPlumberd.Services.Grpc.DirectConnect

Package Description

MicroPlumberd.Services.Identity by: MicroPlumberd.Services.Identity

AspnetCode.Identity with CQRS/EventSourcing made eXtreamly simple. Domain-Layer abstractions: Read-Model, Event-Handler, Aggregate, Subscriptions

MicroPlumberd.Services.Identity.Blazor by: MicroPlumberd.Services.Identity.Blazor

Blazor components for MicroPlumberd.Services.Identity - User and Role management UI

MicroPlumberd.Services.ProcessManagers by: MicroPlumberd.Services.ProcessManagers

CQRS/EventSourcing made eXtreamly simple. This part is EXPERIMENTAL, provides abstraction over StateFull ProcessManager

MicroPlumberd.Services.Uniqueness by: MicroPlumberd.Services.Uniqueness

Set-wide uniqueness for event-sourced aggregates (reservation / try-confirm-cancel pattern) backed by a relational unique index. Provider-neutral core; install the .Sqlite, .Postgres or .SqlServer companion package.

MicroPlumberd.Services.Uniqueness.Postgres by: MicroPlumberd.Services.Uniqueness.Postgres

PostgreSQL provider for MicroPlumberd.Services.Uniqueness — the production default for set-wide uniqueness of event-sourced aggregates.

MicroPlumberd.Services.Uniqueness.Sqlite by: MicroPlumberd.Services.Uniqueness.Sqlite

SQLite provider for MicroPlumberd.Services.Uniqueness. Development, test and single-instance hosts only: SQLite is file-local and single-writer, so it cannot arbitrate uniqueness across replicas. Use the Postgres package in production.

MicroPlumberd.Services.Uniqueness.SqlServer by: MicroPlumberd.Services.Uniqueness.SqlServer

SQL Server provider for MicroPlumberd.Services.Uniqueness — set-wide uniqueness of event-sourced aggregates, backed by a relational unique index.

MicroPlumberd.SourceGenerators by: MicroPlumberd.SourceGenerators

CQRS/EventSourcing made eXtreamly simple. Code Generators.

MicroPlumberd.Testing by: MicroPlumberd.Testing

Testing utilities for MicroPlumberd. Includes Given-When-Then specs, Docker-based EventStore server management, and integration testing helpers for aggregates, command handlers, and process managers.