Class YdbRetryPolicy

Namespace

LinqToDB.Internal.DataProvider.Ydb

Assembly

linq2db.dll

YDB-specific retry policy implementation. Implements official YDB retry strategies such as Full Jitter and Equal Jitter, with different backoff timings depending on status codes. Based on the retry logic from the YDB SDK (YdbRetryPolicy + YdbRetryPolicyConfig).

public sealed class YdbRetryPolicy : RetryPolicyBase, IRetryPolicy

Inheritance

object

RetryPolicyBase

YdbRetryPolicy

Implements

IRetryPolicy

Inherited Members

RetryPolicyBase.RandomFactor

RetryPolicyBase.ExponentialBase

RetryPolicyBase.Coefficient

RetryPolicyBase.Execute<TResult>(Func<TResult>)

RetryPolicyBase.Execute(Action)

RetryPolicyBase.ExecuteAsync<TResult>(Func<CancellationToken, Task<TResult>>, CancellationToken)

RetryPolicyBase.ExecuteAsync(Func<CancellationToken, Task>, CancellationToken)

Extension Methods

Sql.IsDistinctFrom<T>(T, T)

Sql.IsNotDistinctFrom<T>(T, T)

SqlExtensions.In<T>(T, T, T)

SqlExtensions.In<T>(T, T, T, T)

SqlExtensions.In<T>(T, params T[])

SqlExtensions.In<T>(T, IEnumerable<T>)

SqlExtensions.In<T>(T, IQueryable<T>)

SqlExtensions.NotIn<T>(T, T, T)

SqlExtensions.NotIn<T>(T, T, T, T)

SqlExtensions.NotIn<T>(T, params T[])

SqlExtensions.NotIn<T>(T, IEnumerable<T>)

SqlExtensions.NotIn<T>(T, IQueryable<T>)

Constructors

YdbRetryPolicy()

Default constructor — fully matches the default settings from YDB SDK.

public YdbRetryPolicy()

YdbRetryPolicy(int, int, int, int, int, bool)

Extended constructor (can be used together with RetryPolicyOptions if desired). Base class parameters are not critical since we completely override the delay calculation logic.

public YdbRetryPolicy(int maxAttempts, int fastBackoffBaseMs, int slowBackoffBaseMs, int fastCapBackoffMs, int slowCapBackoffMs, bool enableRetryIdempotence)

Parameters

maxAttempts int

fastBackoffBaseMs int

slowBackoffBaseMs int

fastCapBackoffMs int

slowCapBackoffMs int

enableRetryIdempotence bool

Methods

GetNextDelay(Exception)

Calculates the next retry delay based on the last exception and retry attempt count.

protected override TimeSpan? GetNextDelay(Exception lastException)

Parameters

lastException Exception

Returns

TimeSpan?

ShouldRetryOn(Exception)

Determines if the given exception is retryable according to YDB rules.

protected override bool ShouldRetryOn(Exception exception)

Parameters

exception Exception

Returns

bool