aws_sdk_pcs/operation/
create_cluster.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `CreateCluster`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct CreateCluster;
6impl CreateCluster {
7    /// Creates a new `CreateCluster`
8    pub fn new() -> Self {
9        Self
10    }
11    pub(crate) async fn orchestrate(
12        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
13        input: crate::operation::create_cluster::CreateClusterInput,
14    ) -> ::std::result::Result<
15        crate::operation::create_cluster::CreateClusterOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::create_cluster::CreateClusterError,
18            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
19        >,
20    > {
21        let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
22            ::aws_smithy_runtime_api::client::interceptors::context::Error,
23            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
24        >| {
25            err.map_service_error(|err| {
26                err.downcast::<crate::operation::create_cluster::CreateClusterError>()
27                    .expect("correct error type")
28            })
29        };
30        let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
31            .await
32            .map_err(map_err)?;
33        let output = context.finalize().map_err(map_err)?;
34        ::std::result::Result::Ok(
35            output
36                .downcast::<crate::operation::create_cluster::CreateClusterOutput>()
37                .expect("correct output type"),
38        )
39    }
40
41    pub(crate) async fn orchestrate_with_stop_point(
42        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
43        input: crate::operation::create_cluster::CreateClusterInput,
44        stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,
45    ) -> ::std::result::Result<
46        ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext,
47        ::aws_smithy_runtime_api::client::result::SdkError<
48            ::aws_smithy_runtime_api::client::interceptors::context::Error,
49            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
50        >,
51    > {
52        let input = ::aws_smithy_runtime_api::client::interceptors::context::Input::erase(input);
53        use ::tracing::Instrument;
54        ::aws_smithy_runtime::client::orchestrator::invoke_with_stop_point("PCS", "CreateCluster", input, runtime_plugins, stop_point)
55            // Create a parent span for the entire operation. Includes a random, internal-only,
56            // seven-digit ID for the operation orchestration so that it can be correlated in the logs.
57            .instrument(::tracing::debug_span!(
58                "PCS.CreateCluster",
59                "rpc.service" = "PCS",
60                "rpc.method" = "CreateCluster",
61                "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
62                "rpc.system" = "aws-api",
63            ))
64            .await
65    }
66
67    pub(crate) fn operation_runtime_plugins(
68        client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
69        client_config: &crate::config::Config,
70        config_override: ::std::option::Option<crate::config::Builder>,
71    ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
72        let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
73        runtime_plugins = runtime_plugins.with_operation_plugin(crate::client_idempotency_token::IdempotencyTokenRuntimePlugin::new(
74            |token_provider, input| {
75                let input: &mut crate::operation::create_cluster::CreateClusterInput = input.downcast_mut().expect("correct type");
76                if input.client_token.is_none() {
77                    input.client_token = ::std::option::Option::Some(token_provider.make_idempotency_token());
78                }
79            },
80        ));
81        if let ::std::option::Option::Some(config_override) = config_override {
82            for plugin in config_override.runtime_plugins.iter().cloned() {
83                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
84            }
85            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
86                config_override,
87                client_config.config.clone(),
88                &client_config.runtime_components,
89            ));
90        }
91        runtime_plugins
92    }
93}
94impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for CreateCluster {
95    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
96        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CreateCluster");
97
98        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
99            CreateClusterRequestSerializer,
100        ));
101        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
102            CreateClusterResponseDeserializer,
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
106            crate::config::auth::Params::builder()
107                .operation_name("CreateCluster")
108                .build()
109                .expect("required fields set"),
110        ));
111
112        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new("CreateCluster", "PCS"));
113        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
114        signing_options.double_uri_encode = true;
115        signing_options.content_sha256_header = false;
116        signing_options.normalize_uri_path = true;
117        signing_options.payload_override = None;
118
119        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
120            signing_options,
121            ..::std::default::Default::default()
122        });
123
124        ::std::option::Option::Some(cfg.freeze())
125    }
126
127    fn runtime_components(
128        &self,
129        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
130    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
131        #[allow(unused_mut)]
132        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("CreateCluster")
133            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
134                CreateClusterTelemetryInputCaptureInterceptor,
135            ))
136            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
137                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
138            ))
139            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
140                CreateClusterEndpointParamsInterceptor,
141            ))
142            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
143                crate::operation::create_cluster::CreateClusterError,
144            >::new())
145            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
146                crate::operation::create_cluster::CreateClusterError,
147            >::new())
148            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
149                crate::operation::create_cluster::CreateClusterError,
150            >::new());
151
152        ::std::borrow::Cow::Owned(rcb)
153    }
154}
155
156#[derive(Debug)]
157struct CreateClusterTelemetryInputCaptureInterceptor;
158
159#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
160impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateClusterTelemetryInputCaptureInterceptor {
161    fn name(&self) -> &'static str {
162        "CreateClusterTelemetryInputCaptureInterceptor"
163    }
164
165    fn read_before_execution(
166        &self,
167        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
168            '_,
169            ::aws_smithy_runtime_api::client::interceptors::context::Input,
170            ::aws_smithy_runtime_api::client::interceptors::context::Output,
171            ::aws_smithy_runtime_api::client::interceptors::context::Error,
172        >,
173        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
174    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
175        // Nothing to do unless the customer opted in by naming members to record.
176        let ::std::option::Option::Some(requested) = cfg
177            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
178            .filter(|r| !r.is_empty())
179        else {
180            return ::std::result::Result::Ok(());
181        };
182
183        let ::std::option::Option::Some(input) = context.input().downcast_ref::<CreateClusterInput>() else {
184            // A mismatched input is not this interceptor's concern; skip quietly.
185            return ::std::result::Result::Ok(());
186        };
187
188        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
189        if requested.should_capture("clusterName") {
190            if let ::std::option::Option::Some(value) = input.cluster_name.as_deref() {
191                captured.insert("clusterName", value);
192            }
193        }
194        if requested.should_capture("clientToken") {
195            if let ::std::option::Option::Some(value) = input.client_token.as_deref() {
196                captured.insert("clientToken", value);
197            }
198        }
199
200        cfg.interceptor_state().store_put(captured);
201        ::std::result::Result::Ok(())
202    }
203}
204#[derive(Debug)]
205struct CreateClusterResponseDeserializer;
206impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for CreateClusterResponseDeserializer {
207    fn deserialize_nonstreaming_with_config(
208        &self,
209        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
210        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
211    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
212        let (success, status) = (response.status().is_success(), response.status().as_u16());
213        let headers = response.headers();
214        let body = response.body().bytes().expect("body loaded");
215        #[allow(unused_mut)]
216        let mut force_error = false;
217        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
218        let parse_result = if !success && status != 200 || force_error {
219            crate::protocol_serde::shape_create_cluster::de_create_cluster_http_error(status, headers, body)
220        } else {
221            crate::protocol_serde::shape_create_cluster::de_create_cluster_http_response(status, headers, body)
222        };
223        crate::protocol_serde::type_erase_result(parse_result)
224    }
225}
226#[derive(Debug)]
227struct CreateClusterRequestSerializer;
228impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for CreateClusterRequestSerializer {
229    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
230    fn serialize_input(
231        &self,
232        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
233        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
234    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
235        let input = input
236            .downcast::<crate::operation::create_cluster::CreateClusterInput>()
237            .expect("correct type");
238        let _header_serialization_settings = _cfg
239            .load::<crate::serialization_settings::HeaderSerializationSettings>()
240            .cloned()
241            .unwrap_or_default();
242        let mut request_builder = {
243            #[allow(clippy::uninlined_format_args)]
244            fn uri_base(
245                _input: &crate::operation::create_cluster::CreateClusterInput,
246                output: &mut ::std::string::String,
247            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
248                use ::std::fmt::Write as _;
249                ::std::write!(output, "/").expect("formatting should succeed");
250                ::std::result::Result::Ok(())
251            }
252            #[allow(clippy::unnecessary_wraps)]
253            fn update_http_builder(
254                input: &crate::operation::create_cluster::CreateClusterInput,
255                builder: ::http_1x::request::Builder,
256            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
257                let mut uri = ::std::string::String::new();
258                uri_base(input, &mut uri)?;
259                ::std::result::Result::Ok(builder.method("POST").uri(uri))
260            }
261            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
262            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/x-amz-json-1.0");
263            builder = _header_serialization_settings.set_default_header(
264                builder,
265                ::http_1x::header::HeaderName::from_static("x-amz-target"),
266                "AWSParallelComputingService.CreateCluster",
267            );
268            builder
269        };
270        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_create_cluster::ser_create_cluster_input(&input)?);
271        if let Some(content_length) = body.content_length() {
272            let content_length = content_length.to_string();
273            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
274        }
275        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
276    }
277}
278#[derive(Debug)]
279struct CreateClusterEndpointParamsInterceptor;
280
281#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
282impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateClusterEndpointParamsInterceptor {
283    fn name(&self) -> &'static str {
284        "CreateClusterEndpointParamsInterceptor"
285    }
286
287    fn read_before_execution(
288        &self,
289        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
290            '_,
291            ::aws_smithy_runtime_api::client::interceptors::context::Input,
292            ::aws_smithy_runtime_api::client::interceptors::context::Output,
293            ::aws_smithy_runtime_api::client::interceptors::context::Error,
294        >,
295        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
296    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
297        let _input = context
298            .input()
299            .downcast_ref::<CreateClusterInput>()
300            .ok_or("failed to downcast to CreateClusterInput")?;
301
302        let params = crate::config::endpoint::Params::builder()
303            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
304            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
305            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
306            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
307            .build()
308            .map_err(|err| {
309                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
310            })?;
311        cfg.interceptor_state()
312            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
313        ::std::result::Result::Ok(())
314    }
315}
316
317// The get_* functions below are generated from JMESPath expressions in the
318// operationContextParams trait. They target the operation's input shape.
319
320/// Error type for the `CreateClusterError` operation.
321#[non_exhaustive]
322#[derive(::std::fmt::Debug)]
323pub enum CreateClusterError {
324    /// <p>You don't have permission to perform the action.</p>
325    /// <p><u>Examples</u></p>
326    /// <ul>
327    /// <li>
328    /// <p>The launch template instance profile doesn't pass <code>iam:PassRole</code> verification.</p></li>
329    /// <li>
330    /// <p>There is a mismatch between the account ID and cluster ID.</p></li>
331    /// <li>
332    /// <p>The cluster ID doesn't exist.</p></li>
333    /// <li>
334    /// <p>The EC2 instance isn't present.</p></li>
335    /// </ul>
336    AccessDeniedException(crate::types::error::AccessDeniedException),
337    /// <p>Your request has conflicting operations. This can occur if you're trying to perform more than 1 operation on the same resource at the same time.</p>
338    /// <p><u>Examples</u></p>
339    /// <ul>
340    /// <li>
341    /// <p>A cluster with the same name already exists.</p></li>
342    /// <li>
343    /// <p>A cluster isn't in <code>ACTIVE</code> status.</p></li>
344    /// <li>
345    /// <p>A cluster to delete is in an unstable state. For example, because it still has <code>ACTIVE</code> node groups or queues.</p></li>
346    /// <li>
347    /// <p>A queue already exists in a cluster.</p></li>
348    /// </ul>
349    ConflictException(crate::types::error::ConflictException),
350    /// <p>PCS can't process your request right now. Try again later.</p>
351    InternalServerException(crate::types::error::InternalServerException),
352    /// <p>You exceeded your service quota. Service quotas, also referred to as limits, are the maximum number of service resources or operations for your Amazon Web Services account. To learn how to increase your service quota, see <a href="https://docs.aws.amazon.com/servicequotas/latest/userguide/request-quota-increase.html">Requesting a quota increase</a> in the <i>Service Quotas User Guide</i></p>
353    /// <p><u>Examples</u></p>
354    /// <ul>
355    /// <li>
356    /// <p>The max number of clusters or queues has been reached for the account.</p></li>
357    /// <li>
358    /// <p>The max number of compute node groups has been reached for the associated cluster.</p></li>
359    /// <li>
360    /// <p>The total of <code>maxInstances</code> across all compute node groups has been reached for associated cluster.</p></li>
361    /// </ul>
362    ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
363    /// <p>Your request exceeded a request rate quota. Check the resource's request rate quota and try again.</p>
364    ThrottlingException(crate::types::error::ThrottlingException),
365    /// <p>The request isn't valid.</p>
366    /// <p><u>Examples</u></p>
367    /// <ul>
368    /// <li>
369    /// <p>Your request contains malformed JSON or unsupported characters.</p></li>
370    /// <li>
371    /// <p>The scheduler version isn't supported.</p></li>
372    /// <li>
373    /// <p>There are networking related errors, such as network validation failure.</p></li>
374    /// <li>
375    /// <p>AMI type is <code>CUSTOM</code> and the launch template doesn't define the AMI ID, or the AMI type is AL2 and the launch template defines the AMI.</p></li>
376    /// </ul>
377    ValidationException(crate::types::error::ValidationException),
378    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
379    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
380    variable wildcard pattern and check `.code()`:
381     \
382    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
383     \
384    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-CreateClusterError) for what information is available for the error.")]
385    Unhandled(crate::error::sealed_unhandled::Unhandled),
386}
387impl CreateClusterError {
388    /// Creates the `CreateClusterError::Unhandled` variant from any error type.
389    pub fn unhandled(
390        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
391    ) -> Self {
392        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
393            source: err.into(),
394            meta: ::std::default::Default::default(),
395        })
396    }
397
398    /// Creates the `CreateClusterError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
399    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
400        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
401            source: err.clone().into(),
402            meta: err,
403        })
404    }
405    ///
406    /// Returns error metadata, which includes the error code, message,
407    /// request ID, and potentially additional information.
408    ///
409    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
410        match self {
411            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
412            Self::ConflictException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
413            Self::InternalServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
414            Self::ServiceQuotaExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
415            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
416            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
417            Self::Unhandled(e) => &e.meta,
418        }
419    }
420    /// Returns `true` if the error kind is `CreateClusterError::AccessDeniedException`.
421    pub fn is_access_denied_exception(&self) -> bool {
422        matches!(self, Self::AccessDeniedException(_))
423    }
424    /// Returns `true` if the error kind is `CreateClusterError::ConflictException`.
425    pub fn is_conflict_exception(&self) -> bool {
426        matches!(self, Self::ConflictException(_))
427    }
428    /// Returns `true` if the error kind is `CreateClusterError::InternalServerException`.
429    pub fn is_internal_server_exception(&self) -> bool {
430        matches!(self, Self::InternalServerException(_))
431    }
432    /// Returns `true` if the error kind is `CreateClusterError::ServiceQuotaExceededException`.
433    pub fn is_service_quota_exceeded_exception(&self) -> bool {
434        matches!(self, Self::ServiceQuotaExceededException(_))
435    }
436    /// Returns `true` if the error kind is `CreateClusterError::ThrottlingException`.
437    pub fn is_throttling_exception(&self) -> bool {
438        matches!(self, Self::ThrottlingException(_))
439    }
440    /// Returns `true` if the error kind is `CreateClusterError::ValidationException`.
441    pub fn is_validation_exception(&self) -> bool {
442        matches!(self, Self::ValidationException(_))
443    }
444}
445impl ::std::error::Error for CreateClusterError {
446    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
447        match self {
448            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
449            Self::ConflictException(_inner) => ::std::option::Option::Some(_inner),
450            Self::InternalServerException(_inner) => ::std::option::Option::Some(_inner),
451            Self::ServiceQuotaExceededException(_inner) => ::std::option::Option::Some(_inner),
452            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
453            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
454            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
455        }
456    }
457}
458impl ::std::fmt::Display for CreateClusterError {
459    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
460        match self {
461            Self::AccessDeniedException(_inner) => _inner.fmt(f),
462            Self::ConflictException(_inner) => _inner.fmt(f),
463            Self::InternalServerException(_inner) => _inner.fmt(f),
464            Self::ServiceQuotaExceededException(_inner) => _inner.fmt(f),
465            Self::ThrottlingException(_inner) => _inner.fmt(f),
466            Self::ValidationException(_inner) => _inner.fmt(f),
467            Self::Unhandled(_inner) => {
468                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
469                    write!(f, "unhandled error ({code})")
470                } else {
471                    f.write_str("unhandled error")
472                }
473            }
474        }
475    }
476}
477impl ::aws_smithy_types::retry::ProvideErrorKind for CreateClusterError {
478    fn code(&self) -> ::std::option::Option<&str> {
479        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
480    }
481    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
482        match self {
483            Self::InternalServerException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
484            Self::ThrottlingException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
485            _ => ::std::option::Option::None,
486        }
487    }
488}
489impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for CreateClusterError {
490    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
491        match self {
492            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
493            Self::ConflictException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
494            Self::InternalServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
495            Self::ServiceQuotaExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
496            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
497            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
498            Self::Unhandled(_inner) => &_inner.meta,
499        }
500    }
501}
502impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for CreateClusterError {
503    fn create_unhandled_error(
504        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
505        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
506    ) -> Self {
507        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
508            source,
509            meta: meta.unwrap_or_default(),
510        })
511    }
512}
513impl ::aws_types::request_id::RequestId for crate::operation::create_cluster::CreateClusterError {
514    fn request_id(&self) -> Option<&str> {
515        self.meta().request_id()
516    }
517}
518
519pub use crate::operation::create_cluster::_create_cluster_input::CreateClusterInput;
520
521pub use crate::operation::create_cluster::_create_cluster_output::CreateClusterOutput;
522
523mod _create_cluster_input;
524
525mod _create_cluster_output;
526
527/// Builders
528pub mod builders;
aws_sdk_pcs/operation/create_cluster.rs

aws_sdk_pcs/operation/
create_cluster.rs
