Class RegisteredReducerExtensions

Namespace
Cratis.Chronicle.Reducers
Assembly
Cratis.Chronicle.dll

Provides unconstrained siblings of the legacy marker-based reducer operations for plain registered classes.

public static class RegisteredReducerExtensions
Inheritance
RegisteredReducerExtensions
Inherited Members

Methods

GetFailedPartitionsFor<T>(IReducers)

Gets failed partitions for a registered reducer CLR type.

public static Task<IEnumerable<FailedPartition>> GetFailedPartitionsFor<T>(this IReducers reducers) where T : class

Parameters

reducers IReducers

The owning store's reducer registry.

Returns

Task<IEnumerable<FailedPartition>>

The failed partitions.

Type Parameters

T

The reducer class.

GetHandlerFor<T>(IReducers)

Gets a registered handler for a reducer CLR type.

public static IReducerHandler GetHandlerFor<T>(this IReducers reducers) where T : class

Parameters

reducers IReducers

The owning store's reducer registry.

Returns

IReducerHandler

The registered handler.

Type Parameters

T

The reducer class.

GetStateFor<T>(IReducers)

Gets a registered reducer's state.

public static Task<ReducerState> GetStateFor<T>(this IReducers reducers) where T : class

Parameters

reducers IReducers

The owning store's reducer registry.

Returns

Task<ReducerState>

The reducer state.

Type Parameters

T

The reducer class.

Register<T>(IReducers)

Registers a reducer with its inferred read model.

public static Task<IReducerHandler> Register<T>(this IReducers reducers) where T : class

Parameters

reducers IReducers

The owning store's reducer registry.

Returns

Task<IReducerHandler>

The registered handler.

Type Parameters

T

The reducer class.

Replay<T>(IReducers)

Replays a registered reducer CLR type.

public static Task<JobId> Replay<T>(this IReducers reducers) where T : class

Parameters

reducers IReducers

The owning store's reducer registry.

Returns

Task<JobId>

The replay job identifier.

Type Parameters

T

The reducer class.