Interface IReactors

Namespace

Cratis.Chronicle.Reactors

Assembly

Cratis.Chronicle.dll

Defines a system for working with Reactor registrations for the Kernel.

public interface IReactors

Extension Methods

ReactorWaitExtensions.WaitForState<TReactor>(IReactors, ObserverRunningState, TimeSpan?)

ReactorWaitExtensions.WaitForThereToBeFailedPartitions<TReactor>(IReactors, TimeSpan?)

ReactorWaitExtensions.WaitTillActive<TReactor>(IReactors, TimeSpan?)

ReactorWaitExtensions.WaitTillReachesEventSequenceNumber<TReactor>(IReactors, EventSequenceNumber, TimeSpan?)

ReactorWaitExtensions.WaitTillSubscribed<TReactor>(IReactors, TimeSpan?)

Methods

Discover()

Discover all Reactors from the entry assembly and dependencies.

Task Discover()

Returns

Task

Awaitable task.

GetFailedPartitionsFor(Type)

Get any failed partitions for a specific reactor.

Task<IEnumerable<FailedPartition>> GetFailedPartitionsFor(Type reactorType)

Parameters

reactorType Type

Type of reducer.

Returns

Task<IEnumerable<FailedPartition>>

Collection of FailedPartition, if any.

GetFailedPartitionsFor<TReactor>()

Get any failed partitions for a specific reactor.

Task<IEnumerable<FailedPartition>> GetFailedPartitionsFor<TReactor>()

Returns

Task<IEnumerable<FailedPartition>>

Collection of FailedPartition, if any.

Type Parameters

TReactor

Type of reducer.

GetHandlerById(ReactorId)

Gets a specific handler by its ReactorId.

IReactorHandler GetHandlerById(ReactorId id)

Parameters

id ReactorId

ReactorId to get for.

Returns

IReactorHandler

ReactorHandler instance.

GetHandlerFor<TReactor>()

Gets a specific handler by its TReactor type.

IReactorHandler GetHandlerFor<TReactor>() where TReactor : IReactor

Returns

IReactorHandler

ReactorHandler instance.

Type Parameters

TReactor

The reactor type.

GetStateFor<TReactor>()

Get the state of a specific reactor.

Task<ReactorState> GetStateFor<TReactor>() where TReactor : IReactor

Returns

Task<ReactorState>

ReactorState.

Type Parameters

TReactor

Type of reactor get for.

Register()

Register all Reactors with Chronicle.

Task Register()

Returns

Task

Awaitable task.

Register<TReactor>()

Registers a TReactor reactor with Chronicle.

Task<IReactorHandler> Register<TReactor>() where TReactor : IReactor

Returns

Task<IReactorHandler>

Awaitable task.

Type Parameters

TReactor

The reactor type.

Replay(ReactorId)

Replay a specific reactor by its identifier.

Task Replay(ReactorId reactorId)

Parameters

reactorId ReactorId

ReactorId to replay.

Returns

Task

Awaitable task.

Replay<TReactor>()

Replay a specific reactor.

Task Replay<TReactor>() where TReactor : IReactor

Returns

Task

Awaitable task.

Type Parameters

TReactor

Type of reactor to replay.