Interface IAsiBackboneGovernanceOutboxClaimOutcomeStore

Namespace

AsiBackbone.Core.Outbox

Assembly

AsiBackbone.Core.dll

Defines an opt-in claim store that reports whether the current invocation applied a claimed transition.

public interface IAsiBackboneGovernanceOutboxClaimOutcomeStore : IAsiBackboneGovernanceOutboxClaimStore, IAsiBackboneGovernanceOutboxStore

Inherited Members

IAsiBackboneGovernanceOutboxClaimStore.ClaimPendingAsync(GovernanceOutboxClaimRequest, CancellationToken)

IAsiBackboneGovernanceOutboxClaimStore.ClaimRetryReadyAsync(GovernanceOutboxClaimRequest, CancellationToken)

IAsiBackboneGovernanceOutboxClaimStore.MarkClaimDeliveredAsync(GovernanceOutboxClaim, GovernanceEmissionResult, CancellationToken)

IAsiBackboneGovernanceOutboxClaimStore.MarkClaimFailedAsync(GovernanceOutboxClaim, GovernanceEmissionError, DateTimeOffset?, CancellationToken)

IAsiBackboneGovernanceOutboxClaimStore.MarkClaimDeadLetteredAsync(GovernanceOutboxClaim, GovernanceEmissionError, string, CancellationToken)

IAsiBackboneGovernanceOutboxClaimStore.SaveClaimAsync(GovernanceOutboxClaim, GovernanceOutboxEntry, CancellationToken)

IAsiBackboneGovernanceOutboxClaimStore.ReleaseClaimAsync(GovernanceOutboxClaim, string, CancellationToken)

IAsiBackboneGovernanceOutboxStore.EnqueueAsync(GovernanceEmissionEnvelope, CancellationToken)

IAsiBackboneGovernanceOutboxStore.SaveAsync(GovernanceOutboxEntry, CancellationToken)

IAsiBackboneGovernanceOutboxStore.FindByOutboxEntryIdAsync(string, CancellationToken)

IAsiBackboneGovernanceOutboxStore.FindPendingAsync(int, CancellationToken)

IAsiBackboneGovernanceOutboxStore.FindRetryReadyAsync(DateTimeOffset, int, CancellationToken)

IAsiBackboneGovernanceOutboxStore.MarkDeliveredAsync(string, GovernanceEmissionResult, CancellationToken)

IAsiBackboneGovernanceOutboxStore.MarkFailedAsync(string, GovernanceEmissionError, DateTimeOffset?, CancellationToken)

IAsiBackboneGovernanceOutboxStore.MarkDeadLetteredAsync(string, GovernanceEmissionError, string, CancellationToken)

Remarks

This contract is additive to IAsiBackboneGovernanceOutboxClaimStore. Existing convenience methods remain available for compatibility, while these methods distinguish applied transitions from stale claims, terminal no-ops, concurrency losses, and missing rows.

Methods

TryMarkClaimDeadLetteredAsync(GovernanceOutboxClaim, GovernanceEmissionError, string?, CancellationToken)

Attempts to complete a claimed entry as dead-lettered and reports whether this invocation applied the transition.

ValueTask<GovernanceOutboxClaimTransitionResult> TryMarkClaimDeadLetteredAsync(GovernanceOutboxClaim claim, GovernanceEmissionError governanceEmissionError, string? deadLetterReason = null, CancellationToken cancellationToken = default)

Parameters

claim GovernanceOutboxClaim

governanceEmissionError GovernanceEmissionError

deadLetterReason string

cancellationToken CancellationToken

Returns

ValueTask<GovernanceOutboxClaimTransitionResult>

TryMarkClaimDeliveredAsync(GovernanceOutboxClaim, GovernanceEmissionResult, CancellationToken)

Attempts to complete a claimed entry as delivered and reports whether this invocation applied the transition.

ValueTask<GovernanceOutboxClaimTransitionResult> TryMarkClaimDeliveredAsync(GovernanceOutboxClaim claim, GovernanceEmissionResult result, CancellationToken cancellationToken = default)

Parameters

claim GovernanceOutboxClaim

result GovernanceEmissionResult

cancellationToken CancellationToken

Returns

ValueTask<GovernanceOutboxClaimTransitionResult>

TryMarkClaimFailedAsync(GovernanceOutboxClaim, GovernanceEmissionError, DateTimeOffset?, CancellationToken)

Attempts to complete a claimed entry as failed or retryable failed and reports whether this invocation applied the transition.

ValueTask<GovernanceOutboxClaimTransitionResult> TryMarkClaimFailedAsync(GovernanceOutboxClaim claim, GovernanceEmissionError governanceEmissionError, DateTimeOffset? nextRetryUtc = null, CancellationToken cancellationToken = default)

Parameters

claim GovernanceOutboxClaim

governanceEmissionError GovernanceEmissionError

nextRetryUtc DateTimeOffset?

cancellationToken CancellationToken

Returns

ValueTask<GovernanceOutboxClaimTransitionResult>

TrySaveClaimAsync(GovernanceOutboxClaim, GovernanceOutboxEntry, CancellationToken)

Attempts to save a caller-produced claimed transition and reports whether this invocation applied the transition.

ValueTask<GovernanceOutboxClaimTransitionResult> TrySaveClaimAsync(GovernanceOutboxClaim claim, GovernanceOutboxEntry entry, CancellationToken cancellationToken = default)

Parameters

claim GovernanceOutboxClaim

entry GovernanceOutboxEntry

cancellationToken CancellationToken

Returns

ValueTask<GovernanceOutboxClaimTransitionResult>