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

aws_sdk_eks/operation/
create_cluster.rs
