Class ProjectionBuilderFor<TReadModel>

Namespace

Cratis.Chronicle.Projections

Assembly

Cratis.Chronicle.dll

Represents an implementation of IProjectionBuilderFor<TReadModel>.

public class ProjectionBuilderFor<TReadModel> : ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>, IProjectionBuilderFor<TReadModel>, IProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>

Type Parameters

TReadModel

Type of read model.

Inheritance

object

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>

ProjectionBuilderFor<TReadModel>

Implements

IProjectionBuilderFor<TReadModel>

IProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>

Inherited Members

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._fromDefinitions

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._childrenDefinitions

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._nestedDefinitions

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._joinDefinitions

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._fromDerivativesDefinitions

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._removedWithDefinitions

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._removedWithJoinDefinitions

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._observedEventStores

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._noAutoMapProperties

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._fromEveryDefinition

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._initialValues

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._autoMap

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>._readModelIdentifier

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.WithInitialValues(Func<TReadModel>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.AutoMap()

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.NoAutoMap()

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.From<TEvent>(Action<IFromBuilder<TReadModel, TEvent>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.Join<TEvent>(Action<IJoinBuilder<TReadModel, TEvent>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.FromEvery(Action<IFromEveryBuilder<TReadModel>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.FromAll(Action<IFromAllBuilder<TReadModel>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.RemovedWith<TEvent>(Action<RemovedWithBuilder<TReadModel, TEvent>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.RemovedWithJoin<TEvent>(Action<RemovedWithJoinBuilder<TReadModel, TEvent>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.Children<TChildModel>(Expression<Func<TReadModel, IEnumerable<TChildModel>>>, Action<IChildrenBuilder<TReadModel, TChildModel>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.Nested<TNestedModel>(Expression<Func<TReadModel, TNestedModel>>, Action<INestedBuilder<TReadModel, TNestedModel>>)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.GetFromEventType(EventType)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.CollectEventStore(Type)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.ValidateEventType(Type)

ProjectionBuilder<TReadModel, IProjectionBuilderFor<TReadModel>>.BuildDefinitions(EventGenerationDelivery)

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Constructors

ProjectionBuilderFor(ProjectionId, Type, INamingPolicy, IEventTypes, JsonSerializerOptions)

Initializes a new instance of the ProjectionBuilderFor<TReadModel> class.

public ProjectionBuilderFor(ProjectionId identifier, Type projectionType, INamingPolicy namingPolicy, IEventTypes eventTypes, JsonSerializerOptions jsonSerializerOptions)

Parameters

identifier ProjectionId

The unique identifier for the projection.

projectionType Type

The type of the projection.

namingPolicy INamingPolicy

The INamingPolicy to use for converting names during serialization.

eventTypes IEventTypes

IEventTypes for providing event type information.

jsonSerializerOptions JsonSerializerOptions

The JsonSerializerOptions to use for any JSON serialization.

Methods

ContainerName(string)

Names the model container - typically used by storage as name of storage unit (collection, table, etc.).

public IProjectionBuilderFor<TReadModel> ContainerName(string containerName)

Parameters

containerName string

Container name of the read model.

Returns

IProjectionBuilderFor<TReadModel>

Builder continuation.

Remarks

Overrides the container name the naming policy would otherwise give the read model. The identifier of the read model is not affected. Every projection of the same read model must agree on the container name.

EntersOn<TEvent>()

Declares the event that activates this variant.

public IProjectionBuilderFor<TReadModel> EntersOn<TEvent>()

Returns

IProjectionBuilderFor<TReadModel>

Builder continuation.

Type Parameters

TEvent

Type of event that activates this variant.

Remarks

Only for a projection that also declares VariantOf<TIdentity>(Expression<Func<TReadModel, object?>>). The event keeps its ordinary create-or-update behavior; mapping its properties is still done with the usual From call.

FromEventSequence(EventSequenceId)

Specifies the EventSequenceId to use as source.

public IProjectionBuilderFor<TReadModel> FromEventSequence(EventSequenceId eventSequenceId)

Parameters

eventSequenceId EventSequenceId

EventSequenceId to use.

Returns

IProjectionBuilderFor<TReadModel>

Builder continuation.

NotRewindable()

Set the projection to not be rewindable - its a moving forward only projection.

public IProjectionBuilderFor<TReadModel> NotRewindable()

Returns

IProjectionBuilderFor<TReadModel>

Builder continuation.

Passive()

Set the projection not be active, meaning that it won't actively observe.

public IProjectionBuilderFor<TReadModel> Passive()

Returns

IProjectionBuilderFor<TReadModel>

Builder continuation.

VariantOf<TIdentity>(Expression<Func<TReadModel, object?>>)

Declares this projection as one of several mutually exclusive representations of the same logical entity.

public IProjectionBuilderFor<TReadModel> VariantOf<TIdentity>(Expression<Func<TReadModel, object?>> keyAccessor)

Parameters

keyAccessor Expression<Func<TReadModel, object>>

Accessor for this read model's own key, used to correlate an event back to an already-active instance.

Returns

IProjectionBuilderFor<TReadModel>

Builder continuation.

Type Parameters

TIdentity

The type anchoring the logical identity the variants share. It needs no read model and no common base type with the variants.

Remarks

Every projection declaring the same TIdentity forms a group. Entering one variant removes the entity from every other variant in that group. Only the events named with EntersOn<TEvent>() may create this variant; every other event it projects from becomes an update-only mapping that can bring an active instance up to date but never create or resurrect one.