Interface IDurableExecutionRuntimeStateCatalog
Namespace: Cephalon.Abstractions.Execution
Assembly: Cephalon.Abstractions.dll
Exposes the operator-facing durable-execution runtime state currently reported for active streams.
public interface IDurableExecutionRuntimeStateCatalogProperties
Section titled “Properties”States
Section titled “ States”Gets the reported durable-execution state entries visible to the current runtime.
IReadOnlyList<DurableExecutionRuntimeState> States { get; }Property Value
Section titled “Property Value”IReadOnlyList<DurableExecutionRuntimeState>
Methods
Section titled “Methods”GetByBehaviorId(string)
Section titled “ GetByBehaviorId(string)”Gets the reported durable-execution state entries for one durable behavior.
IReadOnlyList<DurableExecutionRuntimeState> GetByBehaviorId(string behaviorId)Parameters
Section titled “Parameters”behaviorId string
The stable durable behavior identifier to filter by.
Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when the behavior has not reported runtime state.
GetByCompensationActionId(string)
Section titled “ GetByCompensationActionId(string)”Gets the reported durable-execution state entries that currently include the requested compensation action.
IReadOnlyList<DurableExecutionRuntimeState> GetByCompensationActionId(string compensationActionId)Parameters
Section titled “Parameters”compensationActionId string
The stable compensation-action identifier to filter by.
Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when no stream currently reports that compensation action.
GetByPendingSignalId(string)
Section titled “ GetByPendingSignalId(string)”Gets the reported durable-execution state entries that currently include the requested pending signal.
IReadOnlyList<DurableExecutionRuntimeState> GetByPendingSignalId(string signalId)Parameters
Section titled “Parameters”signalId string
The stable signal identifier to filter by.
Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when no stream currently reports that signal.
GetByPendingTimerId(string)
Section titled “ GetByPendingTimerId(string)”Gets the reported durable-execution state entries that currently include the requested pending timer.
IReadOnlyList<DurableExecutionRuntimeState> GetByPendingTimerId(string timerId)Parameters
Section titled “Parameters”timerId string
The stable timer identifier to filter by.
Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when no stream currently reports that timer.
GetBySourceModule(string)
Section titled “ GetBySourceModule(string)”Gets the reported durable-execution state entries contributed by one source module.
IReadOnlyList<DurableExecutionRuntimeState> GetBySourceModule(string sourceModuleId)Parameters
Section titled “Parameters”sourceModuleId string
The source module identifier to filter by.
Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when the module has not reported runtime state.
GetByStreamId(string)
Section titled “ GetByStreamId(string)”Gets the latest reported durable-execution state for one stream.
DurableExecutionRuntimeState? GetByStreamId(string streamId)Parameters
Section titled “Parameters”streamId string
The stable stream identifier to resolve.
Returns
Section titled “Returns”The latest reported state, or null when that stream has not reported runtime state.
GetByTransportId(string)
Section titled “ GetByTransportId(string)”Gets the reported durable-execution state entries exposed over one transport.
IReadOnlyList<DurableExecutionRuntimeState> GetByTransportId(string transportId)Parameters
Section titled “Parameters”transportId string
The stable transport identifier to filter by.
Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when none reported runtime state for that transport.
GetWithCompensationActions()
Section titled “ GetWithCompensationActions()”Gets the reported durable-execution state entries that currently expose one or more compensation actions.
IReadOnlyList<DurableExecutionRuntimeState> GetWithCompensationActions()Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when no stream currently reports compensation actions.
GetWithPendingSignals()
Section titled “ GetWithPendingSignals()”Gets the reported durable-execution state entries that currently have one or more pending signals.
IReadOnlyList<DurableExecutionRuntimeState> GetWithPendingSignals()Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when no stream currently reports pending signals.
GetWithPendingTimers()
Section titled “ GetWithPendingTimers()”Gets the reported durable-execution state entries that currently have one or more pending timers.
IReadOnlyList<DurableExecutionRuntimeState> GetWithPendingTimers()Returns
Section titled “Returns”IReadOnlyList<DurableExecutionRuntimeState>
The matching state entries, or an empty list when no stream currently reports pending timers.
TryGetByStreamId(string, out DurableExecutionRuntimeState?)
Section titled “ TryGetByStreamId(string, out DurableExecutionRuntimeState?)”Tries to get the latest reported durable-execution state for one stream.
bool TryGetByStreamId(string streamId, out DurableExecutionRuntimeState? state)Parameters
Section titled “Parameters”streamId string
The stable stream identifier to resolve.
state DurableExecutionRuntimeState?
Receives the latest reported state when the stream has reported one.