92 92 | GetBucketPolicyStatusResponseDeserializer,
|
93 93 | ));
|
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 | "GetBucketPolicyStatus",
|
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 - | let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("GetBucketPolicyStatus")
|
123 - | .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
|
124 - | .with_interceptor(GetBucketPolicyStatusEndpointParamsInterceptor)
|
125 - | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
|
126 - | crate::operation::get_bucket_policy_status::GetBucketPolicyStatusError,
|
127 - | >::new())
|
128 - | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
|
129 - | crate::operation::get_bucket_policy_status::GetBucketPolicyStatusError,
|
130 - | >::new())
|
131 - | .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
|
132 - | crate::operation::get_bucket_policy_status::GetBucketPolicyStatusError,
|
133 - | >::new());
|
122 + | let mut rcb =
|
123 + | ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("GetBucketPolicyStatus")
|
124 + | .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
|
125 + | .with_interceptor(GetBucketPolicyStatusEndpointParamsInterceptor)
|
126 + | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
|
127 + | crate::operation::get_bucket_policy_status::GetBucketPolicyStatusError,
|
128 + | >::new())
|
129 + | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
|
130 + | crate::operation::get_bucket_policy_status::GetBucketPolicyStatusError,
|
131 + | >::new())
|
132 + | .with_retry_classifier(
|
133 + | ::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
|
134 + | crate::operation::get_bucket_policy_status::GetBucketPolicyStatusError,
|
135 + | >::builder()
|
136 + | .transient_errors({
|
137 + | let mut transient_errors: Vec<&'static str> = ::aws_runtime::retries::classifiers::TRANSIENT_ERRORS.into();
|
138 + | transient_errors.push("InternalError");
|
139 + | ::std::borrow::Cow::Owned(transient_errors)
|
140 + | })
|
141 + | .build(),
|
142 + | );
|
134 143 |
|
135 144 | ::std::borrow::Cow::Owned(rcb)
|
136 145 | }
|
137 146 | }
|
138 147 |
|
139 148 | #[derive(Debug)]
|
140 149 | struct GetBucketPolicyStatusResponseDeserializer;
|
141 150 | impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for GetBucketPolicyStatusResponseDeserializer {
|
142 151 | fn deserialize_nonstreaming(
|
143 152 | &self,
|
144 153 | response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
|
145 154 | ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
|
146 155 | let (success, status) = (response.status().is_success(), response.status().as_u16());
|
147 156 | let headers = response.headers();
|
148 157 | let body = response.body().bytes().expect("body loaded");
|
149 158 | #[allow(unused_mut)]
|
150 159 | let mut force_error = false;
|
151 160 | ::tracing::debug!(extended_request_id = ?crate::s3_request_id::RequestIdExt::extended_request_id(response));
|
152 161 | if matches!(crate::rest_xml_unwrapped_errors::body_is_error(body), Ok(true)) {
|
153 162 | force_error = true;
|
154 163 | }
|
155 164 | ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
|
156 165 | let parse_result = if !success && status != 200 || force_error {
|
157 166 | crate::protocol_serde::shape_get_bucket_policy_status::de_get_bucket_policy_status_http_error(status, headers, body)
|
158 167 | } else {
|
159 168 | crate::protocol_serde::shape_get_bucket_policy_status::de_get_bucket_policy_status_http_response(status, headers, body)
|
160 169 | };
|
161 170 | crate::protocol_serde::type_erase_result(parse_result)
|
162 171 | }
|
163 172 | }
|