io.micronaut.retry

Interface RetryState

public interface RetryState

An interface that encapsulates the current state of a Retryable operation.

Since:

1.0

Author:

graemerocher

Method Summary

Modifier and Type	Method and Description
boolean	canRetry(Throwable exception) Should a retry attempt occur.
default void	close(Throwable exception) Closes the RetryState.
int	currentAttempt()
Duration	getDelay()
int	getMaxAttempts()
Optional<Duration>	getMaxDelay()
OptionalDouble	getMultiplier()
Duration	getOverallDelay()
default RetryPredicate	getRetryPredicate()
default void	open() Opens the retry state.

Method Detail

canRetry

boolean canRetry(Throwable exception)

Should a retry attempt occur.

Parameters:

exception - The error

Returns:

True if it should

getMaxAttempts

int getMaxAttempts()

Returns:

The maximum number of attempts

currentAttempt

int currentAttempt()

Returns:

The number of the current attempt

getMultiplier

OptionalDouble getMultiplier()

Returns:

The multiplier to use between delays

getDelay

Duration getDelay()

Returns:

The delay between attempts

getOverallDelay

Duration getOverallDelay()

Returns:

The overall delay so far

getMaxDelay

Optional<Duration> getMaxDelay()

Returns:

The maximum overall delay

getRetryPredicate

default RetryPredicate getRetryPredicate()

Returns:

The retry predicate checking for includes/excludes throwable classes

open

default void open()

Opens the retry state.

close

default void close(@Nullable
                   Throwable exception)

Closes the RetryState.

Parameters:

exception - An exception if an error occurred or null if the operation completed as expected