aws_sdk_eks/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("EKS", "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                "EKS.CreateCluster",
59                "rpc.service" = "EKS",
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_request_token.is_none() {
77                    input.client_request_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", "EKS"));
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("name") {
190            if let ::std::option::Option::Some(value) = input.name.as_deref() {
191                captured.insert("name", value);
192            }
193        }
194        if requested.should_capture("version") {
195            if let ::std::option::Option::Some(value) = input.version.as_deref() {
196                captured.insert("version", value);
197            }
198        }
199        if requested.should_capture("roleArn") {
200            if let ::std::option::Option::Some(value) = input.role_arn.as_deref() {
201                captured.insert("roleArn", value);
202            }
203        }
204        if requested.should_capture("clientRequestToken") {
205            if let ::std::option::Option::Some(value) = input.client_request_token.as_deref() {
206                captured.insert("clientRequestToken", value);
207            }
208        }
209
210        cfg.interceptor_state().store_put(captured);
211        ::std::result::Result::Ok(())
212    }
213}
214#[derive(Debug)]
215struct CreateClusterResponseDeserializer;
216impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for CreateClusterResponseDeserializer {
217    fn deserialize_nonstreaming_with_config(
218        &self,
219        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
220        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
221    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
222        let (success, status) = (response.status().is_success(), response.status().as_u16());
223        let headers = response.headers();
224        let body = response.body().bytes().expect("body loaded");
225        #[allow(unused_mut)]
226        let mut force_error = false;
227        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
228        let parse_result = if !success && status != 200 || force_error {
229            crate::protocol_serde::shape_create_cluster::de_create_cluster_http_error(status, headers, body)
230        } else {
231            crate::protocol_serde::shape_create_cluster::de_create_cluster_http_response(status, headers, body)
232        };
233        crate::protocol_serde::type_erase_result(parse_result)
234    }
235}
236#[derive(Debug)]
237struct CreateClusterRequestSerializer;
238impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for CreateClusterRequestSerializer {
239    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
240    fn serialize_input(
241        &self,
242        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
243        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
244    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
245        let input = input
246            .downcast::<crate::operation::create_cluster::CreateClusterInput>()
247            .expect("correct type");
248        let _header_serialization_settings = _cfg
249            .load::<crate::serialization_settings::HeaderSerializationSettings>()
250            .cloned()
251            .unwrap_or_default();
252        let mut request_builder = {
253            #[allow(clippy::uninlined_format_args)]
254            fn uri_base(
255                _input: &crate::operation::create_cluster::CreateClusterInput,
256                output: &mut ::std::string::String,
257            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
258                use ::std::fmt::Write as _;
259                ::std::write!(output, "/clusters").expect("formatting should succeed");
260                ::std::result::Result::Ok(())
261            }
262            #[allow(clippy::unnecessary_wraps)]
263            fn update_http_builder(
264                input: &crate::operation::create_cluster::CreateClusterInput,
265                builder: ::http_1x::request::Builder,
266            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
267                let mut uri = ::std::string::String::new();
268                uri_base(input, &mut uri)?;
269                ::std::result::Result::Ok(builder.method("POST").uri(uri))
270            }
271            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
272            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/json");
273            builder
274        };
275        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_create_cluster::ser_create_cluster_input(&input)?);
276        if let Some(content_length) = body.content_length() {
277            let content_length = content_length.to_string();
278            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
279        }
280        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
281    }
282}
283#[derive(Debug)]
284struct CreateClusterEndpointParamsInterceptor;
285
286#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
287impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateClusterEndpointParamsInterceptor {
288    fn name(&self) -> &'static str {
289        "CreateClusterEndpointParamsInterceptor"
290    }
291
292    fn read_before_execution(
293        &self,
294        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
295            '_,
296            ::aws_smithy_runtime_api::client::interceptors::context::Input,
297            ::aws_smithy_runtime_api::client::interceptors::context::Output,
298            ::aws_smithy_runtime_api::client::interceptors::context::Error,
299        >,
300        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
301    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
302        let _input = context
303            .input()
304            .downcast_ref::<CreateClusterInput>()
305            .ok_or("failed to downcast to CreateClusterInput")?;
306
307        let params = crate::config::endpoint::Params::builder()
308            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
309            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
310            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
311            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
312            .build()
313            .map_err(|err| {
314                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
315            })?;
316        cfg.interceptor_state()
317            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
318        ::std::result::Result::Ok(())
319    }
320}
321
322// The get_* functions below are generated from JMESPath expressions in the
323// operationContextParams trait. They target the operation's input shape.
324
325/// Error type for the `CreateClusterError` operation.
326#[non_exhaustive]
327#[derive(::std::fmt::Debug)]
328pub enum CreateClusterError {
329    /// <p>These errors are usually caused by a client action. Actions can include using an action or resource on behalf of an <a href="https://docs.aws.amazon.com/IAM/latest/UserGuide/id_roles_terms-and-concepts.html">IAM principal</a> that doesn't have permissions to use the action or resource or specifying an identifier that is not valid.</p>
330    ClientException(crate::types::error::ClientException),
331    /// <p>The specified parameter is invalid. Review the available parameters for the API request.</p>
332    InvalidParameterException(crate::types::error::InvalidParameterException),
333    /// <p>The specified resource is in use.</p>
334    ResourceInUseException(crate::types::error::ResourceInUseException),
335    /// <p>You have encountered a service limit on the specified resource.</p>
336    ResourceLimitExceededException(crate::types::error::ResourceLimitExceededException),
337    /// <p>These errors are usually caused by a server-side issue.</p>
338    ServerException(crate::types::error::ServerException),
339    /// <p>The service is unavailable. Back off and retry the operation.</p>
340    ServiceUnavailableException(crate::types::error::ServiceUnavailableException),
341    /// <p>At least one of your specified cluster subnets is in an Availability Zone that does not support Amazon EKS. The exception output specifies the supported Availability Zones for your account, from which you can choose subnets for your cluster.</p>
342    UnsupportedAvailabilityZoneException(crate::types::error::UnsupportedAvailabilityZoneException),
343    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
344    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
345    variable wildcard pattern and check `.code()`:
346     \
347    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
348     \
349    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-CreateClusterError) for what information is available for the error.")]
350    Unhandled(crate::error::sealed_unhandled::Unhandled),
351}
352impl CreateClusterError {
353    /// Creates the `CreateClusterError::Unhandled` variant from any error type.
354    pub fn unhandled(
355        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
356    ) -> Self {
357        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
358            source: err.into(),
359            meta: ::std::default::Default::default(),
360        })
361    }
362
363    /// Creates the `CreateClusterError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
364    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
365        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
366            source: err.clone().into(),
367            meta: err,
368        })
369    }
370    ///
371    /// Returns error metadata, which includes the error code, message,
372    /// request ID, and potentially additional information.
373    ///
374    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
375        match self {
376            Self::ClientException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
377            Self::InvalidParameterException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
378            Self::ResourceInUseException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
379            Self::ResourceLimitExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
380            Self::ServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
381            Self::ServiceUnavailableException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
382            Self::UnsupportedAvailabilityZoneException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
383            Self::Unhandled(e) => &e.meta,
384        }
385    }
386    /// Returns `true` if the error kind is `CreateClusterError::ClientException`.
387    pub fn is_client_exception(&self) -> bool {
388        matches!(self, Self::ClientException(_))
389    }
390    /// Returns `true` if the error kind is `CreateClusterError::InvalidParameterException`.
391    pub fn is_invalid_parameter_exception(&self) -> bool {
392        matches!(self, Self::InvalidParameterException(_))
393    }
394    /// Returns `true` if the error kind is `CreateClusterError::ResourceInUseException`.
395    pub fn is_resource_in_use_exception(&self) -> bool {
396        matches!(self, Self::ResourceInUseException(_))
397    }
398    /// Returns `true` if the error kind is `CreateClusterError::ResourceLimitExceededException`.
399    pub fn is_resource_limit_exceeded_exception(&self) -> bool {
400        matches!(self, Self::ResourceLimitExceededException(_))
401    }
402    /// Returns `true` if the error kind is `CreateClusterError::ServerException`.
403    pub fn is_server_exception(&self) -> bool {
404        matches!(self, Self::ServerException(_))
405    }
406    /// Returns `true` if the error kind is `CreateClusterError::ServiceUnavailableException`.
407    pub fn is_service_unavailable_exception(&self) -> bool {
408        matches!(self, Self::ServiceUnavailableException(_))
409    }
410    /// Returns `true` if the error kind is `CreateClusterError::UnsupportedAvailabilityZoneException`.
411    pub fn is_unsupported_availability_zone_exception(&self) -> bool {
412        matches!(self, Self::UnsupportedAvailabilityZoneException(_))
413    }
414}
415impl ::std::error::Error for CreateClusterError {
416    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
417        match self {
418            Self::ClientException(_inner) => ::std::option::Option::Some(_inner),
419            Self::InvalidParameterException(_inner) => ::std::option::Option::Some(_inner),
420            Self::ResourceInUseException(_inner) => ::std::option::Option::Some(_inner),
421            Self::ResourceLimitExceededException(_inner) => ::std::option::Option::Some(_inner),
422            Self::ServerException(_inner) => ::std::option::Option::Some(_inner),
423            Self::ServiceUnavailableException(_inner) => ::std::option::Option::Some(_inner),
424            Self::UnsupportedAvailabilityZoneException(_inner) => ::std::option::Option::Some(_inner),
425            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
426        }
427    }
428}
429impl ::std::fmt::Display for CreateClusterError {
430    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
431        match self {
432            Self::ClientException(_inner) => _inner.fmt(f),
433            Self::InvalidParameterException(_inner) => _inner.fmt(f),
434            Self::ResourceInUseException(_inner) => _inner.fmt(f),
435            Self::ResourceLimitExceededException(_inner) => _inner.fmt(f),
436            Self::ServerException(_inner) => _inner.fmt(f),
437            Self::ServiceUnavailableException(_inner) => _inner.fmt(f),
438            Self::UnsupportedAvailabilityZoneException(_inner) => _inner.fmt(f),
439            Self::Unhandled(_inner) => {
440                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
441                    write!(f, "unhandled error ({code})")
442                } else {
443                    f.write_str("unhandled error")
444                }
445            }
446        }
447    }
448}
449impl ::aws_smithy_types::retry::ProvideErrorKind for CreateClusterError {
450    fn code(&self) -> ::std::option::Option<&str> {
451        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
452    }
453    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
454        ::std::option::Option::None
455    }
456}
457impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for CreateClusterError {
458    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
459        match self {
460            Self::ClientException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
461            Self::InvalidParameterException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
462            Self::ResourceInUseException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
463            Self::ResourceLimitExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
464            Self::ServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
465            Self::ServiceUnavailableException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
466            Self::UnsupportedAvailabilityZoneException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
467            Self::Unhandled(_inner) => &_inner.meta,
468        }
469    }
470}
471impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for CreateClusterError {
472    fn create_unhandled_error(
473        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
474        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
475    ) -> Self {
476        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
477            source,
478            meta: meta.unwrap_or_default(),
479        })
480    }
481}
482impl ::aws_types::request_id::RequestId for crate::operation::create_cluster::CreateClusterError {
483    fn request_id(&self) -> Option<&str> {
484        self.meta().request_id()
485    }
486}
487
488pub use crate::operation::create_cluster::_create_cluster_input::CreateClusterInput;
489
490pub use crate::operation::create_cluster::_create_cluster_output::CreateClusterOutput;
491
492mod _create_cluster_input;
493
494mod _create_cluster_output;
495
496/// Builders
497pub mod builders;
aws_sdk_eks/operation/create_cluster.rs

aws_sdk_eks/operation/
create_cluster.rs
