| Modifier and Type | Method and Description |
|---|---|
SdkHttpFullRequest |
Aws4UnsignedPayloadSigner.sign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
protected <B extends Aws4PresignerParams.Builder> |
AbstractAws4Signer.extractPresignerParams(B builder,
ExecutionAttributes executionAttributes) |
protected <B extends Aws4SignerParams.Builder> |
AbstractAws4Signer.extractSignerParams(B paramsBuilder,
ExecutionAttributes executionAttributes) |
SdkHttpFullRequest |
BaseAws4Signer.presign(SdkHttpFullRequest requestToSign,
ExecutionAttributes executionAttributes)
Deprecated.
|
SdkHttpFullRequest |
AbstractAwsS3V4Signer.presign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes) |
SdkHttpFullRequest |
BaseAws4Signer.sign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes)
Deprecated.
|
SdkHttpFullRequest |
AbstractAwsS3V4Signer.sign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
static SigningMethod |
SignerMethodResolver.resolveSigningMethodUsed(Signer signer,
ExecutionAttributes executionAttributes,
AwsCredentials credentials)
The signing method can be Header-Auth, streaming-signing auth or Unsigned-payload.
|
| Modifier and Type | Method and Description |
|---|---|
static software.amazon.awssdk.crt.auth.credentials.Credentials |
SigningUtils.buildCredentials(ExecutionAttributes executionAttributes) |
software.amazon.awssdk.crt.auth.signing.AwsSigningConfig |
SigningConfigProvider.createChunkedSigningConfig(ExecutionAttributes executionAttributes) |
software.amazon.awssdk.crt.auth.signing.AwsSigningConfig |
SigningConfigProvider.createCrtPresigningConfig(ExecutionAttributes executionAttributes) |
software.amazon.awssdk.crt.auth.signing.AwsSigningConfig |
SigningConfigProvider.createCrtSigningConfig(ExecutionAttributes executionAttributes) |
software.amazon.awssdk.crt.auth.signing.AwsSigningConfig |
SigningConfigProvider.createS3CrtPresigningConfig(ExecutionAttributes executionAttributes) |
software.amazon.awssdk.crt.auth.signing.AwsSigningConfig |
SigningConfigProvider.createS3CrtSigningConfig(ExecutionAttributes executionAttributes) |
static Clock |
SigningUtils.getSigningClock(ExecutionAttributes executionAttributes) |
SdkHttpFullRequest |
DefaultAwsCrtV4aSigner.presign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes) |
SdkHttpFullRequest |
DefaultAwsCrtS3V4aSigner.presign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes) |
SdkHttpFullRequest |
DefaultAwsCrtV4aSigner.sign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes) |
SdkHttpFullRequest |
DefaultAwsCrtS3V4aSigner.sign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
Optional<AsyncRequestBody> |
EventStreamInitialRequestInterceptor.modifyAsyncHttpContent(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
SdkHttpRequest |
EventStreamInitialRequestInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
Throwable |
HelpfulUnknownHostExceptionInterceptor.modifyException(Context.FailedExecution context,
ExecutionAttributes executionAttributes) |
Throwable |
GlobalServiceExecutionInterceptor.modifyException(Context.FailedExecution context,
ExecutionAttributes executionAttributes) |
SdkHttpRequest |
TraceIdExecutionInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
static InterceptorContext |
AwsExecutionContextBuilder.runInitialInterceptors(InterceptorContext interceptorContext,
ExecutionAttributes executionAttributes,
ExecutionInterceptorChain executionInterceptorChain)
Finalize
SdkRequest by running beforeExecution and modifyRequest interceptors. |
| Modifier and Type | Method and Description |
|---|---|
void |
TokenAuthorizationStrategy.addCredentialsToExecutionAttributes(ExecutionAttributes executionAttributes)
Deprecated.
Add credentials to be used by the signer in later stages.
|
void |
AwsCredentialsAuthorizationStrategy.addCredentialsToExecutionAttributes(ExecutionAttributes executionAttributes)
Deprecated.
Add credentials to be used by the signer in later stages.
|
void |
AuthorizationStrategy.addCredentialsToExecutionAttributes(ExecutionAttributes executionAttributes)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
SignerOverrideUtils.isSignerOverridden(SdkRequest request,
ExecutionAttributes executionAttributes) |
static SdkRequest |
SignerOverrideUtils.overrideSignerIfNotOverridden(SdkRequest request,
ExecutionAttributes executionAttributes,
Signer signer)
Deprecated.
No longer used by modern clients after migration to reference architecture
|
static SdkRequest |
SignerOverrideUtils.overrideSignerIfNotOverridden(SdkRequest request,
ExecutionAttributes executionAttributes,
Supplier<Signer> signer)
Deprecated.
No longer used by modern clients after migration to reference architecture
|
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
RequestOverrideConfiguration.executionAttributes()
Returns the additional execution attributes to be added to this request.
|
ExecutionAttributes |
RequestOverrideConfiguration.Builder.executionAttributes() |
ExecutionAttributes |
RequestOverrideConfiguration.BuilderImpl.executionAttributes() |
| Modifier and Type | Method and Description |
|---|---|
B |
RequestOverrideConfiguration.Builder.executionAttributes(ExecutionAttributes executionAttributes)
Sets the additional execution attributes collection for this request.
|
B |
RequestOverrideConfiguration.BuilderImpl.executionAttributes(ExecutionAttributes executionAttributes) |
void |
RequestOverrideConfiguration.BuilderImpl.setExecutionAttributes(ExecutionAttributes executionAttributes) |
| Modifier and Type | Field and Description |
|---|---|
static SdkClientOption<ExecutionAttributes> |
SdkClientOption.EXECUTION_ATTRIBUTES
Option to specify additional execution attributes to each client call.
|
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
ClientOverrideConfiguration.executionAttributes()
Returns the additional execution attributes to be added for this client.
|
ExecutionAttributes |
ClientOverrideConfiguration.Builder.executionAttributes() |
| Modifier and Type | Method and Description |
|---|---|
ClientOverrideConfiguration.Builder |
ClientOverrideConfiguration.Builder.executionAttributes(ExecutionAttributes executionAttributes)
Sets the additional execution attributes collection for this client.
|
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
ClientExecutionParams.executionAttributes() |
| Modifier and Type | Method and Description |
|---|---|
T |
AttachHttpMetadataResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
ExecutionContext.executionAttributes() |
| Modifier and Type | Method and Description |
|---|---|
ExecutionContext.Builder |
ExecutionContext.Builder.executionAttributes(ExecutionAttributes executionAttributes) |
T |
MetricCollectingHttpResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
T |
HttpResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes)
Accepts an HTTP response object, and returns an object of type T.
|
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
ExecutionAttributes.Builder.build() |
ExecutionAttributes |
ExecutionAttributes.copy() |
ExecutionAttributes |
ExecutionAttributes.merge(ExecutionAttributes lowerPrecedenceExecutionAttributes)
Merge attributes of a higher precedence into the current lower precedence collection.
|
<U> ExecutionAttributes |
ExecutionAttributes.putAttribute(ExecutionAttribute<U> attribute,
U value)
Update or set the provided attribute in this collection of attributes.
|
<U> ExecutionAttributes |
ExecutionAttributes.putAttributeIfAbsent(ExecutionAttribute<U> attribute,
U value)
Set the provided attribute in this collection of attributes if it does not already exist in the collection.
|
static ExecutionAttributes |
ExecutionAttributes.unmodifiableExecutionAttributes(ExecutionAttributes attributes) |
| Modifier and Type | Method and Description |
|---|---|
void |
ExecutionInterceptorChain.afterExecution(Context.AfterExecution context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.afterExecution(Context.AfterExecution context,
ExecutionAttributes executionAttributes)
Read the finalized
SdkResponse as it will be returned by the client invocation. |
void |
ExecutionInterceptorChain.afterMarshalling(Context.AfterMarshalling context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.afterMarshalling(Context.AfterMarshalling context,
ExecutionAttributes executionAttributes)
Read the marshalled HTTP request, before it is modified by other interceptors.
|
void |
ExecutionInterceptorChain.afterTransmission(Context.AfterTransmission context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.afterTransmission(Context.AfterTransmission context,
ExecutionAttributes executionAttributes)
Read the HTTP response as it was returned by the HTTP client, before it is modified by other interceptors.
|
void |
ExecutionInterceptorChain.afterUnmarshalling(Context.AfterUnmarshalling context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.afterUnmarshalling(Context.AfterUnmarshalling context,
ExecutionAttributes executionAttributes)
Read the
SdkResponse as it was returned by the unmarshaller, before it is modified by other interceptors. |
void |
ExecutionInterceptorChain.beforeExecution(Context.BeforeExecution context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.beforeExecution(Context.BeforeExecution context,
ExecutionAttributes executionAttributes)
Read a request that has been given to a service client before it is modified by other interceptors.
|
void |
ExecutionInterceptorChain.beforeMarshalling(Context.BeforeMarshalling context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.beforeMarshalling(Context.BeforeMarshalling context,
ExecutionAttributes executionAttributes)
Read the finalized request as it will be given to the marshaller to be converted into an
SdkHttpFullRequest. |
void |
ExecutionInterceptorChain.beforeTransmission(Context.BeforeTransmission context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.beforeTransmission(Context.BeforeTransmission context,
ExecutionAttributes executionAttributes)
Read the finalized HTTP request as it will be sent to the HTTP client.
|
void |
ExecutionInterceptorChain.beforeUnmarshalling(Context.BeforeUnmarshalling context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.beforeUnmarshalling(Context.BeforeUnmarshalling context,
ExecutionAttributes executionAttributes)
Read the finalized HTTP response as it will be given to the unmarshaller to be converted into an
SdkResponse. |
ExecutionAttributes |
ExecutionAttributes.merge(ExecutionAttributes lowerPrecedenceExecutionAttributes)
Merge attributes of a higher precedence into the current lower precedence collection.
|
default Optional<AsyncRequestBody> |
ExecutionInterceptor.modifyAsyncHttpContent(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
InterceptorContext |
ExecutionInterceptorChain.modifyAsyncHttpResponse(InterceptorContext context,
ExecutionAttributes executionAttributes) |
default Optional<org.reactivestreams.Publisher<ByteBuffer>> |
ExecutionInterceptor.modifyAsyncHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes)
Modify the
SdkHttpFullRequest before it is unmarshalled into an SdkResponse. |
default Throwable |
ExecutionInterceptor.modifyException(Context.FailedExecution context,
ExecutionAttributes executionAttributes)
Modify the exception before it is thrown.
|
DefaultFailedExecutionContext |
ExecutionInterceptorChain.modifyException(DefaultFailedExecutionContext context,
ExecutionAttributes executionAttributes) |
default Optional<RequestBody> |
ExecutionInterceptor.modifyHttpContent(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
default SdkHttpRequest |
ExecutionInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes)
Modify the
SdkHttpFullRequest before it is sent to the service. |
InterceptorContext |
ExecutionInterceptorChain.modifyHttpRequestAndHttpContent(InterceptorContext context,
ExecutionAttributes executionAttributes) |
default SdkHttpResponse |
ExecutionInterceptor.modifyHttpResponse(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes)
Modify the
SdkHttpFullRequest before it is unmarshalled into an SdkResponse. |
InterceptorContext |
ExecutionInterceptorChain.modifyHttpResponse(InterceptorContext context,
ExecutionAttributes executionAttributes) |
default Optional<InputStream> |
ExecutionInterceptor.modifyHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes)
Modify the
SdkHttpFullRequest before it is unmarshalled into an SdkResponse. |
default SdkRequest |
ExecutionInterceptor.modifyRequest(Context.ModifyRequest context,
ExecutionAttributes executionAttributes)
Modify an
SdkRequest given to a service client before it is marshalled into an SdkHttpFullRequest. |
InterceptorContext |
ExecutionInterceptorChain.modifyRequest(InterceptorContext context,
ExecutionAttributes executionAttributes) |
default SdkResponse |
ExecutionInterceptor.modifyResponse(Context.ModifyResponse context,
ExecutionAttributes executionAttributes)
Modify the
SdkResponse before it is returned by the client. |
InterceptorContext |
ExecutionInterceptorChain.modifyResponse(InterceptorContext context,
ExecutionAttributes executionAttributes) |
void |
ExecutionInterceptorChain.onExecutionFailure(Context.FailedExecution context,
ExecutionAttributes executionAttributes) |
default void |
ExecutionInterceptor.onExecutionFailure(Context.FailedExecution context,
ExecutionAttributes executionAttributes)
Invoked when any error happens during an execution that prevents the request from succeeding.
|
void |
ExecutionAttributes.putAbsentAttributes(ExecutionAttributes lowerPrecedenceExecutionAttributes)
Add the provided attributes to this attribute, if the provided attribute does not exist.
|
static ExecutionAttributes |
ExecutionAttributes.unmodifiableExecutionAttributes(ExecutionAttributes attributes) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
RequestExecutionContext.executionAttributes() |
| Modifier and Type | Method and Description |
|---|---|
Response<OutputT> |
CombinedResponseHandler.handle(SdkHttpFullResponse httpResponse,
ExecutionAttributes executionAttributes) |
| Constructor and Description |
|---|
AsyncResponseHandler(HttpResponseHandler<T> responseHandler,
Function<SdkHttpFullResponse,SdkHttpFullResponse> crc32Validator,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
Optional<org.reactivestreams.Publisher<ByteBuffer>> |
HttpChecksumValidationInterceptor.modifyAsyncHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes) |
Optional<InputStream> |
HttpChecksumValidationInterceptor.modifyHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
static Optional<ChecksumSpecs> |
HttpChecksumUtils.checksumSpecWithRequestAlgorithm(ExecutionAttributes executionAttributes) |
static ChecksumSpecs |
HttpChecksumResolver.getResolvedChecksumSpecs(ExecutionAttributes executionAttributes) |
static boolean |
HttpChecksumUtils.hasLegacyChecksumRequiredTrait(ExecutionAttributes executionAttributes) |
static boolean |
HttpChecksumUtils.isHttpChecksumCalculationNeeded(SdkHttpFullRequest.Builder request,
ExecutionAttributes executionAttributes)
HTTP checksum calculation is needed if one of the following conditions is met:
1.
|
static boolean |
HttpChecksumUtils.isMd5ChecksumRequired(ExecutionAttributes executionAttributes) |
static boolean |
HttpChecksumUtils.isStreamingUnsignedPayload(SdkHttpRequest sdkHttpRequest,
ExecutionAttributes executionAttributes,
ChecksumSpecs headerChecksumSpecs,
boolean isContentStreaming)
The header based Checksum is computed only if following criteria is met
- Flexible checksum is not already computed.
|
static boolean |
HttpChecksumUtils.isTrailerBasedChecksumForClientType(ExecutionAttributes executionAttributes,
SdkHttpRequest httpRequest,
ClientType clientType,
ChecksumSpecs checksumSpecs,
boolean hasRequestBody,
boolean isContentSteaming) |
static boolean |
HttpChecksumUtils.isTrailerBasedFlexibleChecksumComputed(SdkHttpRequest sdkHttpRequest,
ExecutionAttributes executionAttributes,
ChecksumSpecs checksumSpecs,
boolean hasRequestBody,
boolean isContentStreaming)
The trailer based Checksum is computed only if following criteria is met
- Flexible checksum is not already computed.
|
static ChecksumSpecs |
HttpChecksumResolver.resolveChecksumSpecs(ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
RetryPolicyContext.executionAttributes() |
| Modifier and Type | Method and Description |
|---|---|
RetryPolicyContext.Builder |
RetryPolicyContext.Builder.executionAttributes(ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
static Optional<TokenBucketRetryCondition.Capacity> |
TokenBucketRetryCondition.getCapacityForExecution(ExecutionAttributes attributes)
If
TokenBucketRetryCondition.shouldRetry(RetryPolicyContext) returned true for the provided execution, this method returns the
TokenBucketRetryCondition.Capacity consumed by the request. |
| Modifier and Type | Method and Description |
|---|---|
SdkHttpFullRequest |
Presigner.presign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes)
Deprecated.
Method that takes in an request and returns a pre signed version of the request.
|
SdkHttpFullRequest |
NoOpSigner.presign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes)
Deprecated.
|
CompletableFuture<SdkHttpFullRequest> |
AsyncSigner.sign(SdkHttpFullRequest request,
AsyncRequestBody requestBody,
ExecutionAttributes executionAttributes)
Deprecated.
Sign the request, including the contents of the body into the signature calculation.
|
SdkHttpFullRequest |
Signer.sign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes)
Deprecated.
Method that takes in an request and returns a signed version of the request.
|
SdkHttpFullRequest |
NoOpSigner.sign(SdkHttpFullRequest request,
ExecutionAttributes executionAttributes)
Deprecated.
|
AsyncRequestBody |
AsyncRequestBodySigner.signAsyncRequestBody(SdkHttpFullRequest request,
AsyncRequestBody asyncRequestBody,
ExecutionAttributes executionAttributes)
Deprecated.
Method that takes in an signed request and async request body provider,
and returns a transformed version the request body provider.
|
| Modifier and Type | Method and Description |
|---|---|
T |
JsonResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
T |
AwsJsonResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
AwsServiceException |
AwsJsonProtocolErrorUnmarshaller.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
T |
AwsQueryResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
AwsServiceException |
AwsXmlErrorUnmarshaller.unmarshall(XmlElement documentRoot,
Optional<XmlElement> errorRoot,
Optional<SdkBytes> documentBytes,
SdkHttpFullResponse response,
ExecutionAttributes executionAttributes)
Unmarshal an AWS XML exception
|
| Modifier and Type | Method and Description |
|---|---|
AwsServiceException |
AwsXmlErrorProtocolUnmarshaller.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
ExecutionAttributes |
AwsXmlUnmarshallingContext.executionAttributes()
The
ExecutionAttributes associated with this request. |
| Modifier and Type | Method and Description |
|---|---|
AwsXmlUnmarshallingContext.Builder |
AwsXmlUnmarshallingContext.Builder.executionAttributes(ExecutionAttributes executionAttributes) |
T |
XmlResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
T |
AwsXmlResponseHandler.handle(SdkHttpFullResponse response,
ExecutionAttributes executionAttributes) |
Response<OutputT> |
AwsXmlPredicatedResponseHandler.handle(SdkHttpFullResponse httpResponse,
ExecutionAttributes executionAttributes)
Handle a response
|
| Modifier and Type | Method and Description |
|---|---|
void |
S3AuthSchemeInterceptor.beforeExecution(Context.BeforeExecution context,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
AwsEndpointProviderUtils.disableHostPrefixInjection(ExecutionAttributes attrs)
True if the the
SdkInternalExecutionAttribute.DISABLE_HOST_PREFIX_INJECTION attribute is present and its
value is true, false otherwise. |
static Boolean |
AwsEndpointProviderUtils.dualStackEnabledBuiltIn(ExecutionAttributes executionAttributes) |
static String |
AwsEndpointProviderUtils.endpointBuiltIn(ExecutionAttributes executionAttributes)
Returns the endpoint set on the client.
|
static boolean |
AwsEndpointProviderUtils.endpointIsDiscovered(ExecutionAttributes attrs)
True if the the
SdkInternalExecutionAttribute.IS_DISCOVERED_ENDPOINT attribute is present and its value
is true, false otherwise. |
static boolean |
AwsEndpointProviderUtils.endpointIsOverridden(ExecutionAttributes attrs)
Read
SdkExecutionAttribute#CLIENT_ENDPOINT_PROVIDER's isEndpointOverridden attribute. |
static Boolean |
AwsEndpointProviderUtils.fipsEnabledBuiltIn(ExecutionAttributes executionAttributes) |
SdkHttpRequest |
S3ResolveEndpointInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
SdkHttpRequest |
S3RequestSetEndpointInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
SdkRequest |
S3ResolveEndpointInterceptor.modifyRequest(Context.ModifyRequest context,
ExecutionAttributes executionAttributes) |
static Region |
AwsEndpointProviderUtils.regionBuiltIn(ExecutionAttributes executionAttributes) |
static S3EndpointParams |
S3ResolveEndpointInterceptor.ruleParams(SdkRequest request,
ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
ChecksumsEnabledValidator.getObjectChecksumEnabledPerRequest(SdkRequest request,
ExecutionAttributes executionAttributes)
Checks if trailing checksum is enabled and
ChecksumMode is disabled for
S3Client.getObject(GetObjectRequest) per request. |
static boolean |
ChecksumsEnabledValidator.getObjectChecksumEnabledPerResponse(SdkRequest request,
SdkHttpHeaders responseHeaders,
ExecutionAttributes executionAttributes)
Checks if trailing checksum is enabled for
S3Client.getObject(GetObjectRequest) per response. |
| Modifier and Type | Method and Description |
|---|---|
void |
GetObjectInterceptor.afterTransmission(Context.AfterTransmission context,
ExecutionAttributes executionAttributes) |
void |
DisablePayloadSigningInterceptor.beforeExecution(Context.BeforeExecution context,
ExecutionAttributes executionAttributes) |
void |
ConfigureSignerInterceptor.beforeExecution(Context.BeforeExecution context,
ExecutionAttributes executionAttributes) |
static ChecksumSpecs |
LegacyMd5ExecutionInterceptor.getResolvedChecksumSpecs(ExecutionAttributes executionAttributes) |
static boolean |
LegacyMd5ExecutionInterceptor.isMd5ChecksumRequired(ExecutionAttributes executionAttributes) |
Optional<org.reactivestreams.Publisher<ByteBuffer>> |
GetBucketPolicyInterceptor.modifyAsyncHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes) |
Optional<org.reactivestreams.Publisher<ByteBuffer>> |
AsyncChecksumValidationInterceptor.modifyAsyncHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes) |
Throwable |
ExceptionTranslationInterceptor.modifyException(Context.FailedExecution context,
ExecutionAttributes executionAttributes) |
Optional<RequestBody> |
CreateMultipartUploadRequestInterceptor.modifyHttpContent(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
SdkHttpRequest |
StreamingRequestInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
SdkHttpRequest |
LegacyMd5ExecutionInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
SdkHttpRequest |
EnableTrailingChecksumInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes)
Append trailing checksum header for
GetObjectRequest if trailing checksum is enabled from config,
ChecksumMode is disabled, and is not S3Express. |
SdkHttpRequest |
CreateMultipartUploadRequestInterceptor.modifyHttpRequest(Context.ModifyHttpRequest context,
ExecutionAttributes executionAttributes) |
Optional<InputStream> |
SyncChecksumValidationInterceptor.modifyHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes) |
Optional<InputStream> |
GetBucketPolicyInterceptor.modifyHttpResponseContent(Context.ModifyHttpResponse context,
ExecutionAttributes executionAttributes) |
SdkRequest |
ObjectMetadataInterceptor.modifyRequest(Context.ModifyRequest context,
ExecutionAttributes executionAttributes) |
SdkRequest |
EnableTrailingChecksumInterceptor.modifyRequest(Context.ModifyRequest context,
ExecutionAttributes executionAttributes)
Enable
ChecksumMode for GetObjectRequest if trailing checksum is enabled from config,
ChecksumMode is disabled, and is S3Express. |
SdkRequest |
EnableChunkedEncodingInterceptor.modifyRequest(Context.ModifyRequest context,
ExecutionAttributes executionAttributes) |
SdkRequest |
CreateBucketInterceptor.modifyRequest(Context.ModifyRequest context,
ExecutionAttributes executionAttributes) |
SdkResponse |
GetObjectInterceptor.modifyResponse(Context.ModifyResponse context,
ExecutionAttributes executionAttributes) |
SdkResponse |
EnableTrailingChecksumInterceptor.modifyResponse(Context.ModifyResponse context,
ExecutionAttributes executionAttributes)
Subtract the contentLength of
GetObjectResponse if trailing checksums is enabled. |
SdkResponse |
DecodeUrlEncodedResponseInterceptor.modifyResponse(Context.ModifyResponse context,
ExecutionAttributes executionAttributes) |
static ChecksumSpecs |
LegacyMd5ExecutionInterceptor.resolveChecksumSpecs(ExecutionAttributes executionAttributes) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
S3ExpressUtils.useS3Express(ExecutionAttributes executionAttributes)
Returns true if the resolved endpoint contains S3Express, else false.
|
static boolean |
S3ExpressUtils.useS3ExpressAuthScheme(ExecutionAttributes executionAttributes)
Whether aws.auth#sigv4-s3express is used or not
|
| Modifier and Type | Method and Description |
|---|---|
SdkRequest |
ApplyUserAgentInterceptor.modifyRequest(Context.ModifyRequest context,
ExecutionAttributes executionAttributes) |
Copyright © 2026. All rights reserved.