Class ClickHouseRetryPolicy

Namespace

LinqToDB.DataProvider.ClickHouse

Assembly

linq2db.dll

Retry policy handles only following exceptions:

• Octonica client ClickHouseException with codes ClickHouseErrorCodes.InvalidConnectionState, ClickHouseErrorCodes.ConnectionClosed, ClickHouseErrorCodes.NetworkError
• MySqlConnector MySqlException.IsTransient == true (requires .NET 6+ and MySqlConnector 1.3.0 or greater)

public class ClickHouseRetryPolicy : RetryPolicyBase, IRetryPolicy

Inheritance

object

RetryPolicyBase

ClickHouseRetryPolicy

Implements

IRetryPolicy

Inherited Members

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

RetryPolicyBase.Execute(Action)

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

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

RetryPolicyBase.OnFirstExecution()

RetryPolicyBase.OnRetry()

RetryPolicyBase.RandomFactor

RetryPolicyBase.ExponentialBase

RetryPolicyBase.Coefficient

RetryPolicyBase.ExceptionsEncountered

RetryPolicyBase.Random

RetryPolicyBase.MaxRetryCount

RetryPolicyBase.MaxRetryDelay

RetryPolicyBase.Suspended

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

Sql.IsDistinctFrom<T>(T, T)

Sql.IsNotDistinctFrom<T>(T, T)

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

SqlExtensions.In<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, T)

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

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

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

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

Constructors

ClickHouseRetryPolicy()

Creates a new instance of ClickHouseRetryPolicy.

public ClickHouseRetryPolicy()

ClickHouseRetryPolicy(int)

Creates a new instance of ClickHouseRetryPolicy.

public ClickHouseRetryPolicy(int maxRetryCount)

Parameters

maxRetryCount int

The maximum number of retry attempts.

ClickHouseRetryPolicy(int, TimeSpan, double, double, TimeSpan, ICollection<int>?)

Creates a new instance of ClickHouseRetryPolicy.

public ClickHouseRetryPolicy(int maxRetryCount, TimeSpan maxRetryDelay, double randomFactor, double exponentialBase, TimeSpan coefficient, ICollection<int>? errorNumbersToAdd)

Parameters

maxRetryCount int

The maximum number of retry attempts.

maxRetryDelay TimeSpan

The maximum delay in milliseconds between retries.

randomFactor double

The maximum random factor.

exponentialBase double

The base for the exponential function used to compute the delay between retries.

coefficient TimeSpan

The coefficient for the exponential function used to compute the delay between retries.

errorNumbersToAdd ICollection<int>

Additional SQL error numbers that should be considered transient.

Methods

GetNextDelay(Exception)

protected override TimeSpan? GetNextDelay(Exception lastException)

Parameters

lastException Exception

Returns

TimeSpan?

ShouldRetryOn(Exception)

protected override bool ShouldRetryOn(Exception exception)

Parameters

exception Exception

Returns

bool