Packages

Core

Package	NuGet	Description
Nagare		Aggregates, events, projections, subscriptions, OpenTelemetry, middleware. Everything you need to build event-sourced systems.
Nagare.Dashboard		Embedded operational dashboard — live event tail, time machine, provenance lens, process inspector, outbox triage.

Dynamic Consistency Boundaries

Package	NuGet	Description
Nagare.Dcb (experimental)		DCB event store abstractions and decision models — tag-indexed global journal, conditional appends for hard cross-entity invariants. Tracks a young spec; the API may evolve. See DCB.

Database stores

Package	NuGet	Databases	Notes
Nagare.SqlServer		SQL Server	Production-grade with MERGE upsert support.
Nagare.Sqlite		SQLite	Ideal for development and testing.
Nagare.PostgreSql		PostgreSQL	Full support with advisory locks for distributed subscriptions.
Nagare.MySql		MySQL / MariaDB	Full support with distributed locks.

Messaging

Package	NuGet	Description
Nagare.Messaging		Pub/sub messaging abstractions — topic publishers, consumers, subscription runners.
Nagare.Messaging.Kafka		Apache Kafka implementation using the Confluent client.

Streams

Package	NuGet	Description
Nagare.Streams		Composable async pipelines — Source/Flow/Sink DSL for projections, process managers, pollers, and SSE.
Nagare.Streams.Kafka		Kafka source, sink, and offset store for Nagare.Streams pipelines.
Nagare.Streams.Testing		TestKit and shared test bases for Nagare.Streams pipelines.

Process managers

Package	NuGet	Description
Nagare.Process.Orleans		Orleans grain runtime for process managers — single-writer semantics, outbox dispatch, event route subscriptions.

Read queries

Package	NuGet	Description
Nagare.ReadQueries		Typed read-model query store — inline interpolated SQL, dialect-aware emission.
Nagare.ReadQueries.Generators		Source generator + analyzers for Nagare.ReadQueries. Ships inside Nagare.ReadQueries.
Nagare.ReadQueries.Validation		Build-time SQL validation for [ReadQuery] methods — column-name mismatches become build errors.

Testing

Package	NuGet	Description
Nagare.Testing		Given-When-Then harness, Eventually for polling projections, Find() for querying projected state.

Quick start

<PackageReference Include="Nagare" />
<PackageReference Include="Nagare.Sqlite" />

builder.Services.AddNagare();
builder.Services.AddNagareSqliteStorage(connectionString: "Data Source=nagare.db");
builder.Services.AddAggregate<BookAggregate, BookCommand, BookEvent, BookState>();

For PostgreSQL:

<PackageReference Include="Nagare" />
<PackageReference Include="Nagare.PostgreSql" />

builder.Services.AddNagare();
builder.Services.AddNagarePostgresStorage(connectionString: "Host=localhost;Database=nagare");
builder.Services.AddAggregate<BookAggregate, BookCommand, BookEvent, BookState>();