Class DaprResiliencePipeline

Namespace

Virtufin.WorkManager.Services

Assembly

Virtufin.WorkManager.dll

Provides resilience policies for Dapr operations with retry and circuit breaker. Constants are configurable via DaprResilienceOptions (env-var-driven).

public sealed class DaprResiliencePipeline

Inheritance

object

DaprResiliencePipeline

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

DaprResiliencePipeline(ILogger<DaprResiliencePipeline>, DaprResilienceOptions)

Creates a new DaprResiliencePipeline with the supplied options.

public DaprResiliencePipeline(ILogger<DaprResiliencePipeline> logger, DaprResilienceOptions options)

Parameters

logger ILogger<DaprResiliencePipeline>

options DaprResilienceOptions

Properties

CircuitBroken

Whether the Dapr circuit breaker is currently open.

public bool CircuitBroken { get; }

Property Value

bool

Methods

ExecuteAsync(Func<CancellationToken, Task>, CancellationToken)

Executes a void Dapr operation with retry and circuit breaker resilience.

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

Parameters

action Func<CancellationToken, Task>

cancellationToken CancellationToken

Returns

Task

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

Executes a Dapr operation with retry and circuit breaker resilience.

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