Class ProjectionHandler

Namespace

Cratis.Chronicle.Projections

Assembly

Cratis.Chronicle.dll

Represents an implementation of IProjectionHandler.

public class ProjectionHandler : IProjectionHandler

Inheritance

object

ProjectionHandler

Implements

IProjectionHandler

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

ProjectionWaitExtensions.WaitForState(IProjectionHandler, ObserverRunningState, TimeSpan?)

ProjectionWaitExtensions.WaitForThereToBeFailedPartitions(IProjectionHandler, TimeSpan?)

ProjectionWaitExtensions.WaitTillActive(IProjectionHandler, TimeSpan?)

ProjectionWaitExtensions.WaitTillReachesEventSequenceNumber(IProjectionHandler, EventSequenceNumber, TimeSpan?)

ProjectionWaitExtensions.WaitTillSubscribed(IProjectionHandler, TimeSpan?)

Constructors

ProjectionHandler(IEventStore, ProjectionId, EventSequenceId)

Represents an implementation of IProjectionHandler.

public ProjectionHandler(IEventStore eventStore, ProjectionId projectionId, EventSequenceId eventSequenceId)

Parameters

eventStore IEventStore

The event store to use.

projectionId ProjectionId

The identifier of the projection.

eventSequenceId EventSequenceId

The event sequence identifier.

Properties

Id

Gets the identifier of the projection.

public ProjectionId Id { get; }

Property Value

ProjectionId

Methods

GetFailedPartitions()

Get any failed partitions for a specific reducer.

public Task<IEnumerable<FailedPartition>> GetFailedPartitions()

Returns

Task<IEnumerable<FailedPartition>>

Collection of FailedPartition, if any.

GetState()

Get the current state of the reducer.

public Task<ProjectionState> GetState()

Returns

Task<ProjectionState>

The current ProjectionState.