Class Reducers

Namespace

Cratis.Chronicle.Reducers

Assembly

Cratis.Chronicle.dll

Represents an implementation of IReducers.

public class Reducers : IReducers

Inheritance

object

Reducers

Implements

IReducers

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

ReducerWaitExtensions.WaitForState<TReducer>(IReducers, ObserverRunningState, TimeSpan?)

ReducerWaitExtensions.WaitForThereToBeFailedPartitions<TReducer>(IReducers, TimeSpan?)

ReducerWaitExtensions.WaitTillActive<TReducer>(IReducers, TimeSpan?)

ReducerWaitExtensions.WaitTillReachesEventSequenceNumber<TReducer>(IReducers, EventSequenceNumber, TimeSpan?)

ReducerWaitExtensions.WaitTillSubscribed<TReducer>(IReducers, TimeSpan?)

Constructors

Reducers(IEventStore, IClientArtifactsProvider, IServiceProvider, IReducerValidator, IEventTypes, IEventSerializer, IModelNameResolver, IJsonSchemaGenerator, JsonSerializerOptions, IIdentityProvider, ILogger<Reducers>)

Initializes a new instance of the Reducers class.

public Reducers(IEventStore eventStore, IClientArtifactsProvider clientArtifacts, IServiceProvider serviceProvider, IReducerValidator reducerValidator, IEventTypes eventTypes, IEventSerializer eventSerializer, IModelNameResolver modelNameResolver, IJsonSchemaGenerator jsonSchemaGenerator, JsonSerializerOptions jsonSerializerOptions, IIdentityProvider identityProvider, ILogger<Reducers> logger)

Parameters

eventStore IEventStore

IEventStore the reducers belong to.

clientArtifacts IClientArtifactsProvider

IClientArtifactsProvider for discovery.

serviceProvider IServiceProvider

IServiceProvider to get instances of types.

reducerValidator IReducerValidator

IReducerValidator for validating reducer types.

eventTypes IEventTypes

Registered IEventTypes.

eventSerializer IEventSerializer

IEventSerializer for serializing of events.

modelNameResolver IModelNameResolver

IModelNameResolver for resolving read model names.

jsonSchemaGenerator IJsonSchemaGenerator

IJsonSchemaGenerator for generating JSON schemas.

jsonSerializerOptions JsonSerializerOptions

JsonSerializerOptions for JSON serialization.

identityProvider IIdentityProvider

IIdentityProvider for managing identity context.

logger ILogger<Reducers>

ILogger for logging.

Methods

Discover()

Discover all reducers from the entry assembly and dependencies.

public Task Discover()

Returns

Task

Awaitable task.

GetAllHandlers()

Get all registered handlers.

public IEnumerable<IReducerHandler> GetAllHandlers()

Returns

IEnumerable<IReducerHandler>

Collection of IReducerHandler.

GetClrType(ReducerId)

Get the CLR type for a specific reducer.

public Type GetClrType(ReducerId reducerId)

Parameters

reducerId ReducerId

ReducerId to get for.

Returns

Type

The type.

GetFailedPartitionsFor(Type)

Get any failed partitions for a specific reducer.

public Task<IEnumerable<FailedPartition>> GetFailedPartitionsFor(Type reducerType)

Parameters

reducerType Type

Type of reducer.

Returns

Task<IEnumerable<FailedPartition>>

Collection of FailedPartition, if any.

GetFailedPartitionsFor<TReducer>()

Get any failed partitions for a specific reducer.

public Task<IEnumerable<FailedPartition>> GetFailedPartitionsFor<TReducer>() where TReducer : IReducer

Returns

Task<IEnumerable<FailedPartition>>

Collection of FailedPartition, if any.

Type Parameters

TReducer

Type of reducer.

GetHandlerById(ReducerId)

Get all registered reducers by its identifier.

public IReducerHandler GetHandlerById(ReducerId reducerId)

Parameters

reducerId ReducerId

The identifier of the reducer to get.

Returns

IReducerHandler

IReducerHandler instance.

GetHandlerFor(Type)

Gets a specific handler by its reducer type.

public IReducerHandler GetHandlerFor(Type reducerType)

Parameters

reducerType Type

The reducer type to get for.

Returns

IReducerHandler

IReducerHandler.

GetHandlerForReadModelType(Type)

Get a specific handler for a specific model type.

public IReducerHandler GetHandlerForReadModelType(Type modelType)

Parameters

modelType Type

Model type to get for.

Returns

IReducerHandler

IReducerHandler instance.

GetHandlerFor<TReducer>()

Get a specific handler for a specific reducer.

public IReducerHandler GetHandlerFor<TReducer>() where TReducer : IReducer

Returns

IReducerHandler

IReducerHandler.

Type Parameters

TReducer

Type of reducer to get for.

GetStateFor<TReducer>()

Get the state of a specific reactor.

public Task<ReducerState> GetStateFor<TReducer>() where TReducer : IReducer

Returns

Task<ReducerState>

ReducerState.

Type Parameters

TReducer

Type of reactor get for.

HasReducerFor(Type)

Check if there is a reducer for a specific model type.

public bool HasReducerFor(Type modelType)

Parameters

modelType Type

Model type to check for.

Returns

bool

True if it has, false if not.

Register()

Register all reducers with Chronicle.

public Task Register()

Returns

Task

Awaitable task.

Register<TReducer, TModel>()

Registers a TReducer reducer with Chronicle.

public Task<IReducerHandler> Register<TReducer, TModel>() where TReducer : IReducerFor<TModel> where TModel : class

Returns

Task<IReducerHandler>

Awaitable task.

Type Parameters

TReducer

The reactor type.

TModel

The model type the reducer is for.

Replay(ReducerId)

Replay a specific reducer by its identifier.

public Task Replay(ReducerId reducerId)

Parameters

reducerId ReducerId

ReducerId to replay.

Returns

Task

Awaitable task.

Replay<TReducer>()

Replay a specific reducer.

public Task Replay<TReducer>() where TReducer : IReducer

Returns

Task

Awaitable task.

Type Parameters

TReducer

Type of reducer to replay.