Package software.amazon.awssdk.retries.internal

Class DefaultAdaptiveRetryStrategy

java.lang.Object

software.amazon.awssdk.retries.internal.BaseRetryStrategy

software.amazon.awssdk.retries.internal.DefaultAdaptiveRetryStrategy

All Implemented Interfaces:

AutoCloseable, AdaptiveRetryStrategy, RetryStrategy, DefaultAwareRetryStrategy, SdkAutoCloseable

@SdkInternalApi
public final class DefaultAdaptiveRetryStrategy
extends BaseRetryStrategy
implements AdaptiveRetryStrategy

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultAdaptiveRetryStrategy.Builder

Field Summary

Fields inherited from class software.amazon.awssdk.retries.internal.BaseRetryStrategy

backoffStrategy, circuitBreakerEnabled, defaultsAdded, exceptionCost, log, maxAttempts, retryPredicates, throttlingBackoffStrategy, throttlingExceptionCost, tokenBucketStore, treatAsThrottling, useClientDefaults

Method Summary

Modifier and Type	Method	Description
AcquireInitialTokenResponse	acquireInitialToken(AcquireInitialTokenRequest request)	This method implements the logic of RetryStrategy.acquireInitialToken(AcquireInitialTokenRequest).
CompletableFuture<AcquireInitialTokenResponse>	acquireInitialTokenAsync(AcquireInitialTokenRequest request)
static DefaultAdaptiveRetryStrategy.Builder	builder()	Create a new AdaptiveRetryStrategy.Builder.
void	close()
RefreshRetryTokenResponse	refreshRetryToken(RefreshRetryTokenRequest request)	This method implements the logic of RetryStrategy.refreshRetryToken(RefreshRetryTokenRequest).
CompletableFuture<RefreshRetryTokenResponse>	refreshRetryTokenAsync(RefreshRetryTokenRequest request)
DefaultAdaptiveRetryStrategy.Builder	toBuilder()
protected void	updateStateForRetry(RefreshRetryTokenRequest request)	Called inside BaseRetryStrategy.refreshRetryToken(software.amazon.awssdk.retries.api.RefreshRetryTokenRequest) to allow extending classes to update their internal state before retrying a request.
protected void	updateStateForSuccess(DefaultRetryToken token)	Called inside BaseRetryStrategy.recordSuccess(software.amazon.awssdk.retries.api.RecordSuccessRequest) to allow extending classes to update their internal state after a successful request.

Methods inherited from class software.amazon.awssdk.retries.internal.BaseRetryStrategy

addDefaults, computeAcquireFailureBackoff, computeBackoff, computeInitialBackoff, exceptionCost, hasRetryPredicates, logAcquireInitialToken, logRefreshTokenSuccess, maxAttempts, recordSuccess, refreshTokenOrThrow, retryPredicates, shouldAddDefaults, toString, useClientDefaults

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.awssdk.retries.api.RetryStrategy

maxAttempts, recordSuccess, useClientDefaults

Method Details

acquireInitialToken

public AcquireInitialTokenResponse acquireInitialToken(AcquireInitialTokenRequest request)

Description copied from class: BaseRetryStrategy

This method implements the logic of RetryStrategy.acquireInitialToken(AcquireInitialTokenRequest).

Specified by:

acquireInitialToken in interface RetryStrategy

Overrides:

acquireInitialToken in class BaseRetryStrategy

See Also:

• RetryStrategy.acquireInitialToken(AcquireInitialTokenRequest)

refreshRetryToken

public RefreshRetryTokenResponse refreshRetryToken(RefreshRetryTokenRequest request)

Description copied from class: BaseRetryStrategy

This method implements the logic of RetryStrategy.refreshRetryToken(RefreshRetryTokenRequest).

Specified by:

refreshRetryToken in interface RetryStrategy

Overrides:

refreshRetryToken in class BaseRetryStrategy

See Also:

• RetryStrategy.refreshRetryToken(RefreshRetryTokenRequest)

acquireInitialTokenAsync

public CompletableFuture<AcquireInitialTokenResponse> acquireInitialTokenAsync(AcquireInitialTokenRequest request)

Specified by:

acquireInitialTokenAsync in interface RetryStrategy

refreshRetryTokenAsync

public CompletableFuture<RefreshRetryTokenResponse> refreshRetryTokenAsync(RefreshRetryTokenRequest request)

Specified by:

refreshRetryTokenAsync in interface RetryStrategy

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RetryStrategy

Specified by:

close in interface SdkAutoCloseable

updateStateForRetry

protected void updateStateForRetry(RefreshRetryTokenRequest request)

Description copied from class: BaseRetryStrategy

Called inside BaseRetryStrategy.refreshRetryToken(software.amazon.awssdk.retries.api.RefreshRetryTokenRequest) to allow extending classes to update their internal state before retrying a request.

Overrides:

updateStateForRetry in class BaseRetryStrategy

updateStateForSuccess

protected void updateStateForSuccess(DefaultRetryToken token)

Description copied from class: BaseRetryStrategy

Called inside BaseRetryStrategy.recordSuccess(software.amazon.awssdk.retries.api.RecordSuccessRequest) to allow extending classes to update their internal state after a successful request.

Overrides:

updateStateForSuccess in class BaseRetryStrategy

toBuilder

public DefaultAdaptiveRetryStrategy.Builder toBuilder()

Specified by:

toBuilder in interface AdaptiveRetryStrategy

Specified by:

toBuilder in interface RetryStrategy

builder

public static DefaultAdaptiveRetryStrategy.Builder builder()

Description copied from interface: AdaptiveRetryStrategy

Create a new AdaptiveRetryStrategy.Builder.

Example Usage

 AdaptiveRetryStrategy retryStrategy =
     AdaptiveRetryStrategy.builder()
                          .retryOnExceptionInstanceOf(IllegalArgumentException.class)
                          .retryOnExceptionInstanceOf(IllegalStateException.class)
                          .build();