io.picodata.driver.api.retry

Class TarantoolRequestRetryPolicies

java.lang.Object

io.picodata.driver.api.retry.TarantoolRequestRetryPolicies

public final class TarantoolRequestRetryPolicies
extends Object

Class-container for built-in request retry policies

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicy<T extends Predicate<Throwable>> Retry policy that accepts a maximum number of attempts and an exception checking predicate.
static class	TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicyFactory<T extends Predicate<Throwable>> Factory for TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicy
static class	TarantoolRequestRetryPolicies.InfiniteRetryPolicy<T extends Predicate<Throwable>> Retry policy that performs unbounded number of attempts.
static class	TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory<T extends Predicate<Throwable>> Factory for TarantoolRequestRetryPolicies.InfiniteRetryPolicy

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_ONE_HOUR_TIMEOUT
static Predicate<Throwable>	retryAll
static Predicate<Throwable>	retryNone

Method Summary

Modifier and Type	Method and Description
static TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicyFactory.Builder<Predicate<Throwable>>	byNumberOfAttempts(int numberOfAttempts) Create a factory for retry policy bound by retry attempts.
static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicyFactory.Builder<T>	byNumberOfAttempts(int numberOfAttempts, T exceptionCheck) Create a factory for retry policy bound by retry attempts
static ScheduledExecutorService	getTimeoutScheduler() Get timeout scheduler instance.
static Predicate<Throwable>	retryNetworkErrors() Check all known network exceptions
static Predicate<Throwable>	retryTarantoolNoSuchProcedureErrors() Check TarantoolNoSuchProcedureException
static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory.Builder<T>	unbound() Create a factory for retry policy with unbounded number of attempts.
static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory.Builder<T>	unbound(T exceptionCheck) Create a factory for retry policy with unbounded number of attempts

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

retryAll

public static final Predicate<Throwable> retryAll

retryNone

public static final Predicate<Throwable> retryNone

DEFAULT_ONE_HOUR_TIMEOUT

public static final long DEFAULT_ONE_HOUR_TIMEOUT

Method Detail

retryNetworkErrors

public static Predicate<Throwable> retryNetworkErrors()

Check all known network exceptions

Returns:

predicate for checking all network exceptions

retryTarantoolNoSuchProcedureErrors

public static Predicate<Throwable> retryTarantoolNoSuchProcedureErrors()

Check TarantoolNoSuchProcedureException

Returns:

predicate for checking TarantoolNoSuchProcedureException

byNumberOfAttempts

public static TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicyFactory.Builder<Predicate<Throwable>> byNumberOfAttempts(int numberOfAttempts)

Create a factory for retry policy bound by retry attempts. The retry will be performed on any known network exceptions.

Parameters:

numberOfAttempts - maximum number of retries, zero value means no retries

Returns:

new factory instance

byNumberOfAttempts

public static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicyFactory.Builder<T> byNumberOfAttempts(int numberOfAttempts,
                                                                                                                                           T exceptionCheck)

Create a factory for retry policy bound by retry attempts

Type Parameters:

T - exception checking predicate type

Parameters:

numberOfAttempts - maximum number of retries, zero value means no retries

exceptionCheck - predicate, checking the given exception whether the request may be retried

Returns:

new factory instance

unbound

public static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory.Builder<T> unbound()

Create a factory for retry policy with unbounded number of attempts. retryNetworkErrors() is used for checking exceptions by default.

Type Parameters:

T - exception checking predicate type

Returns:

new factory instance

unbound

public static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory.Builder<T> unbound(T exceptionCheck)

Create a factory for retry policy with unbounded number of attempts

Type Parameters:

T - exception checking predicate type

Parameters:

exceptionCheck - predicate, checking the given exception whether the request may be retried

Returns:

new factory instance

getTimeoutScheduler

public static ScheduledExecutorService getTimeoutScheduler()

Get timeout scheduler instance.

Returns:

scheduler instance