| Modifier and Type | Method and Description |
|---|---|
static <ResponseT,ResultT> |
AsyncResponseTransformerUtils.wrapWithEndOfStreamFuture(AsyncResponseTransformer<ResponseT,ResultT> responseTransformer)
Wrap a
AsyncResponseTransformer and associate it with a future that is completed upon end-of-stream, regardless of
whether the transformer is configured to complete its future upon end-of-response or end-of-stream. |
| Modifier and Type | Method and Description |
|---|---|
Pair<SdkHttpFullRequest,SdkHttpFullResponse> |
AfterTransmissionExecutionInterceptorsStage.execute(Pair<SdkHttpFullRequest,SdkHttpFullResponse> input,
RequestExecutionContext context) |
Pair<SdkHttpFullRequest,SdkHttpFullResponse> |
MakeHttpRequestStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context)
Returns the response from executing one httpClientSettings request; or null for retry.
|
| Modifier and Type | Method and Description |
|---|---|
SdkHttpFullResponse |
BeforeUnmarshallingExecutionInterceptorsStage.execute(Pair<SdkHttpFullRequest,SdkHttpFullResponse> input,
RequestExecutionContext context) |
Pair<SdkHttpFullRequest,SdkHttpFullResponse> |
AfterTransmissionExecutionInterceptorsStage.execute(Pair<SdkHttpFullRequest,SdkHttpFullResponse> input,
RequestExecutionContext context) |
| Modifier and Type | Method and Description |
|---|---|
static Pair<ChecksumAlgorithm,String> |
HttpChecksumUtils.getAlgorithmChecksumValuePair(SdkHttpResponse sdkHttpResponse,
ChecksumSpecs resolvedChecksumSpecs)
Loops through the supported list of checksum for the operation, and gets the header value for the checksum header.
|
static <T> Pair<T,Duration> |
MetricUtils.measureDuration(Supplier<T> c)
Measure the duration of the given callable.
|
static <T> Pair<T,Duration> |
MetricUtils.measureDurationUnsafe(Callable<T> c)
Measure the duration of the given callable.
|
static <T> Pair<T,Duration> |
MetricUtils.measureDurationUnsafe(Callable<T> c,
long startTime)
Measure the duration of the given callable, using the provided time as the basis.
|
| Modifier and Type | Method and Description |
|---|---|
static XmlAttributesTrait |
XmlAttributesTrait.create(Pair<String,XmlAttributesTrait.AttributeAccessors>... pairs) |
| Modifier and Type | Method and Description |
|---|---|
Pair<String,List<String>> |
SigV4aTrailerProvider.get() |
Pair<byte[],byte[]> |
SigV4aChunkExtensionProvider.get(ByteBuffer chunk) |
| Modifier and Type | Method and Description |
|---|---|
static List<Pair<String,List<String>>> |
V4CanonicalRequest.getCanonicalHeaders(Map<String,List<String>> headers)
Get the list of headers that are to be signed.
|
static List<Pair<String,List<String>>> |
V4CanonicalRequest.getCanonicalHeaders(SdkHttpRequest request)
Get the list of headers that are to be signed.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
V4CanonicalRequest.getCanonicalHeadersString(List<Pair<String,List<String>>> canonicalHeaders)
Get the string representing the headers that will be signed and their values.
|
static String |
V4CanonicalRequest.getSignedHeadersString(List<Pair<String,List<String>>> canonicalHeaders)
Get the string representing which headers are part of the signing process.
|
| Modifier and Type | Method and Description |
|---|---|
Pair<String,List<String>> |
TrailerProvider.get() |
Pair<String,List<String>> |
SigV4TrailerProvider.get() |
Pair<String,List<String>> |
ChecksumTrailerProvider.get() |
Pair<byte[],byte[]> |
SigV4ChunkExtensionProvider.get(ByteBuffer chunk) |
Pair<byte[],byte[]> |
ChunkExtensionProvider.get(ByteBuffer chunk) |
| Modifier and Type | Method and Description |
|---|---|
<TypeT extends SdkPojo> |
QueryProtocolUnmarshaller.unmarshall(SdkPojo sdkPojo,
SdkHttpFullResponse response) |
| Modifier and Type | Method and Description |
|---|---|
static Pair<String,PartitionEndpointKey> |
ServiceMetadataUtils.partitionKey(ServiceEndpointKey key) |
| Modifier and Type | Method and Description |
|---|---|
static String |
ServiceMetadataUtils.dnsSuffix(ServiceEndpointKey key,
Map<ServiceEndpointKey,String> dnsSuffixesByRegion,
Map<Pair<String,PartitionEndpointKey>,String> dnsSuffixesByPartition) |
static String |
ServiceMetadataUtils.hostname(ServiceEndpointKey key,
Map<ServiceEndpointKey,String> hostnamesByRegion,
Map<Pair<String,PartitionEndpointKey>,String> hostnamesByPartition) |
static Region |
ServiceMetadataUtils.signingRegion(ServiceEndpointKey key,
Map<ServiceEndpointKey,String> signingRegionsByRegion,
Map<Pair<String,PartitionEndpointKey>,String> signingRegionsByPartition) |
| Modifier and Type | Method and Description |
|---|---|
protected Pair<Expr,Expr> |
Fn.expectTwoArgs() |
| Modifier and Type | Method and Description |
|---|---|
Pair<PutObjectRequest,AsyncRequestBody> |
MpuRequestContext.request() |
| Modifier and Type | Method and Description |
|---|---|
MpuRequestContext.Builder |
MpuRequestContext.Builder.request(Pair<PutObjectRequest,AsyncRequestBody> request) |
| Modifier and Type | Method and Description |
|---|---|
static Pair<DownloadFileRequest,AsyncResponseTransformer<GetObjectResponse,GetObjectResponse>> |
ResumableRequestConverter.toDownloadFileRequestAndTransformer(ResumableFileDownload resumableFileDownload,
HeadObjectResponse headObjectResponse,
DownloadFileRequest originalDownloadRequest)
|
| Modifier and Type | Method and Description |
|---|---|
static <LeftT,RightT> |
Pair.of(LeftT left,
RightT right) |
Copyright © 2026. All rights reserved.