io.picodata.driver.api.retry

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

java.lang.Object

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

Type Parameters:

T - exception checking predicate type

All Implemented Interfaces:

RequestRetryPolicyFactory

Enclosing class:

TarantoolRequestRetryPolicies

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

Factory for TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicy

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
AttemptsBoundRetryPolicyFactory(int numberOfAttempts, long requestTimeout, long delay, T exceptionCheck) Basic constructor with timeout and delay

Method Summary

Modifier and Type	Method and Description
static <T extends Predicate<Throwable>> TarantoolRequestRetryPolicies.AttemptsBoundRetryPolicyFactory.Builder<T>	builder(int attempts, T exceptionCheck) Create a builder for this factory
RequestRetryPolicy	create() Instantiate a new request retry policy instance.
long	getDelay() Getter for delay
T	getExceptionCheck() Getter for exception handler
int	getNumberOfAttempts() Getter for number of attempts
long	getRequestTimeout() Getter for request timeout

Methods inherited from class java.lang.Object

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

Constructor Detail

AttemptsBoundRetryPolicyFactory

public AttemptsBoundRetryPolicyFactory(int numberOfAttempts,
                                       long requestTimeout,
                                       long delay,
                                       T exceptionCheck)

Basic constructor with timeout and delay

Parameters:

numberOfAttempts - maximum number of retry attempts

requestTimeout - timeout for one retry attempt, in milliseconds

delay - delay between retry attempts, in milliseconds

exceptionCheck - predicate checking whether the given exception may be retried

Method Detail

builder

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

Create a builder for this factory

Type Parameters:

T - exception checking predicate type

Parameters:

attempts - maximum number of attempts

exceptionCheck - function 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

getNumberOfAttempts

public int getNumberOfAttempts()

Getter for number of attempts

Returns:

number of attempts

getExceptionCheck

public T getExceptionCheck()

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 timeout

Returns:

request timeout in milliseconds