94 94 |
|
95 95 | cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
|
96 96 | ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
|
97 97 | ));
|
98 98 |
|
99 99 | cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
|
100 100 | "AbortMultipartUpload",
|
101 101 | "s3",
|
102 102 | ));
|
103 103 | let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
|
104 104 | signing_options.double_uri_encode = false;
|
105 105 | signing_options.content_sha256_header = true;
|
106 106 | signing_options.normalize_uri_path = false;
|
107 107 | signing_options.payload_override = None;
|
108 108 |
|
109 109 | cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
|
110 110 | signing_options,
|
111 111 | ..::std::default::Default::default()
|
112 112 | });
|
113 113 |
|
114 114 | ::std::option::Option::Some(cfg.freeze())
|
115 115 | }
|
116 116 |
|
117 117 | fn runtime_components(
|
118 118 | &self,
|
119 119 | _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
|
120 120 | ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
|
121 121 | #[allow(unused_mut)]
|
122 122 | let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("AbortMultipartUpload")
|
123 123 | .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
|
124 - | .with_interceptor(AbortMultipartUploadEndpointParamsInterceptor)
|
125 - | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
|
126 - | crate::operation::abort_multipart_upload::AbortMultipartUploadError,
|
127 - | >::new())
|
128 - | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
|
129 - | crate::operation::abort_multipart_upload::AbortMultipartUploadError,
|
130 - | >::new())
|
131 - | .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
|
132 - | crate::operation::abort_multipart_upload::AbortMultipartUploadError,
|
133 - | >::new());
|
124 + | .with_interceptor(AbortMultipartUploadEndpointParamsInterceptor)
|
125 + | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<crate::operation::abort_multipart_upload::AbortMultipartUploadError>::new())
|
126 + | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<crate::operation::abort_multipart_upload::AbortMultipartUploadError>::new())
|
127 + | .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<crate::operation::abort_multipart_upload::AbortMultipartUploadError>::builder().transient_errors({
|
128 + | let mut transient_errors: Vec<&'static str> = ::aws_runtime::retries::classifiers::TRANSIENT_ERRORS.into();
|
129 + | transient_errors.push("InternalError");
|
130 + | ::std::borrow::Cow::Owned(transient_errors)
|
131 + | }).build());
|
134 132 |
|
135 133 | ::std::borrow::Cow::Owned(rcb)
|
136 134 | }
|
137 135 | }
|
138 136 |
|
139 137 | #[derive(Debug)]
|
140 138 | struct AbortMultipartUploadResponseDeserializer;
|
141 139 | impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for AbortMultipartUploadResponseDeserializer {
|
142 140 | fn deserialize_nonstreaming(
|
143 141 | &self,
|
144 142 | response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
|
145 143 | ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
|
146 144 | let (success, status) = (response.status().is_success(), response.status().as_u16());
|
147 145 | let headers = response.headers();
|
148 146 | let body = response.body().bytes().expect("body loaded");
|
149 147 | #[allow(unused_mut)]
|
150 148 | let mut force_error = false;
|
151 149 | ::tracing::debug!(extended_request_id = ?crate::s3_request_id::RequestIdExt::extended_request_id(response));
|
152 150 | if matches!(crate::rest_xml_unwrapped_errors::body_is_error(body), Ok(true)) {
|
153 151 | force_error = true;
|
154 152 | }
|
155 153 | ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
|
156 154 | let parse_result = if !success && status != 204 || force_error {
|
157 155 | crate::protocol_serde::shape_abort_multipart_upload::de_abort_multipart_upload_http_error(status, headers, body)
|
158 156 | } else {
|
159 157 | crate::protocol_serde::shape_abort_multipart_upload::de_abort_multipart_upload_http_response(status, headers, body)
|
160 158 | };
|
161 159 | crate::protocol_serde::type_erase_result(parse_result)
|
162 160 | }
|
163 161 | }
|