Package io.tarantool.driver.api.retry

Class TarantoolRequestRetryPolicies.InfiniteRetryPolicy<T extends Predicate<Throwable>>

java.lang.Object

io.tarantool.driver.api.retry.TarantoolRequestRetryPolicies.InfiniteRetryPolicy<T>

Type Parameters:

T - exception checking callback function type

All Implemented Interfaces:

RequestRetryPolicy

Enclosing class:

TarantoolRequestRetryPolicies

public static final class TarantoolRequestRetryPolicies.InfiniteRetryPolicy<T extends Predicate<Throwable>>
extends Object
implements RequestRetryPolicy

Retry policy that performs unbounded number of attempts. If the exception check passes, the policy returns true.

Constructor Summary

Constructors

Constructor	Description
InfiniteRetryPolicy(long requestTimeout, long operationTimeout, long delay, T exceptionCheck)	Basic constructor

Method Summary

Modifier and Type	Method	Description
boolean	canRetryRequest(Throwable throwable)	A callback called when the request ends with an exception.
long	getOperationTimeout()
long	getRequestTimeout()	Get timeout value for one retry attempt.
<R> CompletableFuture<R>	wrapOperation(Supplier<CompletableFuture<R>> operation, Executor executor)	Wrap a generic operation taking an arbitrary number of arguments and returning a CompletableFuture.

Methods inherited from class java.lang.Object

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

Constructor Detail

InfiniteRetryPolicy

public InfiniteRetryPolicy(long requestTimeout,
                           long operationTimeout,
                           long delay,
                           T exceptionCheck)

Basic constructor

Parameters:

requestTimeout - timeout for one retry attempt, in milliseconds

operationTimeout - timeout for the whole operation, in milliseconds

delay - delay between attempts, in milliseconds

exceptionCheck - predicate checking whether the given exception may be retried

Method Detail

canRetryRequest

public boolean canRetryRequest(Throwable throwable)

Description copied from interface: RequestRetryPolicy

A callback called when the request ends with an exception. Should return true if and only if the request may be performed again (e.g. it is a timeout exception and it indicates only that the current server is overloaded). This may depend not only on the exception type, but also on the other conditions like the allowed number of retries or the maximum request execution time.

Effective use of the retry policies may be achieved by combining them with multiple server connections and a ConnectionSelectionStrategy.

Specified by:

canRetryRequest in interface RequestRetryPolicy

Parameters:

throwable - exception a request failed with

Returns:

true if the request may be retried

getRequestTimeout

public long getRequestTimeout()

Description copied from interface: RequestRetryPolicy

Get timeout value for one retry attempt. The default value is 1 hour.

Specified by:

getRequestTimeout in interface RequestRetryPolicy

Returns:

timeout value (ms), should be greater or equal to 0

getOperationTimeout

public long getOperationTimeout()

wrapOperation

public <R> CompletableFuture<R> wrapOperation(Supplier<CompletableFuture<R>> operation,
                                              Executor executor)

Description copied from interface: RequestRetryPolicy

Wrap a generic operation taking an arbitrary number of arguments and returning a CompletableFuture. Each operation attempt is limited with a timeout returned by RequestRetryPolicy.getRequestTimeout(). See TarantoolRequestRetryPolicies.InfiniteRetryPolicy for example of implementation.

Specified by:

wrapOperation in interface RequestRetryPolicy

Type Parameters:

R - operation result type

Parameters:

operation - supplier for the operation to perform. Must return a new operation instance

executor - executor in which the retry callbacks will be scheduled

Returns:

CompletableFuture with the same type as the operation result type