Class ProjectionHandler

Namespace

Cratis.Chronicle.Projections

Assembly

Cratis.Chronicle.dll

Represents an implementation of IProjectionHandler.

public class ProjectionHandler : IProjectionHandler, IHaveReadModel

Inheritance

object

ProjectionHandler

Implements

IProjectionHandler

IHaveReadModel

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, Type, ReadModelContainerName, EventSequenceId)

Represents an implementation of IProjectionHandler.

public ProjectionHandler(IEventStore eventStore, ProjectionId projectionId, Type readModelType, ReadModelContainerName containerName, EventSequenceId eventSequenceId)

Parameters

eventStore IEventStore

The event store to use.

projectionId ProjectionId

The identifier of the projection.

readModelType Type

The type of the read model.

containerName ReadModelContainerName

The container name of the read model (collection, table, etc.).

eventSequenceId EventSequenceId

The event sequence identifier.

Properties

ContainerName

Gets the container name of the read model (collection, table, etc.).

public ReadModelContainerName ContainerName { get; }

Property Value

ReadModelContainerName

Id

Gets the identifier of the projection.

public ProjectionId Id { get; }

Property Value

ProjectionId

ReadModelType

Gets the type of the read model.

public Type ReadModelType { get; }

Property Value

Type

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.