aws_sdk_pcs/operation/
create_compute_node_group.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `CreateComputeNodeGroup`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct CreateComputeNodeGroup;
6impl CreateComputeNodeGroup {
7    /// Creates a new `CreateComputeNodeGroup`
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_compute_node_group::CreateComputeNodeGroupInput,
14    ) -> ::std::result::Result<
15        crate::operation::create_compute_node_group::CreateComputeNodeGroupOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::create_compute_node_group::CreateComputeNodeGroupError,
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_compute_node_group::CreateComputeNodeGroupError>()
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_compute_node_group::CreateComputeNodeGroupOutput>()
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_compute_node_group::CreateComputeNodeGroupInput,
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", "CreateComputeNodeGroup", 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.CreateComputeNodeGroup",
59                "rpc.service" = "PCS",
60                "rpc.method" = "CreateComputeNodeGroup",
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_compute_node_group::CreateComputeNodeGroupInput =
76                    input.downcast_mut().expect("correct type");
77                if input.client_token.is_none() {
78                    input.client_token = ::std::option::Option::Some(token_provider.make_idempotency_token());
79                }
80            },
81        ));
82        if let ::std::option::Option::Some(config_override) = config_override {
83            for plugin in config_override.runtime_plugins.iter().cloned() {
84                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
85            }
86            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
87                config_override,
88                client_config.config.clone(),
89                &client_config.runtime_components,
90            ));
91        }
92        runtime_plugins
93    }
94}
95impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for CreateComputeNodeGroup {
96    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
97        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CreateComputeNodeGroup");
98
99        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
100            CreateComputeNodeGroupRequestSerializer,
101        ));
102        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
103            CreateComputeNodeGroupResponseDeserializer,
104        ));
105
106        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
107            crate::config::auth::Params::builder()
108                .operation_name("CreateComputeNodeGroup")
109                .build()
110                .expect("required fields set"),
111        ));
112
113        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
114            "CreateComputeNodeGroup",
115            "PCS",
116        ));
117        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
118        signing_options.double_uri_encode = true;
119        signing_options.content_sha256_header = false;
120        signing_options.normalize_uri_path = true;
121        signing_options.payload_override = None;
122
123        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
124            signing_options,
125            ..::std::default::Default::default()
126        });
127
128        ::std::option::Option::Some(cfg.freeze())
129    }
130
131    fn runtime_components(
132        &self,
133        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
134    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
135        #[allow(unused_mut)]
136        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("CreateComputeNodeGroup")
137            .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
138            .with_interceptor(CreateComputeNodeGroupEndpointParamsInterceptor)
139            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
140                crate::operation::create_compute_node_group::CreateComputeNodeGroupError,
141            >::new())
142            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
143                crate::operation::create_compute_node_group::CreateComputeNodeGroupError,
144            >::new())
145            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
146                crate::operation::create_compute_node_group::CreateComputeNodeGroupError,
147            >::new());
148
149        ::std::borrow::Cow::Owned(rcb)
150    }
151}
152
153#[derive(Debug)]
154struct CreateComputeNodeGroupResponseDeserializer;
155impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for CreateComputeNodeGroupResponseDeserializer {
156    fn deserialize_nonstreaming(
157        &self,
158        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
159    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
160        let (success, status) = (response.status().is_success(), response.status().as_u16());
161        let headers = response.headers();
162        let body = response.body().bytes().expect("body loaded");
163        #[allow(unused_mut)]
164        let mut force_error = false;
165        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
166        let parse_result = if !success && status != 200 || force_error {
167            crate::protocol_serde::shape_create_compute_node_group::de_create_compute_node_group_http_error(status, headers, body)
168        } else {
169            crate::protocol_serde::shape_create_compute_node_group::de_create_compute_node_group_http_response(status, headers, body)
170        };
171        crate::protocol_serde::type_erase_result(parse_result)
172    }
173}
174#[derive(Debug)]
175struct CreateComputeNodeGroupRequestSerializer;
176impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for CreateComputeNodeGroupRequestSerializer {
177    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
178    fn serialize_input(
179        &self,
180        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
181        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
182    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
183        let input = input
184            .downcast::<crate::operation::create_compute_node_group::CreateComputeNodeGroupInput>()
185            .expect("correct type");
186        let _header_serialization_settings = _cfg
187            .load::<crate::serialization_settings::HeaderSerializationSettings>()
188            .cloned()
189            .unwrap_or_default();
190        let mut request_builder = {
191            #[allow(clippy::uninlined_format_args)]
192            fn uri_base(
193                _input: &crate::operation::create_compute_node_group::CreateComputeNodeGroupInput,
194                output: &mut ::std::string::String,
195            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
196                use ::std::fmt::Write as _;
197                ::std::write!(output, "/").expect("formatting should succeed");
198                ::std::result::Result::Ok(())
199            }
200            #[allow(clippy::unnecessary_wraps)]
201            fn update_http_builder(
202                input: &crate::operation::create_compute_node_group::CreateComputeNodeGroupInput,
203                builder: ::http::request::Builder,
204            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
205                let mut uri = ::std::string::String::new();
206                uri_base(input, &mut uri)?;
207                ::std::result::Result::Ok(builder.method("POST").uri(uri))
208            }
209            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
210            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
211            builder = _header_serialization_settings.set_default_header(
212                builder,
213                ::http::header::HeaderName::from_static("x-amz-target"),
214                "AWSParallelComputingService.CreateComputeNodeGroup",
215            );
216            builder
217        };
218        let body = ::aws_smithy_types::body::SdkBody::from(
219            crate::protocol_serde::shape_create_compute_node_group::ser_create_compute_node_group_input(&input)?,
220        );
221        if let Some(content_length) = body.content_length() {
222            let content_length = content_length.to_string();
223            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
224        }
225        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
226    }
227}
228#[derive(Debug)]
229struct CreateComputeNodeGroupEndpointParamsInterceptor;
230
231impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateComputeNodeGroupEndpointParamsInterceptor {
232    fn name(&self) -> &'static str {
233        "CreateComputeNodeGroupEndpointParamsInterceptor"
234    }
235
236    fn read_before_execution(
237        &self,
238        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
239            '_,
240            ::aws_smithy_runtime_api::client::interceptors::context::Input,
241            ::aws_smithy_runtime_api::client::interceptors::context::Output,
242            ::aws_smithy_runtime_api::client::interceptors::context::Error,
243        >,
244        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
245    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
246        let _input = context
247            .input()
248            .downcast_ref::<CreateComputeNodeGroupInput>()
249            .ok_or("failed to downcast to CreateComputeNodeGroupInput")?;
250
251        let params = crate::config::endpoint::Params::builder()
252            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
253            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
254            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
255            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
256            .build()
257            .map_err(|err| {
258                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
259            })?;
260        cfg.interceptor_state()
261            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
262        ::std::result::Result::Ok(())
263    }
264}
265
266// The get_* functions below are generated from JMESPath expressions in the
267// operationContextParams trait. They target the operation's input shape.
268
269/// Error type for the `CreateComputeNodeGroupError` operation.
270#[non_exhaustive]
271#[derive(::std::fmt::Debug)]
272pub enum CreateComputeNodeGroupError {
273    /// <p>You don't have permission to perform the action.</p>
274    /// <p><u>Examples</u></p>
275    /// <ul>
276    /// <li>
277    /// <p>The launch template instance profile doesn't pass <code>iam:PassRole</code> verification.</p></li>
278    /// <li>
279    /// <p>There is a mismatch between the account ID and cluster ID.</p></li>
280    /// <li>
281    /// <p>The cluster ID doesn't exist.</p></li>
282    /// <li>
283    /// <p>The EC2 instance isn't present.</p></li>
284    /// </ul>
285    AccessDeniedException(crate::types::error::AccessDeniedException),
286    /// <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>
287    /// <p><u>Examples</u></p>
288    /// <ul>
289    /// <li>
290    /// <p>A cluster with the same name already exists.</p></li>
291    /// <li>
292    /// <p>A cluster isn't in <code>ACTIVE</code> status.</p></li>
293    /// <li>
294    /// <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>
295    /// <li>
296    /// <p>A queue already exists in a cluster.</p></li>
297    /// </ul>
298    ConflictException(crate::types::error::ConflictException),
299    /// <p>PCS can't process your request right now. Try again later.</p>
300    InternalServerException(crate::types::error::InternalServerException),
301    /// <p>The requested resource can't be found. The cluster, node group, or queue you're attempting to get, update, list, or delete doesn't exist.</p>
302    /// <p><u>Examples</u></p>
303    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
304    /// <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>
305    /// <p><u>Examples</u></p>
306    /// <ul>
307    /// <li>
308    /// <p>The max number of clusters or queues has been reached for the account.</p></li>
309    /// <li>
310    /// <p>The max number of compute node groups has been reached for the associated cluster.</p></li>
311    /// <li>
312    /// <p>The total of <code>maxInstances</code> across all compute node groups has been reached for associated cluster.</p></li>
313    /// </ul>
314    ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
315    /// <p>Your request exceeded a request rate quota. Check the resource's request rate quota and try again.</p>
316    ThrottlingException(crate::types::error::ThrottlingException),
317    /// <p>The request isn't valid.</p>
318    /// <p><u>Examples</u></p>
319    /// <ul>
320    /// <li>
321    /// <p>Your request contains malformed JSON or unsupported characters.</p></li>
322    /// <li>
323    /// <p>The scheduler version isn't supported.</p></li>
324    /// <li>
325    /// <p>There are networking related errors, such as network validation failure.</p></li>
326    /// <li>
327    /// <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>
328    /// </ul>
329    ValidationException(crate::types::error::ValidationException),
330    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
331    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
332    variable wildcard pattern and check `.code()`:
333     \
334    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
335     \
336    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-CreateComputeNodeGroupError) for what information is available for the error.")]
337    Unhandled(crate::error::sealed_unhandled::Unhandled),
338}
339impl CreateComputeNodeGroupError {
340    /// Creates the `CreateComputeNodeGroupError::Unhandled` variant from any error type.
341    pub fn unhandled(
342        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
343    ) -> Self {
344        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
345            source: err.into(),
346            meta: ::std::default::Default::default(),
347        })
348    }
349
350    /// Creates the `CreateComputeNodeGroupError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
351    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
352        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
353            source: err.clone().into(),
354            meta: err,
355        })
356    }
357    ///
358    /// Returns error metadata, which includes the error code, message,
359    /// request ID, and potentially additional information.
360    ///
361    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
362        match self {
363            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
364            Self::ConflictException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
365            Self::InternalServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
366            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
367            Self::ServiceQuotaExceededException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
368            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
369            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
370            Self::Unhandled(e) => &e.meta,
371        }
372    }
373    /// Returns `true` if the error kind is `CreateComputeNodeGroupError::AccessDeniedException`.
374    pub fn is_access_denied_exception(&self) -> bool {
375        matches!(self, Self::AccessDeniedException(_))
376    }
377    /// Returns `true` if the error kind is `CreateComputeNodeGroupError::ConflictException`.
378    pub fn is_conflict_exception(&self) -> bool {
379        matches!(self, Self::ConflictException(_))
380    }
381    /// Returns `true` if the error kind is `CreateComputeNodeGroupError::InternalServerException`.
382    pub fn is_internal_server_exception(&self) -> bool {
383        matches!(self, Self::InternalServerException(_))
384    }
385    /// Returns `true` if the error kind is `CreateComputeNodeGroupError::ResourceNotFoundException`.
386    pub fn is_resource_not_found_exception(&self) -> bool {
387        matches!(self, Self::ResourceNotFoundException(_))
388    }
389    /// Returns `true` if the error kind is `CreateComputeNodeGroupError::ServiceQuotaExceededException`.
390    pub fn is_service_quota_exceeded_exception(&self) -> bool {
391        matches!(self, Self::ServiceQuotaExceededException(_))
392    }
393    /// Returns `true` if the error kind is `CreateComputeNodeGroupError::ThrottlingException`.
394    pub fn is_throttling_exception(&self) -> bool {
395        matches!(self, Self::ThrottlingException(_))
396    }
397    /// Returns `true` if the error kind is `CreateComputeNodeGroupError::ValidationException`.
398    pub fn is_validation_exception(&self) -> bool {
399        matches!(self, Self::ValidationException(_))
400    }
401}
402impl ::std::error::Error for CreateComputeNodeGroupError {
403    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
404        match self {
405            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
406            Self::ConflictException(_inner) => ::std::option::Option::Some(_inner),
407            Self::InternalServerException(_inner) => ::std::option::Option::Some(_inner),
408            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
409            Self::ServiceQuotaExceededException(_inner) => ::std::option::Option::Some(_inner),
410            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
411            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
412            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
413        }
414    }
415}
416impl ::std::fmt::Display for CreateComputeNodeGroupError {
417    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
418        match self {
419            Self::AccessDeniedException(_inner) => _inner.fmt(f),
420            Self::ConflictException(_inner) => _inner.fmt(f),
421            Self::InternalServerException(_inner) => _inner.fmt(f),
422            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
423            Self::ServiceQuotaExceededException(_inner) => _inner.fmt(f),
424            Self::ThrottlingException(_inner) => _inner.fmt(f),
425            Self::ValidationException(_inner) => _inner.fmt(f),
426            Self::Unhandled(_inner) => {
427                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
428                    write!(f, "unhandled error ({code})")
429                } else {
430                    f.write_str("unhandled error")
431                }
432            }
433        }
434    }
435}
436impl ::aws_smithy_types::retry::ProvideErrorKind for CreateComputeNodeGroupError {
437    fn code(&self) -> ::std::option::Option<&str> {
438        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
439    }
440    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
441        match self {
442            Self::InternalServerException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
443            Self::ThrottlingException(inner) => ::std::option::Option::Some(inner.retryable_error_kind()),
444            _ => ::std::option::Option::None,
445        }
446    }
447}
448impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for CreateComputeNodeGroupError {
449    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
450        match self {
451            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
452            Self::ConflictException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
453            Self::InternalServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
454            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
455            Self::ServiceQuotaExceededException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
456            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
457            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
458            Self::Unhandled(_inner) => &_inner.meta,
459        }
460    }
461}
462impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for CreateComputeNodeGroupError {
463    fn create_unhandled_error(
464        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
465        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
466    ) -> Self {
467        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
468            source,
469            meta: meta.unwrap_or_default(),
470        })
471    }
472}
473impl ::aws_types::request_id::RequestId for crate::operation::create_compute_node_group::CreateComputeNodeGroupError {
474    fn request_id(&self) -> Option<&str> {
475        self.meta().request_id()
476    }
477}
478
479pub use crate::operation::create_compute_node_group::_create_compute_node_group_output::CreateComputeNodeGroupOutput;
480
481pub use crate::operation::create_compute_node_group::_create_compute_node_group_input::CreateComputeNodeGroupInput;
482
483mod _create_compute_node_group_input;
484
485mod _create_compute_node_group_output;
486
487/// Builders
488pub mod builders;
aws_sdk_pcs/operation/create_compute_node_group.rs

aws_sdk_pcs/operation/
create_compute_node_group.rs
