Class MaterializedReadModels

Namespace

Cratis.Chronicle.ReadModels

Assembly

Cratis.Chronicle.dll

Represents an implementation of IMaterializedReadModels.

public class MaterializedReadModels : IMaterializedReadModels

Inheritance

object

MaterializedReadModels

Implements

IMaterializedReadModels

Inherited Members

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

MaterializedReadModels(IEventStore, IProjections, IReducers, IJsonSchemaGenerator, IChronicleServicesAccessor, JsonSerializerOptions, ILogger<MaterializedReadModels>)

Represents an implementation of IMaterializedReadModels.

public MaterializedReadModels(IEventStore eventStore, IProjections projections, IReducers reducers, IJsonSchemaGenerator schemaGenerator, IChronicleServicesAccessor chronicleServicesAccessor, JsonSerializerOptions jsonSerializerOptions, ILogger<MaterializedReadModels> logger)

Parameters

eventStore IEventStore

The IEventStore to use.

projections IProjections

Projections to get read models from.

reducers IReducers

Reducers to get read models from.

schemaGenerator IJsonSchemaGenerator

Schema generator to use.

chronicleServicesAccessor IChronicleServicesAccessor

Accessor for Chronicle services.

jsonSerializerOptions JsonSerializerOptions

The JsonSerializerOptions to use for JSON serialization.

logger ILogger<MaterializedReadModels>

The ILogger<TCategoryName> for logging.

Methods

GetInstances<TReadModel>(InstanceCountToSkip?, InstanceCount?)

Get paginated instances of a read model from the sink.

public Task<IEnumerable<TReadModel>> GetInstances<TReadModel>(InstanceCountToSkip? skip = null, InstanceCount? take = null)

Parameters

skip InstanceCountToSkip

Number of instances to skip. Defaults to zero.

take InstanceCount

Number of instances to retrieve. Defaults to 50.

Returns

Task<IEnumerable<TReadModel>>

Collection of read model instances.

Type Parameters

TReadModel

The read model type.

ObserveInstances<TReadModel>(InstanceCountToSkip?, InstanceCount?)

Observe changes for a paginated window of read model instances.

public IObservable<IEnumerable<TReadModel>> ObserveInstances<TReadModel>(InstanceCountToSkip? skip = null, InstanceCount? take = null)

Parameters

skip InstanceCountToSkip

Number of instances to skip. Defaults to zero.

take InstanceCount

Number of instances to observe. Defaults to 50.

Returns

IObservable<IEnumerable<TReadModel>>

An observable of IEnumerable<T>.

Type Parameters

TReadModel

Type of read model to observe changes for.