Modifier and Type | Method and Description |
---|---|
RequestExecutionContext |
RequestExecutionContext.Builder.build() |
Modifier and Type | Method and Description |
---|---|
Response<OutputT> |
StreamManagingStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context) |
Modifier and Type | Method and Description |
---|---|
OutputT |
RequestPipeline.execute(InputT input,
RequestExecutionContext context)
Execute the pipeline with the given input.
|
Modifier and Type | Method and Description |
---|---|
<any> |
AfterTransmissionExecutionInterceptorsStage.execute(<any> input,
RequestExecutionContext context) |
SdkHttpFullResponse |
BeforeUnmarshallingExecutionInterceptorsStage.execute(<any> input,
RequestExecutionContext context) |
CompletableFuture<SdkHttpFullRequest> |
AsyncBeforeTransmissionExecutionInterceptorsStage.execute(CompletableFuture<SdkHttpFullRequest> input,
RequestExecutionContext context) |
CompletableFuture<Response<OutputT>> |
MakeAsyncHttpRequestStage.execute(CompletableFuture<SdkHttpFullRequest> requestFuture,
RequestExecutionContext context) |
OutputT |
AfterExecutionInterceptorsStage.execute(OutputT input,
RequestExecutionContext context) |
OutputT |
UnwrapResponseContainer.execute(Response<OutputT> input,
RequestExecutionContext context) |
SdkHttpFullRequest.Builder |
MergeCustomHeadersStage.execute(SdkHttpFullRequest.Builder request,
RequestExecutionContext context) |
SdkHttpFullRequest.Builder |
ApplyTransactionIdStage.execute(SdkHttpFullRequest.Builder request,
RequestExecutionContext context) |
SdkHttpFullRequest |
MakeRequestImmutableStage.execute(SdkHttpFullRequest.Builder input,
RequestExecutionContext context) |
SdkHttpFullRequest.Builder |
MergeCustomQueryParamsStage.execute(SdkHttpFullRequest.Builder request,
RequestExecutionContext context) |
SdkHttpFullRequest.Builder |
ApplyUserAgentStage.execute(SdkHttpFullRequest.Builder request,
RequestExecutionContext context) |
<any> |
MakeHttpRequestStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context)
Returns the response from executing one httpClientSettings request; or null for retry.
|
CompletableFuture<SdkHttpFullRequest> |
AsyncSigningStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context)
Returns the response from executing one httpClientSettings request; or null for retry.
|
SdkHttpFullRequest |
SigningStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context)
Returns the response from executing one httpClientSettings request; or null for retry.
|
CompletableFuture<OutputT> |
AsyncApiCallTimeoutTrackingStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
Response<OutputT> |
TimeoutExceptionHandlingStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context)
Translate an
Exception caused by timeout based on the following criteria:
If the Exception is caused by ClientOverrideConfiguration.apiCallTimeout , translates it to
InterruptedException so it can be handled
appropriately in ApiCallTimeoutTrackingStage . |
Response<OutputT> |
ApiCallAttemptMetricCollectionStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
CompletableFuture<OutputT> |
AsyncExecutionFailureExceptionReportingStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
CompletableFuture<OutputT> |
AsyncApiCallMetricCollectionStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
CompletableFuture<Response<OutputT>> |
AsyncRetryableStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context) |
SdkHttpFullRequest |
BeforeTransmissionExecutionInterceptorsStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
SdkHttpFullRequest.Builder |
MakeRequestMutableStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
Response<OutputT> |
ApiCallMetricCollectionStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
Response<OutputT> |
ApiCallAttemptTimeoutTrackingStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context)
Start and end api call attempt timer around the execution of the api call attempt.
|
Response<OutputT> |
ApiCallTimeoutTrackingStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context) |
CompletableFuture<Response<OutputT>> |
AsyncApiCallAttemptMetricCollectionStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
OutputT |
ExecutionFailureExceptionReportingStage.execute(SdkHttpFullRequest input,
RequestExecutionContext context) |
Response<OutputT> |
RetryableStage.execute(SdkHttpFullRequest request,
RequestExecutionContext context) |
Response<OutputT> |
HandleResponseStage.execute(SdkHttpFullResponse httpResponse,
RequestExecutionContext context) |
Modifier and Type | Method and Description |
---|---|
static Throwable |
ExceptionReportingUtils.reportFailureToInterceptors(RequestExecutionContext context,
Throwable failure)
Report the failure to the execution interceptors.
|
Constructor and Description |
---|
RetryableStageHelper(SdkHttpFullRequest request,
RequestExecutionContext context,
RateLimitingTokenBucket rateLimitingTokenBucket,
HttpClientDependencies dependencies) |
Modifier and Type | Method and Description |
---|---|
static MetricCollector |
MetricUtils.createAttemptMetricsCollector(RequestExecutionContext context) |
static MetricCollector |
MetricUtils.createHttpMetricsCollector(RequestExecutionContext context) |
Copyright © 2022. All rights reserved.