Interface IReducers
Defines a system for working with reducer registrations for the Kernel.
public interface IReducers- Extension Methods
Methods
Discover()
Discover all reducers from the entry assembly and dependencies.
Task Discover()Returns
- Task
Awaitable task.
GetAllHandlers()
Get all registered handlers.
IEnumerable<IReducerHandler> GetAllHandlers()Returns
- IEnumerable<IReducerHandler>
Collection of IReducerHandler.
GetClrType(ReducerId)
Get the CLR type for a specific reducer.
Type GetClrType(ReducerId reducerId)Parameters
Returns
- Type
The type.
GetFailedPartitionsFor(Type)
Get any failed partitions for a specific reducer.
Task<IEnumerable<FailedPartition>> GetFailedPartitionsFor(Type reducerType)Parameters
reducerTypeTypeType of reducer.
Returns
- Task<IEnumerable<FailedPartition>>
Collection of FailedPartition, if any.
GetFailedPartitionsFor<TReducer>()
Get any failed partitions for a specific reducer.
Task<IEnumerable<FailedPartition>> GetFailedPartitionsFor<TReducer>() where TReducer : IReducerReturns
- Task<IEnumerable<FailedPartition>>
Collection of FailedPartition, if any.
Type Parameters
TReducerType of reducer.
GetHandlerById(ReducerId)
Get all registered reducers by its identifier.
IReducerHandler GetHandlerById(ReducerId reducerId)Parameters
reducerIdReducerIdThe identifier of the reducer to get.
Returns
- IReducerHandler
IReducerHandler instance.
GetHandlerFor(Type)
Gets a specific handler by its reducer type.
IReducerHandler GetHandlerFor(Type reducerType)Parameters
reducerTypeTypeThe reducer type to get for.
Returns
GetHandlerForReadModelType(Type)
Get a specific handler for a specific model type.
IReducerHandler GetHandlerForReadModelType(Type readModelType)Parameters
readModelTypeTypeModel type to get for.
Returns
- IReducerHandler
IReducerHandler instance.
GetHandlerFor<TReducer>()
Get a specific handler for a specific reducer.
IReducerHandler GetHandlerFor<TReducer>() where TReducer : IReducerReturns
Type Parameters
TReducerType of reducer to get for.
GetStateFor<TReducer>()
Get the state of a specific reactor.
Task<ReducerState> GetStateFor<TReducer>() where TReducer : IReducerReturns
Type Parameters
TReducerType of reactor get for.
HasFor(Type)
Check if there is a reducer for a specific read model type.
bool HasFor(Type readModelType)Parameters
readModelTypeTypeThe read model type to check for.
Returns
- bool
True if it has, false if not.
HasFor<TReadModel>()
Check if there is a reducer for a specific read model type.
bool HasFor<TReadModel>()Returns
- bool
True if it has, false if not.
Type Parameters
TReadModelThe read model type to check for.
HasReducerFor(Type)
Check if there is a reducer for a specific model type.
bool HasReducerFor(Type readModelType)Parameters
readModelTypeTypeModel type to check for.
Returns
- bool
True if it has, false if not.
Register()
Register all reducers with Chronicle.
Task Register()Returns
- Task
Awaitable task.
Register<TReducer, TReadModel>()
Registers a TReducer reducer with Chronicle.
Task<IReducerHandler> Register<TReducer, TReadModel>() where TReducer : IReducerFor<TReadModel> where TReadModel : classReturns
- Task<IReducerHandler>
Awaitable task.
Type Parameters
TReducerThe reactor type.
TReadModelThe model type the reducer is for.
Replay(ReducerId)
Replay a specific reducer by its identifier.
Task Replay(ReducerId reducerId)Parameters
Returns
- Task
Awaitable task.
Replay<TReducer>()
Replay a specific reducer.
Task Replay<TReducer>() where TReducer : IReducerReturns
- Task
Awaitable task.
Type Parameters
TReducerType of reducer to replay.