Interface IProjectionHandler

Namespace

Cratis.Chronicle.Projections

Assembly

Cratis.Chronicle.dll

Defines a system for handling projections.

public interface IProjectionHandler

Extension Methods

ProjectionWaitExtensions.WaitForState(IProjectionHandler, ObserverRunningState, TimeSpan?)

ProjectionWaitExtensions.WaitForThereToBeFailedPartitions(IProjectionHandler, TimeSpan?)

ProjectionWaitExtensions.WaitTillActive(IProjectionHandler, TimeSpan?)

ProjectionWaitExtensions.WaitTillReachesEventSequenceNumber(IProjectionHandler, EventSequenceNumber, TimeSpan?)

ProjectionWaitExtensions.WaitTillSubscribed(IProjectionHandler, TimeSpan?)

Properties

Id

Gets the identifier of the projection.

ProjectionId Id { get; }

Property Value

ProjectionId

Methods

GetFailedPartitions()

Get any failed partitions for a specific reducer.

Task<IEnumerable<FailedPartition>> GetFailedPartitions()

Returns

Task<IEnumerable<FailedPartition>>

Collection of FailedPartition, if any.

GetState()

Get the current state of the reducer.

Task<ProjectionState> GetState()

Returns

Task<ProjectionState>

The current ProjectionState.