aws_sdk_rds/operation/
delete_db_cluster_parameter_group.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `DeleteDBClusterParameterGroup`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct DeleteDBClusterParameterGroup;
6impl DeleteDBClusterParameterGroup {
7    /// Creates a new `DeleteDBClusterParameterGroup`
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::delete_db_cluster_parameter_group::DeleteDbClusterParameterGroupInput,
14    ) -> ::std::result::Result<
15        crate::operation::delete_db_cluster_parameter_group::DeleteDbClusterParameterGroupOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::delete_db_cluster_parameter_group::DeleteDBClusterParameterGroupError,
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::delete_db_cluster_parameter_group::DeleteDBClusterParameterGroupError>()
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::delete_db_cluster_parameter_group::DeleteDbClusterParameterGroupOutput>()
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::delete_db_cluster_parameter_group::DeleteDbClusterParameterGroupInput,
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("RDS", "DeleteDBClusterParameterGroup", 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                "RDS.DeleteDBClusterParameterGroup",
59                "rpc.service" = "RDS",
60                "rpc.method" = "DeleteDBClusterParameterGroup",
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
74        if let ::std::option::Option::Some(config_override) = config_override {
75            for plugin in config_override.runtime_plugins.iter().cloned() {
76                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
77            }
78            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
79                config_override,
80                client_config.config.clone(),
81                &client_config.runtime_components,
82            ));
83        }
84        runtime_plugins
85    }
86}
87impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for DeleteDBClusterParameterGroup {
88    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("DeleteDBClusterParameterGroup");
90
91        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92            DeleteDBClusterParameterGroupRequestSerializer,
93        ));
94        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95            DeleteDBClusterParameterGroupResponseDeserializer,
96        ));
97
98        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99            crate::config::auth::Params::builder()
100                .operation_name("DeleteDBClusterParameterGroup")
101                .build()
102                .expect("required fields set"),
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
106            "DeleteDBClusterParameterGroup",
107            "RDS",
108        ));
109        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
110        signing_options.double_uri_encode = true;
111        signing_options.content_sha256_header = false;
112        signing_options.normalize_uri_path = true;
113        signing_options.payload_override = None;
114
115        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
116            signing_options,
117            ..::std::default::Default::default()
118        });
119
120        ::std::option::Option::Some(cfg.freeze())
121    }
122
123    fn runtime_components(
124        &self,
125        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
126    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
127        #[allow(unused_mut)]
128        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("DeleteDBClusterParameterGroup")
129            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
130                DeleteDBClusterParameterGroupTelemetryInputCaptureInterceptor,
131            ))
132            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
133                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
134            ))
135            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
136                DeleteDBClusterParameterGroupEndpointParamsInterceptor,
137            ))
138            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
139                crate::operation::delete_db_cluster_parameter_group::DeleteDBClusterParameterGroupError,
140            >::new())
141            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
142                crate::operation::delete_db_cluster_parameter_group::DeleteDBClusterParameterGroupError,
143            >::new())
144            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
145                crate::operation::delete_db_cluster_parameter_group::DeleteDBClusterParameterGroupError,
146            >::new());
147
148        ::std::borrow::Cow::Owned(rcb)
149    }
150}
151
152#[derive(Debug)]
153struct DeleteDBClusterParameterGroupTelemetryInputCaptureInterceptor;
154
155#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
156impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DeleteDBClusterParameterGroupTelemetryInputCaptureInterceptor {
157    fn name(&self) -> &'static str {
158        "DeleteDBClusterParameterGroupTelemetryInputCaptureInterceptor"
159    }
160
161    fn read_before_execution(
162        &self,
163        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
164            '_,
165            ::aws_smithy_runtime_api::client::interceptors::context::Input,
166            ::aws_smithy_runtime_api::client::interceptors::context::Output,
167            ::aws_smithy_runtime_api::client::interceptors::context::Error,
168        >,
169        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
170    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
171        // Nothing to do unless the customer opted in by naming members to record.
172        let ::std::option::Option::Some(requested) = cfg
173            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
174            .filter(|r| !r.is_empty())
175        else {
176            return ::std::result::Result::Ok(());
177        };
178
179        let ::std::option::Option::Some(input) = context.input().downcast_ref::<DeleteDbClusterParameterGroupInput>() else {
180            // A mismatched input is not this interceptor's concern; skip quietly.
181            return ::std::result::Result::Ok(());
182        };
183
184        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
185        if requested.should_capture("DBClusterParameterGroupName") {
186            if let ::std::option::Option::Some(value) = input.db_cluster_parameter_group_name.as_deref() {
187                captured.insert("DBClusterParameterGroupName", value);
188            }
189        }
190
191        cfg.interceptor_state().store_put(captured);
192        ::std::result::Result::Ok(())
193    }
194}
195#[derive(Debug)]
196struct DeleteDBClusterParameterGroupResponseDeserializer;
197impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for DeleteDBClusterParameterGroupResponseDeserializer {
198    fn deserialize_nonstreaming_with_config(
199        &self,
200        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
201        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
202    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
203        let (success, status) = (response.status().is_success(), response.status().as_u16());
204        let headers = response.headers();
205        let body = response.body().bytes().expect("body loaded");
206        #[allow(unused_mut)]
207        let mut force_error = false;
208        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
209        let parse_result = if !success && status != 200 || force_error {
210            crate::protocol_serde::shape_delete_db_cluster_parameter_group::de_delete_db_cluster_parameter_group_http_error(status, headers, body)
211        } else {
212            crate::protocol_serde::shape_delete_db_cluster_parameter_group::de_delete_db_cluster_parameter_group_http_response(status, headers, body)
213        };
214        crate::protocol_serde::type_erase_result(parse_result)
215    }
216}
217#[derive(Debug)]
218struct DeleteDBClusterParameterGroupRequestSerializer;
219impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for DeleteDBClusterParameterGroupRequestSerializer {
220    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
221    fn serialize_input(
222        &self,
223        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
224        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
225    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
226        let input = input
227            .downcast::<crate::operation::delete_db_cluster_parameter_group::DeleteDbClusterParameterGroupInput>()
228            .expect("correct type");
229        let _header_serialization_settings = _cfg
230            .load::<crate::serialization_settings::HeaderSerializationSettings>()
231            .cloned()
232            .unwrap_or_default();
233        let mut request_builder = {
234            #[allow(clippy::uninlined_format_args)]
235            fn uri_base(
236                _input: &crate::operation::delete_db_cluster_parameter_group::DeleteDbClusterParameterGroupInput,
237                output: &mut ::std::string::String,
238            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
239                use ::std::fmt::Write as _;
240                ::std::write!(output, "/").expect("formatting should succeed");
241                ::std::result::Result::Ok(())
242            }
243            #[allow(clippy::unnecessary_wraps)]
244            fn update_http_builder(
245                input: &crate::operation::delete_db_cluster_parameter_group::DeleteDbClusterParameterGroupInput,
246                builder: ::http_1x::request::Builder,
247            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
248                let mut uri = ::std::string::String::new();
249                uri_base(input, &mut uri)?;
250                ::std::result::Result::Ok(builder.method("POST").uri(uri))
251            }
252            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
253            builder =
254                _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/x-www-form-urlencoded");
255            builder
256        };
257        let body = ::aws_smithy_types::body::SdkBody::from(
258            crate::protocol_serde::shape_delete_db_cluster_parameter_group_input::ser_delete_db_cluster_parameter_group_input_input_input(&input)?,
259        );
260        if let Some(content_length) = body.content_length() {
261            let content_length = content_length.to_string();
262            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
263        }
264        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
265    }
266}
267#[derive(Debug)]
268struct DeleteDBClusterParameterGroupEndpointParamsInterceptor;
269
270#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
271impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DeleteDBClusterParameterGroupEndpointParamsInterceptor {
272    fn name(&self) -> &'static str {
273        "DeleteDBClusterParameterGroupEndpointParamsInterceptor"
274    }
275
276    fn read_before_execution(
277        &self,
278        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
279            '_,
280            ::aws_smithy_runtime_api::client::interceptors::context::Input,
281            ::aws_smithy_runtime_api::client::interceptors::context::Output,
282            ::aws_smithy_runtime_api::client::interceptors::context::Error,
283        >,
284        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
285    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
286        let _input = context
287            .input()
288            .downcast_ref::<DeleteDbClusterParameterGroupInput>()
289            .ok_or("failed to downcast to DeleteDbClusterParameterGroupInput")?;
290
291        let params = crate::config::endpoint::Params::builder()
292            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
293            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
294            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
295            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
296            .build()
297            .map_err(|err| {
298                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
299            })?;
300        cfg.interceptor_state()
301            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
302        ::std::result::Result::Ok(())
303    }
304}
305
306// The get_* functions below are generated from JMESPath expressions in the
307// operationContextParams trait. They target the operation's input shape.
308
309/// Error type for the `DeleteDBClusterParameterGroupError` operation.
310#[non_exhaustive]
311#[derive(::std::fmt::Debug)]
312pub enum DeleteDBClusterParameterGroupError {
313    /// <p><code>DBParameterGroupName</code> doesn't refer to an existing DB parameter group.</p>
314    DbParameterGroupNotFoundFault(crate::types::error::DbParameterGroupNotFoundFault),
315    /// <p>The DB parameter group is in use or is in an invalid state. If you are attempting to delete the parameter group, you can't delete it when the parameter group is in this state.</p>
316    InvalidDbParameterGroupStateFault(crate::types::error::InvalidDbParameterGroupStateFault),
317    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
318    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
319    variable wildcard pattern and check `.code()`:
320     \
321    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
322     \
323    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DeleteDBClusterParameterGroupError) for what information is available for the error.")]
324    Unhandled(crate::error::sealed_unhandled::Unhandled),
325}
326impl DeleteDBClusterParameterGroupError {
327    /// Creates the `DeleteDBClusterParameterGroupError::Unhandled` variant from any error type.
328    pub fn unhandled(
329        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
330    ) -> Self {
331        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
332            source: err.into(),
333            meta: ::std::default::Default::default(),
334        })
335    }
336
337    /// Creates the `DeleteDBClusterParameterGroupError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
338    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
339        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
340            source: err.clone().into(),
341            meta: err,
342        })
343    }
344    ///
345    /// Returns error metadata, which includes the error code, message,
346    /// request ID, and potentially additional information.
347    ///
348    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
349        match self {
350            Self::DbParameterGroupNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
351            Self::InvalidDbParameterGroupStateFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
352            Self::Unhandled(e) => &e.meta,
353        }
354    }
355    /// Returns `true` if the error kind is `DeleteDBClusterParameterGroupError::DbParameterGroupNotFoundFault`.
356    pub fn is_db_parameter_group_not_found_fault(&self) -> bool {
357        matches!(self, Self::DbParameterGroupNotFoundFault(_))
358    }
359    /// Returns `true` if the error kind is `DeleteDBClusterParameterGroupError::InvalidDbParameterGroupStateFault`.
360    pub fn is_invalid_db_parameter_group_state_fault(&self) -> bool {
361        matches!(self, Self::InvalidDbParameterGroupStateFault(_))
362    }
363}
364impl ::std::error::Error for DeleteDBClusterParameterGroupError {
365    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
366        match self {
367            Self::DbParameterGroupNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
368            Self::InvalidDbParameterGroupStateFault(_inner) => ::std::option::Option::Some(_inner),
369            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
370        }
371    }
372}
373impl ::std::fmt::Display for DeleteDBClusterParameterGroupError {
374    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
375        match self {
376            Self::DbParameterGroupNotFoundFault(_inner) => _inner.fmt(f),
377            Self::InvalidDbParameterGroupStateFault(_inner) => _inner.fmt(f),
378            Self::Unhandled(_inner) => {
379                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
380                    write!(f, "unhandled error ({code})")
381                } else {
382                    f.write_str("unhandled error")
383                }
384            }
385        }
386    }
387}
388impl ::aws_smithy_types::retry::ProvideErrorKind for DeleteDBClusterParameterGroupError {
389    fn code(&self) -> ::std::option::Option<&str> {
390        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
391    }
392    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
393        ::std::option::Option::None
394    }
395}
396impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for DeleteDBClusterParameterGroupError {
397    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
398        match self {
399            Self::DbParameterGroupNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
400            Self::InvalidDbParameterGroupStateFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
401            Self::Unhandled(_inner) => &_inner.meta,
402        }
403    }
404}
405impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for DeleteDBClusterParameterGroupError {
406    fn create_unhandled_error(
407        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
408        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
409    ) -> Self {
410        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
411            source,
412            meta: meta.unwrap_or_default(),
413        })
414    }
415}
416impl ::aws_types::request_id::RequestId for crate::operation::delete_db_cluster_parameter_group::DeleteDBClusterParameterGroupError {
417    fn request_id(&self) -> Option<&str> {
418        self.meta().request_id()
419    }
420}
421
422pub use crate::operation::delete_db_cluster_parameter_group::_delete_db_cluster_parameter_group_input::DeleteDbClusterParameterGroupInput;
423
424pub use crate::operation::delete_db_cluster_parameter_group::_delete_db_cluster_parameter_group_output::DeleteDbClusterParameterGroupOutput;
425
426mod _delete_db_cluster_parameter_group_input;
427
428mod _delete_db_cluster_parameter_group_output;
429
430/// Builders
431pub mod builders;
aws_sdk_rds/operation/delete_db_cluster_parameter_group.rs

aws_sdk_rds/operation/
delete_db_cluster_parameter_group.rs
