Interface IIdempotencyStore

Namespace

PatternKit.Messaging.Reliability

Assembly

PatternKit.Core.dll

Pluggable idempotency key store used by idempotent receivers and inbox processors.

public interface IIdempotencyStore

Methods

MarkCompletedAsync(string, object?, CancellationToken)

Marks a claimed key as completed and stores an optional replayable result.

ValueTask MarkCompletedAsync(string key, object? result = null, CancellationToken cancellationToken = default)

Parameters

key string

result object

cancellationToken CancellationToken

Returns

ValueTask

MarkFailedAsync(string, string?, CancellationToken)

Marks a claimed key as failed with an optional reason.

ValueTask MarkFailedAsync(string key, string? reason = null, CancellationToken cancellationToken = default)

Parameters

key string

reason string

cancellationToken CancellationToken

Returns

ValueTask

TryClaimAsync(string, CancellationToken)

Attempts to claim key for processing.

ValueTask<IdempotencyClaim> TryClaimAsync(string key, CancellationToken cancellationToken = default)

Parameters

key string

cancellationToken CancellationToken

Returns

ValueTask<IdempotencyClaim>