Class ConcurrencyLimitOptions

Namespace

Kevlar

Assembly

Kevlar.dll

Configuration for a concurrency limit (concurrency limiter) strategy: at most MaxConcurrency executions run at once, with up to QueueLimit more waiting; anything beyond that is rejected immediately.

public sealed class ConcurrencyLimitOptions

Inheritance

object

ConcurrencyLimitOptions

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Remarks

When an execution is rejected, rejection metrics are recorded and OnRejected runs and is awaited. Callback failures are reported through OnCallbackError and do not replace the rejection.

Constructors

ConcurrencyLimitOptions()

public ConcurrencyLimitOptions()

Properties

MaxConcurrency

Maximum concurrent executions. Default 10.

public int MaxConcurrency { get; set; }

Property Value

int

Name

An optional low-cardinality name used by strategy telemetry.

public string? Name { get; set; }

Property Value

string

OnRejected

Invoked and awaited when an execution is rejected. Return default from a synchronous callback.

public Func<ConcurrencyLimitRejectedEvent, ValueTask>? OnRejected { get; set; }

Property Value

Func<ConcurrencyLimitRejectedEvent, ValueTask>

QueueLimit

Maximum executions allowed to wait for a slot. Default 0 (reject immediately when full). The queue has no built-in timeout; compose a timeout outside this strategy to bound the wait.

public int QueueLimit { get; set; }

Property Value

int