Skip to main content
Table of Contents

Namespace Stratara.Abstractions.Projections

Classes

ProjectionPartitionLag

A partition that did not reach the mark, and how it stood when the wait ended.

ProjectionWaitResult

The answer of a wait for a projection.

ReplayCompletion

How a replay ended, as the replaying worker reports it to Complete(ReplayCompletion).

ReplayOutcome

The outcome of a replay that has ended.

ReplayProgress

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

StoreMark

Where the store was when a mark was taken. A host passes it back to IProjectionProgress and relies on nothing inside it; what it holds is meaningful only to the reader that produced it. Two marks are equal when they name the same reader and the same positions.

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.

IProjectionProgress

Lets a host wait until a projection that reads the store from a checkpoint has applied what was committed: take a StoreMark once the write has committed, then wait for the projection to reach it before reading its read model.

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. Dispatchers and readers query IsReplayActive to hold back while a replay runs; admin endpoints request a replay with RequestReplay(Guid) and watch it with GetProgress().

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.

Enums

ProjectionWaitOutcome

How a wait for a projection ended, or how a partition stood when it ended.

ReplayResult

How a replay ended.