Namespace Stratara.Abstractions.Projections

Classes

ReplayProgress

Snapshot of replay progress at a point in time. Returned by GetProgress() for status dashboards.

Interfaces

IProjectionCheckpointStore

Reads and writes the position a store-reading consumer resumes after, one per consumer and partition. A position is only meaningful to the reader that produced it, so every read names the reader it expects and a checkpoint written under another reader is refused rather than misread.

IProjectionRebuilder

Rebuilds one projection from the beginning of the store while every other projection keeps applying. Only a projection that declares how to empty its own read model can be rebuilt alone.

IProjectionReplayState

In-memory coordination handle for the projection-replay state-machine. Workers query this to decide whether they are currently running a replay; admin endpoints flip it via Activate() / Deactivate().

IProjectionViewTruncator

Truncates every projection view as part of a replay reset. Implementations typically execute a single transaction with TRUNCATE ... CASCADE across the read-store schema.