Class WorkerProcessingRetryPipeline

Namespace

Virtufin.WorkManager.Services

Assembly

Virtufin.WorkManager.dll

Polly-based retry pipeline for worker business-logic processing failures, as distinct from DaprResiliencePipeline (which wraps Dapr/Gateway infra calls). Exhausting all attempts lets the caller's exception propagate so it can dead-letter the message -- see WorkerProcessingRetryOptions for why this exists as its own pipeline.

public sealed class WorkerProcessingRetryPipeline

Inheritance

object

WorkerProcessingRetryPipeline

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

WorkerProcessingRetryPipeline(ILogger<WorkerProcessingRetryPipeline>, WorkerProcessingRetryOptions)

public WorkerProcessingRetryPipeline(ILogger<WorkerProcessingRetryPipeline> logger, WorkerProcessingRetryOptions options)

Parameters

logger ILogger<WorkerProcessingRetryPipeline>

options WorkerProcessingRetryOptions

Methods

ExecuteAsync<T>(Func<CancellationToken, Task<T>>, CancellationToken)

Executes a worker-processing operation with retry. Throws the last exception once RetryAttempts is exhausted -- callers are expected to dead-letter the message on that final failure rather than let it propagate further.

public Task<T> ExecuteAsync<T>(Func<CancellationToken, Task<T>> action, CancellationToken cancellationToken)

Parameters

action Func<CancellationToken, Task<T>>

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T