Stratara.Projections
4.5.0
Prefix Reserved
See the version list below for details.
dotnet add package Stratara.Projections --version 4.5.0
NuGet\Install-Package Stratara.Projections -Version 4.5.0
<PackageReference Include="Stratara.Projections" Version="4.5.0" />
<PackageVersion Include="Stratara.Projections" Version="4.5.0" />
<PackageReference Include="Stratara.Projections" />
paket add Stratara.Projections --version 4.5.0
#r "nuget: Stratara.Projections, 4.5.0"
#:package Stratara.Projections@4.5.0
#addin nuget:?package=Stratara.Projections&version=4.5.0
#tool nuget:?package=Stratara.Projections&version=4.5.0
Stratara.Projections
Derived. The behaviour described here is specified under
openspec/specs/. Those specifications are the source; this page explains and illustrates them.
License: MIT.
Projection runtime for the Stratara event-sourced stack. Discovers IProjection implementations in the consumer's application assemblies, dispatches event bundles to them, and applies the resulting change sets atomically via the read-model repository layer.
What's in the box
| Folder | Contents |
|---|---|
Services/ |
The runtime, all internal: ProjectionManager (event-bundle → matching projection-handlers fan-out), ProjectionHandler (invokes a projection's matching methods), ProjectionMethodInvoker (reflection-cached method-pointer dispatch into consumer projections). You implement IProjection; these drive it |
Abstractions/ |
IProjection and its refinements: IRebuildableProjection (can be rebuilt alone on the Orleans execution model) and IForgetsDeletedTenants (a fact recorded for a tenant after its deletion is passed over instead of failing the projection; the record is kept by IForgottenTenantStore, which the read store provides), and IReadModelPreservation (lets a failed replay restore the read models it emptied; the PostgreSQL implementation comes with AddReadModelRestore<TReadContext>()) |
Multitenancy/ |
TenantProjection — the framework's own opinionated tenant aggregate projection. Skip the registration if your application has its own tenancy model |
Diagnostics/Extensions/ |
Source-generated LoggerProjectionExtensions, LoggerChangeSetExtensions, LoggerUpdateExtensions — typed [LoggerMessage] surfaces under the Stratara.Projection.* / Stratara.ChangeSet.* / Stratara.Update.* event-ID bands |
Quick start
// In your EventProjection worker:
builder.Services
.AddProjectionWorker(builder.Configuration) // the runtime + hosted service
.AddProjectionsFromAssemblyContaining<MyAppProjectionMarker>(); // your IProjection implementations
Then implement IProjection in your application assembly. The projection manager picks them up automatically.
Both calls are needed: AddProjectionsFromAssemblyContaining<T>() only registers your projections —
AddProjectionWorker(IConfiguration) registers the manager, the invoker and the hosted service that
consumes the event-bundle subscription. Without it nothing drives your projections. Most hosts get
both from the AddEventProjectionWorkerServices() composite in Stratara.EventSourcing.WorkerDefaults.
No checkpoint store. Projections are driven push-wise off the event bus; the framework keeps no per-projection checkpoint, so there is no consumer-lag metric and no built-in resume-from-sequence. Replay is coordinated separately (see
Stratara.Outbox.RabbitMQ's replay state).
Dependencies
Stratara.Contracts— forEventBundle+IEvent<T>.Stratara.Domain— for the framework'sTenantaggregate (only consumed byTenantProjection).Stratara.Shared— for change-tracking primitives, reflection cache, partitioning helpers, diagnostics base.Microsoft.Extensions.Hosting.Abstractions+Microsoft.Extensions.Options.ConfigurationExtensions— for projection-worker checkpointing options.JetBrains.Annotations— for static-analysis attributes on projection-handler conventions.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
-
net10.0
- JetBrains.Annotations (>= 2026.2.0)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.13)
- Microsoft.Extensions.Options.ConfigurationExtensions (>= 10.0.13)
- Stratara.Contracts (>= 4.5.0)
- Stratara.Domain (>= 4.5.0)
- Stratara.Shared (>= 4.5.0)
NuGet packages (3)
Showing the top 3 NuGet packages that depend on Stratara.Projections:
| Package | Downloads |
|---|---|
|
Stratara.EventSourcing.EntityFrameworkCore
EF Core persistence for the Stratara event-sourced stack on PostgreSQL — write-store, read-store, ASP.NET Identity store — including a shared identity store with its migrations — shared conventions, value generators, and UnitOfWork primitives. Targets Npgsql; maps pgvector types for a model that uses them, and needs no database extension otherwise. |
|
|
Stratara.EventSourcing.WorkerDefaults
Worker-host wiring composites for the Stratara event-sourced stack. IHostApplicationBuilder extensions (AddBackendServices, AddCommandWorkerServices, AddHeavyCommandWorkerServices, AddEventProjectionWorkerServices, AddEventStreamHashWorkerServices, AddSagaWorkerServices, AddOutboxWorkerServices, and AddCommandServices, AddEventProjectionServices and AddSagaServices without the bus-fed workers) bundle the per-concern DI calls so each worker host opts in with one line. |
|
|
Stratara.Orleans
The Orleans execution model for the Stratara event-sourced stack — one activation per aggregate across the cluster, commands recorded before the call returns and resumed after a crash, projections and sagas that read the store in commit order from a checkpoint, singleton work, owner-checked durable timers and heavy work bounded across the cluster. |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 4.8.0 | 226 | 11/6/2026 |
| 4.7.1 | 186 | 11/5/2026 |
| 4.7.0 | 597 | 10/30/2026 |
| 4.6.1 | 166 | 10/29/2026 |
| 4.6.0 | 233 | 10/28/2026 |
| 4.5.0 | 322 | 10/28/2026 |
| 4.4.10 | 268 | 10/26/2026 |
| 4.4.9 | 174 | 10/26/2026 |
| 4.4.8 | 320 | 10/24/2026 |
| 4.4.7 | 174 | 10/23/2026 |
| 4.4.6 | 280 | 10/22/2026 |
| 4.4.5 | 366 | 10/14/2026 |
| 4.4.4 | 349 | 10/10/2026 |
| 4.4.3 | 183 | 10/10/2026 |
| 4.4.2 | 445 | 10/2/2026 |
| 4.4.1 | 433 | 9/29/2026 |
| 4.4.0 | 187 | 9/27/2026 |
| 4.3.1 | 192 | 9/25/2026 |
| 4.3.0 | 356 | 9/23/2026 |
| 4.2.0 | 231 | 9/18/2026 |
A release about reads that cost more the more the store holds. Loading an aggregate read its stream and its
snapshot through every partition of the store, so every command grew slower as the store grew. A write context
that applies `ApplyGlobalEntityConfiguration()` also lost the index on the event stream's sequence number, which
left the hashing worker, reading in sequence order and the store's head without an index. Every read of one stream
is now confined to its partition, and the write model declares the indexes it was missing, whichever key the
context gives the event stream. No public type or member changes, but the write context needs a migration, and a
write context that overrides `ConfigureConventions` without calling `base` is now refused at start-up.
**Upgrading:**
- **If your store holds events written before 3.0.0, check it first.** Releases before 3.0.0 worked out a
stream's partition with another formula, and the store now reads a stream only in the partition its id gives.
The composition guide (*A store written before 3.0.0*) gives a check that needs nothing but the database, and a
repair that moves the rows to their partition without touching the hash chain. A store that 3.0.0 or later wrote
from its start has nothing to check.
- **Generate an EF Core migration for your write context.** It adds up to three indexes and changes no table or
column: `ix_event_stream_entry_sequence_number` (unique, only where the event stream is not keyed by its sequence
number, which `ApplyGlobalEntityConfiguration()` makes it), `ix_event_stream_entry_unhashed_sequence_number`
(the entries whose hash is still null) and `ix_event_chain_anchor_sequence_number`. A host that does not migrate
fails at `Migrate()` on pending model changes, as with any schema addition.
- **If you declared these indexes yourself, remove your declarations first.** Under the same names and
definitions, the migration then leaves them as they are. A `(stream_id, version)` index you added to bridge the
stream reads is no longer needed and can be dropped.
- **On a large store, create the indexes without blocking writes.** The schema section of the composition guide
shows a migration that creates them with `CREATE INDEX CONCURRENTLY`.
- **A context that overrides `ConfigureConventions` calls `base.ConfigureConventions`.** `WriteDbContext<TContext>`
declares the sequence-number indexes there. A write context whose override does not call it is now refused when
its model is built, at start-up and in `dotnet ef` alike, with an `InvalidOperationException` that names the
context, so it never runs or migrates without the indexes. An override that was fine on 4.4 because the
method was empty there needs `base.ConfigureConventions(configurationBuilder);` now.
- **An entry or snapshot written outside the framework has to carry its stream's partition.** The store writes
each one with the partition its stream id gives it, through `BucketCalculator.GetBucketId`, and now reads one
stream only there. A row a host inserted itself under another partition, in a test fixture or an import, is no
longer found by the reads of its stream.
### Fixed
- **Loading an aggregate costs what its stream holds.** The reads of one stream (whether it exists, its first entry,
a range of versions, its current version) and of its snapshot conditioned on the stream id alone. The indexes that
serve them begin with the partition, so PostgreSQL before 18 walked the whole index for each of them, and a
command loads several. They now condition on the partition as well. On 300,000 events, reading a stream of three
went from 2,404 pages to 6.
- **The sequence number stays indexed under `ApplyGlobalEntityConfiguration()`.** That convention keys every entity
by `Id`, the event stream included, which dropped the key the framework had put on the sequence number. The
hashing worker's reads, reading the store in sequence order and the store's head then scanned the whole table on
every pass. The write model now declares a unique index on the sequence number wherever it is not the key.
- **The hashing worker reads only what is still unchained.** An index over the entries whose hash is null lets
each pass read the backlog and not the chained history before it. Its filter names the column your model maps the
hash to.
- **The latest anchor is found by index.** The hash chain's anchors are indexed by sequence number, so finding the
last one no longer sorts every anchor on every pass.