com.amazonaws.services.dynamodbv2.nio.http

Class ExecutionContext

java.lang.Object

com.amazonaws.services.dynamodbv2.nio.http.ExecutionContext

@NotThreadSafe
public class ExecutionContext
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private com.amazonaws.retry.internal.AuthErrorRetryStrategy	authErrorRetryStrategy An internal retry strategy for auth errors.
private AmazonWebserviceClient	awsClient
private com.amazonaws.util.AWSRequestMetrics	awsRequestMetrics
private com.amazonaws.http.timers.client.ClientExecutionAbortTrackerTask	clientExecutionTrackerTask
private com.amazonaws.auth.AWSCredentialsProvider	credentialsProvider Optional credentials to enable the runtime layer to handle signing requests (and resigning on retries).
private List<com.amazonaws.handlers.RequestHandler2>	requestHandler2s
private boolean	retryCapacityConsumed

Constructor Summary

Constructors

Constructor and Description
ExecutionContext() For testing purposes.
ExecutionContext(boolean isMetricEnabled) For testing purposes.
ExecutionContext(List<com.amazonaws.handlers.RequestHandler2> requestHandler2s, boolean isMetricEnabled, AmazonWebserviceClient awsClient)

Method Summary

Modifier and Type	Method and Description
com.amazonaws.retry.internal.AuthErrorRetryStrategy	getAuthErrorRetryStrategy() Returns the retry strategy for auth errors.
protected AmazonWebserviceClient	getAwsClient()
com.amazonaws.util.AWSRequestMetrics	getAwsRequestMetrics()
com.amazonaws.http.timers.client.ClientExecutionAbortTrackerTask	getClientExecutionTrackerTask()
com.amazonaws.auth.AWSCredentialsProvider	getCredentialsProvider() Returns the credentials provider used for fetching the credentials.
List<com.amazonaws.handlers.RequestHandler2>	getRequestHandler2s()
com.amazonaws.auth.Signer	getSignerByURI(URI uri) Returns the signer for the given uri.
void	markRetryCapacityConsumed() Marks that a retry during this request lifecycle has consumed retry capacity.
boolean	retryCapacityConsumed() Returns whether retry capacity was consumed during this request lifecycle.
void	setAuthErrorRetryStrategy(com.amazonaws.retry.internal.AuthErrorRetryStrategy authErrorRetryStrategy) Sets the optional auth error retry strategy for this request execution.
void	setClientExecutionTrackerTask(com.amazonaws.http.timers.client.ClientExecutionAbortTrackerTask clientExecutionTrackerTask)
void	setCredentialsProvider(com.amazonaws.auth.AWSCredentialsProvider credentialsProvider) Sets the credentials provider used for fetching the credentials.
void	setSigner(com.amazonaws.auth.Signer signer) There is in general no need to set the signer in the execution context, since the signer for each request may differ depending on the URI of the request.

Methods inherited from class java.lang.Object

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

Field Detail

awsRequestMetrics

private final com.amazonaws.util.AWSRequestMetrics awsRequestMetrics

requestHandler2s

private final List<com.amazonaws.handlers.RequestHandler2> requestHandler2s

awsClient

private final AmazonWebserviceClient awsClient

retryCapacityConsumed

private boolean retryCapacityConsumed

credentialsProvider

private com.amazonaws.auth.AWSCredentialsProvider credentialsProvider

Optional credentials to enable the runtime layer to handle signing requests (and resigning on retries).

authErrorRetryStrategy

private com.amazonaws.retry.internal.AuthErrorRetryStrategy authErrorRetryStrategy

An internal retry strategy for auth errors. This is currently only used by the S3 client for auto-resolving V4-required regions.

clientExecutionTrackerTask

private com.amazonaws.http.timers.client.ClientExecutionAbortTrackerTask clientExecutionTrackerTask

Constructor Detail

ExecutionContext

public ExecutionContext(boolean isMetricEnabled)

For testing purposes.

ExecutionContext

public ExecutionContext()

For testing purposes.

ExecutionContext

public ExecutionContext(List<com.amazonaws.handlers.RequestHandler2> requestHandler2s,
                        boolean isMetricEnabled,
                        AmazonWebserviceClient awsClient)

Method Detail

getRequestHandler2s

public List<com.amazonaws.handlers.RequestHandler2> getRequestHandler2s()

getAwsRequestMetrics

public com.amazonaws.util.AWSRequestMetrics getAwsRequestMetrics()

getAwsClient

protected AmazonWebserviceClient getAwsClient()

setSigner

public void setSigner(com.amazonaws.auth.Signer signer)

There is in general no need to set the signer in the execution context, since the signer for each request may differ depending on the URI of the request. The exception is S3 where the signer is currently determined only when the S3 client is constructed. Hence the need for this method. We may consider supporting a per request level signer determination for S3 later on.

retryCapacityConsumed

public boolean retryCapacityConsumed()

Returns whether retry capacity was consumed during this request lifecycle. This can be inspected to determine whether capacity should be released if a retry succeeds.

Returns:

true if retry capacity was consumed

markRetryCapacityConsumed

public void markRetryCapacityConsumed()

Marks that a retry during this request lifecycle has consumed retry capacity. This is inspected when determining if capacity should be released if a retry succeeds.

getSignerByURI

public com.amazonaws.auth.Signer getSignerByURI(URI uri)

Returns the signer for the given uri. Note S3 in particular overrides this method.

setCredentialsProvider

public void setCredentialsProvider(com.amazonaws.auth.AWSCredentialsProvider credentialsProvider)

Sets the credentials provider used for fetching the credentials. The credentials fetched is used for signing the request. If there is no credential provider, then the runtime will not attempt to sign (or resign on retries) requests.

Parameters:

credentialsProvider - the credentials provider to fetch AWSCredentials

getCredentialsProvider

public com.amazonaws.auth.AWSCredentialsProvider getCredentialsProvider()

Returns the credentials provider used for fetching the credentials. The credentials fetched is used for signing the request. If there is no credential provider, then the runtime will not attempt to sign (or resign on retries) requests.

Returns:

the credentials provider to fetch AWSCredentials

getAuthErrorRetryStrategy

public com.amazonaws.retry.internal.AuthErrorRetryStrategy getAuthErrorRetryStrategy()

Returns the retry strategy for auth errors. This is currently only used by the S3 client for auto-resolving sigv4-required regions.

Note that this will be checked BEFORE the HTTP client consults the user-specified RetryPolicy. i.e. if the configured AuthErrorRetryStrategy says the request should be retried, the retry will be performed internally and the effect is transparent to the user's RetryPolicy.

setAuthErrorRetryStrategy

public void setAuthErrorRetryStrategy(com.amazonaws.retry.internal.AuthErrorRetryStrategy authErrorRetryStrategy)

Sets the optional auth error retry strategy for this request execution.

See Also:

getAuthErrorRetryStrategy()

getClientExecutionTrackerTask

public com.amazonaws.http.timers.client.ClientExecutionAbortTrackerTask getClientExecutionTrackerTask()

setClientExecutionTrackerTask

public void setClientExecutionTrackerTask(com.amazonaws.http.timers.client.ClientExecutionAbortTrackerTask clientExecutionTrackerTask)