io.picodata.driver.api.retry

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

java.lang.Object

io.picodata.driver.api.retry.TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory<T>

Type Parameters:

T - exception checking predicate type

All Implemented Interfaces:

RequestRetryPolicyFactory

Enclosing class:

TarantoolRequestRetryPolicies

public static final class TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory<T extends Predicate<Throwable>>
extends Object
implements RequestRetryPolicyFactory

Factory for TarantoolRequestRetryPolicies.InfiniteRetryPolicy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory.Builder<T extends Predicate<Throwable>> Builder for TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory

Constructor Summary

Constructors

Constructor and Description
InfiniteRetryPolicyFactory(long requestTimeout, long operationTimeout, long delay, T callback) Basic constructor with timeout and delay.

Method Summary

Modifier and Type	Method and Description
static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.InfiniteRetryPolicyFactory.Builder<T>	builder(T callback) Create a builder for this factory
RequestRetryPolicy	create() Instantiate a new request retry policy instance.
T	getCallback() Getter for exception handler
long	getDelay() Getter for delay
long	getOperationTimeout() Getter for operation timeout
long	getRequestTimeout() Getter for request timout

Methods inherited from class java.lang.Object

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

Constructor Detail

InfiniteRetryPolicyFactory

public InfiniteRetryPolicyFactory(long requestTimeout,
                                  long operationTimeout,
                                  long delay,
                                  T callback)

Basic constructor with timeout and delay.

Parameters:

requestTimeout - timeout for one retry attempt, in milliseconds

operationTimeout - timeout for the whole operation, in milliseconds

delay - delay between retry attempts, in milliseconds

callback - predicate checking whether the given exception may be retried

Method Detail

builder

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

Create a builder for this factory

Type Parameters:

T - exception checking callback function type

Parameters:

callback - predicate checking whether the given exception may be retried

Returns:

new builder instance

create

public RequestRetryPolicy create()

Description copied from interface: RequestRetryPolicyFactory

Instantiate a new request retry policy instance. The policy may be either stateful or stateless, so depending on that the policy may be either instantiated as a singleton or once per request.

Specified by:

create in interface RequestRetryPolicyFactory

Returns:

new policy instance

getCallback

public T getCallback()

Getter for exception handler

Returns:

exception handler

getDelay

public long getDelay()

Getter for delay

Returns:

delay in milliseconds

getRequestTimeout

public long getRequestTimeout()

Getter for request timout

Returns:

request timeout in milliseconds

getOperationTimeout

public long getOperationTimeout()

Getter for operation timeout

Returns:

operation timeout in milliseconds