1#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct CreateDBInstanceReadReplica;
6impl CreateDBInstanceReadReplica {
7 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_db_instance_read_replica::CreateDbInstanceReadReplicaInput,
14 ) -> ::std::result::Result<
15 crate::operation::create_db_instance_read_replica::CreateDbInstanceReadReplicaOutput,
16 ::aws_smithy_runtime_api::client::result::SdkError<
17 crate::operation::create_db_instance_read_replica::CreateDBInstanceReadReplicaError,
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_db_instance_read_replica::CreateDBInstanceReadReplicaError>()
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_db_instance_read_replica::CreateDbInstanceReadReplicaOutput>()
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_db_instance_read_replica::CreateDbInstanceReadReplicaInput,
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", "CreateDBInstanceReadReplica", input, runtime_plugins, stop_point)
55 .instrument(::tracing::debug_span!(
58 "RDS.CreateDBInstanceReadReplica",
59 "rpc.service" = "RDS",
60 "rpc.method" = "CreateDBInstanceReadReplica",
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 CreateDBInstanceReadReplica {
88 fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89 let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CreateDBInstanceReadReplica");
90
91 cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92 CreateDBInstanceReadReplicaRequestSerializer,
93 ));
94 cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95 CreateDBInstanceReadReplicaResponseDeserializer,
96 ));
97
98 cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99 crate::config::auth::Params::builder()
100 .operation_name("CreateDBInstanceReadReplica")
101 .build()
102 .expect("required fields set"),
103 ));
104
105 cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::SensitiveOutput);
106 cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
107 "CreateDBInstanceReadReplica",
108 "RDS",
109 ));
110 let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
111 signing_options.double_uri_encode = true;
112 signing_options.content_sha256_header = false;
113 signing_options.normalize_uri_path = true;
114 signing_options.payload_override = None;
115
116 cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
117 signing_options,
118 ..::std::default::Default::default()
119 });
120
121 ::std::option::Option::Some(cfg.freeze())
122 }
123
124 fn runtime_components(
125 &self,
126 _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
127 ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
128 #[allow(unused_mut)]
129 let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("CreateDBInstanceReadReplica")
130 .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
131 CreateDBInstanceReadReplicaTelemetryInputCaptureInterceptor,
132 ))
133 .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
134 ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
135 ))
136 .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
137 CreateDBInstanceReadReplicaEndpointParamsInterceptor,
138 ))
139 .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
140 crate::operation::create_db_instance_read_replica::CreateDBInstanceReadReplicaError,
141 >::new())
142 .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
143 crate::operation::create_db_instance_read_replica::CreateDBInstanceReadReplicaError,
144 >::new())
145 .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
146 crate::operation::create_db_instance_read_replica::CreateDBInstanceReadReplicaError,
147 >::new());
148
149 ::std::borrow::Cow::Owned(rcb)
150 }
151}
152
153#[derive(Debug)]
154struct CreateDBInstanceReadReplicaTelemetryInputCaptureInterceptor;
155
156#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
157impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateDBInstanceReadReplicaTelemetryInputCaptureInterceptor {
158 fn name(&self) -> &'static str {
159 "CreateDBInstanceReadReplicaTelemetryInputCaptureInterceptor"
160 }
161
162 fn read_before_execution(
163 &self,
164 context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
165 '_,
166 ::aws_smithy_runtime_api::client::interceptors::context::Input,
167 ::aws_smithy_runtime_api::client::interceptors::context::Output,
168 ::aws_smithy_runtime_api::client::interceptors::context::Error,
169 >,
170 cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
171 ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
172 let ::std::option::Option::Some(requested) = cfg
174 .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
175 .filter(|r| !r.is_empty())
176 else {
177 return ::std::result::Result::Ok(());
178 };
179
180 let ::std::option::Option::Some(input) = context.input().downcast_ref::<CreateDbInstanceReadReplicaInput>() else {
181 return ::std::result::Result::Ok(());
183 };
184
185 let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
186 if requested.should_capture("DBInstanceIdentifier") {
187 if let ::std::option::Option::Some(value) = input.db_instance_identifier.as_deref() {
188 captured.insert("DBInstanceIdentifier", value);
189 }
190 }
191 if requested.should_capture("SourceDBInstanceIdentifier") {
192 if let ::std::option::Option::Some(value) = input.source_db_instance_identifier.as_deref() {
193 captured.insert("SourceDBInstanceIdentifier", value);
194 }
195 }
196 if requested.should_capture("DBInstanceClass") {
197 if let ::std::option::Option::Some(value) = input.db_instance_class.as_deref() {
198 captured.insert("DBInstanceClass", value);
199 }
200 }
201 if requested.should_capture("AvailabilityZone") {
202 if let ::std::option::Option::Some(value) = input.availability_zone.as_deref() {
203 captured.insert("AvailabilityZone", value);
204 }
205 }
206 if requested.should_capture("OptionGroupName") {
207 if let ::std::option::Option::Some(value) = input.option_group_name.as_deref() {
208 captured.insert("OptionGroupName", value);
209 }
210 }
211 if requested.should_capture("DBParameterGroupName") {
212 if let ::std::option::Option::Some(value) = input.db_parameter_group_name.as_deref() {
213 captured.insert("DBParameterGroupName", value);
214 }
215 }
216 if requested.should_capture("DBSubnetGroupName") {
217 if let ::std::option::Option::Some(value) = input.db_subnet_group_name.as_deref() {
218 captured.insert("DBSubnetGroupName", value);
219 }
220 }
221 if requested.should_capture("StorageType") {
222 if let ::std::option::Option::Some(value) = input.storage_type.as_deref() {
223 captured.insert("StorageType", value);
224 }
225 }
226 if requested.should_capture("MonitoringRoleArn") {
227 if let ::std::option::Option::Some(value) = input.monitoring_role_arn.as_deref() {
228 captured.insert("MonitoringRoleArn", value);
229 }
230 }
231 if requested.should_capture("KmsKeyId") {
232 if let ::std::option::Option::Some(value) = input.kms_key_id.as_deref() {
233 captured.insert("KmsKeyId", value);
234 }
235 }
236 if requested.should_capture("PerformanceInsightsKMSKeyId") {
237 if let ::std::option::Option::Some(value) = input.performance_insights_kms_key_id.as_deref() {
238 captured.insert("PerformanceInsightsKMSKeyId", value);
239 }
240 }
241 if requested.should_capture("Domain") {
242 if let ::std::option::Option::Some(value) = input.domain.as_deref() {
243 captured.insert("Domain", value);
244 }
245 }
246 if requested.should_capture("DomainIAMRoleName") {
247 if let ::std::option::Option::Some(value) = input.domain_iam_role_name.as_deref() {
248 captured.insert("DomainIAMRoleName", value);
249 }
250 }
251 if requested.should_capture("DomainFqdn") {
252 if let ::std::option::Option::Some(value) = input.domain_fqdn.as_deref() {
253 captured.insert("DomainFqdn", value);
254 }
255 }
256 if requested.should_capture("DomainOu") {
257 if let ::std::option::Option::Some(value) = input.domain_ou.as_deref() {
258 captured.insert("DomainOu", value);
259 }
260 }
261 if requested.should_capture("DomainAuthSecretArn") {
262 if let ::std::option::Option::Some(value) = input.domain_auth_secret_arn.as_deref() {
263 captured.insert("DomainAuthSecretArn", value);
264 }
265 }
266 if requested.should_capture("NetworkType") {
267 if let ::std::option::Option::Some(value) = input.network_type.as_deref() {
268 captured.insert("NetworkType", value);
269 }
270 }
271 if requested.should_capture("BackupTarget") {
272 if let ::std::option::Option::Some(value) = input.backup_target.as_deref() {
273 captured.insert("BackupTarget", value);
274 }
275 }
276 if requested.should_capture("CustomIamInstanceProfile") {
277 if let ::std::option::Option::Some(value) = input.custom_iam_instance_profile.as_deref() {
278 captured.insert("CustomIamInstanceProfile", value);
279 }
280 }
281 if requested.should_capture("SourceDBClusterIdentifier") {
282 if let ::std::option::Option::Some(value) = input.source_db_cluster_identifier.as_deref() {
283 captured.insert("SourceDBClusterIdentifier", value);
284 }
285 }
286 if requested.should_capture("CACertificateIdentifier") {
287 if let ::std::option::Option::Some(value) = input.ca_certificate_identifier.as_deref() {
288 captured.insert("CACertificateIdentifier", value);
289 }
290 }
291
292 cfg.interceptor_state().store_put(captured);
293 ::std::result::Result::Ok(())
294 }
295}
296#[derive(Debug)]
297struct CreateDBInstanceReadReplicaResponseDeserializer;
298impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for CreateDBInstanceReadReplicaResponseDeserializer {
299 fn deserialize_nonstreaming_with_config(
300 &self,
301 response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
302 _cfg: &::aws_smithy_types::config_bag::ConfigBag,
303 ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
304 let (success, status) = (response.status().is_success(), response.status().as_u16());
305 let headers = response.headers();
306 let body = response.body().bytes().expect("body loaded");
307 #[allow(unused_mut)]
308 let mut force_error = false;
309 ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
310 let parse_result = if !success && status != 200 || force_error {
311 crate::protocol_serde::shape_create_db_instance_read_replica::de_create_db_instance_read_replica_http_error(status, headers, body)
312 } else {
313 crate::protocol_serde::shape_create_db_instance_read_replica::de_create_db_instance_read_replica_http_response(status, headers, body)
314 };
315 crate::protocol_serde::type_erase_result(parse_result)
316 }
317}
318#[derive(Debug)]
319struct CreateDBInstanceReadReplicaRequestSerializer;
320impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for CreateDBInstanceReadReplicaRequestSerializer {
321 #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
322 fn serialize_input(
323 &self,
324 input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
325 _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
326 ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
327 let input = input
328 .downcast::<crate::operation::create_db_instance_read_replica::CreateDbInstanceReadReplicaInput>()
329 .expect("correct type");
330 let _header_serialization_settings = _cfg
331 .load::<crate::serialization_settings::HeaderSerializationSettings>()
332 .cloned()
333 .unwrap_or_default();
334 let mut request_builder = {
335 #[allow(clippy::uninlined_format_args)]
336 fn uri_base(
337 _input: &crate::operation::create_db_instance_read_replica::CreateDbInstanceReadReplicaInput,
338 output: &mut ::std::string::String,
339 ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
340 use ::std::fmt::Write as _;
341 ::std::write!(output, "/").expect("formatting should succeed");
342 ::std::result::Result::Ok(())
343 }
344 #[allow(clippy::unnecessary_wraps)]
345 fn update_http_builder(
346 input: &crate::operation::create_db_instance_read_replica::CreateDbInstanceReadReplicaInput,
347 builder: ::http_1x::request::Builder,
348 ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
349 let mut uri = ::std::string::String::new();
350 uri_base(input, &mut uri)?;
351 ::std::result::Result::Ok(builder.method("POST").uri(uri))
352 }
353 let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
354 builder =
355 _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/x-www-form-urlencoded");
356 builder
357 };
358 let body = ::aws_smithy_types::body::SdkBody::from(
359 crate::protocol_serde::shape_create_db_instance_read_replica_input::ser_create_db_instance_read_replica_input_input_input(&input)?,
360 );
361 if let Some(content_length) = body.content_length() {
362 let content_length = content_length.to_string();
363 request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
364 }
365 ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
366 }
367}
368#[derive(Debug)]
369struct CreateDBInstanceReadReplicaEndpointParamsInterceptor;
370
371#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
372impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateDBInstanceReadReplicaEndpointParamsInterceptor {
373 fn name(&self) -> &'static str {
374 "CreateDBInstanceReadReplicaEndpointParamsInterceptor"
375 }
376
377 fn read_before_execution(
378 &self,
379 context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
380 '_,
381 ::aws_smithy_runtime_api::client::interceptors::context::Input,
382 ::aws_smithy_runtime_api::client::interceptors::context::Output,
383 ::aws_smithy_runtime_api::client::interceptors::context::Error,
384 >,
385 cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
386 ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
387 let _input = context
388 .input()
389 .downcast_ref::<CreateDbInstanceReadReplicaInput>()
390 .ok_or("failed to downcast to CreateDbInstanceReadReplicaInput")?;
391
392 let params = crate::config::endpoint::Params::builder()
393 .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
394 .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
395 .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
396 .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
397 .build()
398 .map_err(|err| {
399 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
400 })?;
401 cfg.interceptor_state()
402 .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
403 ::std::result::Result::Ok(())
404 }
405}
406
407#[non_exhaustive]
412#[derive(::std::fmt::Debug)]
413pub enum CreateDBInstanceReadReplicaError {
414 CertificateNotFoundFault(crate::types::error::CertificateNotFoundFault),
416 DbClusterNotFoundFault(crate::types::error::DbClusterNotFoundFault),
418 DbInstanceAlreadyExistsFault(crate::types::error::DbInstanceAlreadyExistsFault),
420 DbInstanceNotFoundFault(crate::types::error::DbInstanceNotFoundFault),
422 DbParameterGroupNotFoundFault(crate::types::error::DbParameterGroupNotFoundFault),
424 DbSecurityGroupNotFoundFault(crate::types::error::DbSecurityGroupNotFoundFault),
426 DbSubnetGroupDoesNotCoverEnoughAZs(crate::types::error::DbSubnetGroupDoesNotCoverEnoughAZs),
428 DbSubnetGroupNotAllowedFault(crate::types::error::DbSubnetGroupNotAllowedFault),
430 DbSubnetGroupNotFoundFault(crate::types::error::DbSubnetGroupNotFoundFault),
432 DomainNotFoundFault(crate::types::error::DomainNotFoundFault),
434 InstanceQuotaExceededFault(crate::types::error::InstanceQuotaExceededFault),
436 InsufficientDbInstanceCapacityFault(crate::types::error::InsufficientDbInstanceCapacityFault),
438 InvalidDbClusterStateFault(crate::types::error::InvalidDbClusterStateFault),
440 InvalidDbInstanceStateFault(crate::types::error::InvalidDbInstanceStateFault),
442 InvalidDbSubnetGroupFault(crate::types::error::InvalidDbSubnetGroupFault),
444 InvalidSubnet(crate::types::error::InvalidSubnet),
446 InvalidVpcNetworkStateFault(crate::types::error::InvalidVpcNetworkStateFault),
448 KmsKeyNotAccessibleFault(crate::types::error::KmsKeyNotAccessibleFault),
450 NetworkTypeNotSupported(crate::types::error::NetworkTypeNotSupported),
452 OptionGroupNotFoundFault(crate::types::error::OptionGroupNotFoundFault),
454 ProvisionedIopsNotAvailableInAzFault(crate::types::error::ProvisionedIopsNotAvailableInAzFault),
456 StorageQuotaExceededFault(crate::types::error::StorageQuotaExceededFault),
458 StorageTypeNotSupportedFault(crate::types::error::StorageTypeNotSupportedFault),
460 TenantDatabaseQuotaExceededFault(crate::types::error::TenantDatabaseQuotaExceededFault),
462 VpcEncryptionControlViolationException(crate::types::error::VpcEncryptionControlViolationException),
464 #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
466 variable wildcard pattern and check `.code()`:
467 \
468 `err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
469 \
470 See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-CreateDBInstanceReadReplicaError) for what information is available for the error.")]
471 Unhandled(crate::error::sealed_unhandled::Unhandled),
472}
473impl CreateDBInstanceReadReplicaError {
474 pub fn unhandled(
476 err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
477 ) -> Self {
478 Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
479 source: err.into(),
480 meta: ::std::default::Default::default(),
481 })
482 }
483
484 pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
486 Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
487 source: err.clone().into(),
488 meta: err,
489 })
490 }
491 pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
496 match self {
497 Self::CertificateNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
498 Self::DbClusterNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
499 Self::DbInstanceAlreadyExistsFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
500 Self::DbInstanceNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
501 Self::DbParameterGroupNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
502 Self::DbSecurityGroupNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
503 Self::DbSubnetGroupDoesNotCoverEnoughAZs(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
504 Self::DbSubnetGroupNotAllowedFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
505 Self::DbSubnetGroupNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
506 Self::DomainNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
507 Self::InstanceQuotaExceededFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
508 Self::InsufficientDbInstanceCapacityFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
509 Self::InvalidDbClusterStateFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
510 Self::InvalidDbInstanceStateFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
511 Self::InvalidDbSubnetGroupFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
512 Self::InvalidSubnet(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
513 Self::InvalidVpcNetworkStateFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
514 Self::KmsKeyNotAccessibleFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
515 Self::NetworkTypeNotSupported(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
516 Self::OptionGroupNotFoundFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
517 Self::ProvisionedIopsNotAvailableInAzFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
518 Self::StorageQuotaExceededFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
519 Self::StorageTypeNotSupportedFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
520 Self::TenantDatabaseQuotaExceededFault(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
521 Self::VpcEncryptionControlViolationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
522 Self::Unhandled(e) => &e.meta,
523 }
524 }
525 pub fn is_certificate_not_found_fault(&self) -> bool {
527 matches!(self, Self::CertificateNotFoundFault(_))
528 }
529 pub fn is_db_cluster_not_found_fault(&self) -> bool {
531 matches!(self, Self::DbClusterNotFoundFault(_))
532 }
533 pub fn is_db_instance_already_exists_fault(&self) -> bool {
535 matches!(self, Self::DbInstanceAlreadyExistsFault(_))
536 }
537 pub fn is_db_instance_not_found_fault(&self) -> bool {
539 matches!(self, Self::DbInstanceNotFoundFault(_))
540 }
541 pub fn is_db_parameter_group_not_found_fault(&self) -> bool {
543 matches!(self, Self::DbParameterGroupNotFoundFault(_))
544 }
545 pub fn is_db_security_group_not_found_fault(&self) -> bool {
547 matches!(self, Self::DbSecurityGroupNotFoundFault(_))
548 }
549 pub fn is_db_subnet_group_does_not_cover_enough_azs(&self) -> bool {
551 matches!(self, Self::DbSubnetGroupDoesNotCoverEnoughAZs(_))
552 }
553 pub fn is_db_subnet_group_not_allowed_fault(&self) -> bool {
555 matches!(self, Self::DbSubnetGroupNotAllowedFault(_))
556 }
557 pub fn is_db_subnet_group_not_found_fault(&self) -> bool {
559 matches!(self, Self::DbSubnetGroupNotFoundFault(_))
560 }
561 pub fn is_domain_not_found_fault(&self) -> bool {
563 matches!(self, Self::DomainNotFoundFault(_))
564 }
565 pub fn is_instance_quota_exceeded_fault(&self) -> bool {
567 matches!(self, Self::InstanceQuotaExceededFault(_))
568 }
569 pub fn is_insufficient_db_instance_capacity_fault(&self) -> bool {
571 matches!(self, Self::InsufficientDbInstanceCapacityFault(_))
572 }
573 pub fn is_invalid_db_cluster_state_fault(&self) -> bool {
575 matches!(self, Self::InvalidDbClusterStateFault(_))
576 }
577 pub fn is_invalid_db_instance_state_fault(&self) -> bool {
579 matches!(self, Self::InvalidDbInstanceStateFault(_))
580 }
581 pub fn is_invalid_db_subnet_group_fault(&self) -> bool {
583 matches!(self, Self::InvalidDbSubnetGroupFault(_))
584 }
585 pub fn is_invalid_subnet(&self) -> bool {
587 matches!(self, Self::InvalidSubnet(_))
588 }
589 pub fn is_invalid_vpc_network_state_fault(&self) -> bool {
591 matches!(self, Self::InvalidVpcNetworkStateFault(_))
592 }
593 pub fn is_kms_key_not_accessible_fault(&self) -> bool {
595 matches!(self, Self::KmsKeyNotAccessibleFault(_))
596 }
597 pub fn is_network_type_not_supported(&self) -> bool {
599 matches!(self, Self::NetworkTypeNotSupported(_))
600 }
601 pub fn is_option_group_not_found_fault(&self) -> bool {
603 matches!(self, Self::OptionGroupNotFoundFault(_))
604 }
605 pub fn is_provisioned_iops_not_available_in_az_fault(&self) -> bool {
607 matches!(self, Self::ProvisionedIopsNotAvailableInAzFault(_))
608 }
609 pub fn is_storage_quota_exceeded_fault(&self) -> bool {
611 matches!(self, Self::StorageQuotaExceededFault(_))
612 }
613 pub fn is_storage_type_not_supported_fault(&self) -> bool {
615 matches!(self, Self::StorageTypeNotSupportedFault(_))
616 }
617 pub fn is_tenant_database_quota_exceeded_fault(&self) -> bool {
619 matches!(self, Self::TenantDatabaseQuotaExceededFault(_))
620 }
621 pub fn is_vpc_encryption_control_violation_exception(&self) -> bool {
623 matches!(self, Self::VpcEncryptionControlViolationException(_))
624 }
625}
626impl ::std::error::Error for CreateDBInstanceReadReplicaError {
627 fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
628 match self {
629 Self::CertificateNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
630 Self::DbClusterNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
631 Self::DbInstanceAlreadyExistsFault(_inner) => ::std::option::Option::Some(_inner),
632 Self::DbInstanceNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
633 Self::DbParameterGroupNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
634 Self::DbSecurityGroupNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
635 Self::DbSubnetGroupDoesNotCoverEnoughAZs(_inner) => ::std::option::Option::Some(_inner),
636 Self::DbSubnetGroupNotAllowedFault(_inner) => ::std::option::Option::Some(_inner),
637 Self::DbSubnetGroupNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
638 Self::DomainNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
639 Self::InstanceQuotaExceededFault(_inner) => ::std::option::Option::Some(_inner),
640 Self::InsufficientDbInstanceCapacityFault(_inner) => ::std::option::Option::Some(_inner),
641 Self::InvalidDbClusterStateFault(_inner) => ::std::option::Option::Some(_inner),
642 Self::InvalidDbInstanceStateFault(_inner) => ::std::option::Option::Some(_inner),
643 Self::InvalidDbSubnetGroupFault(_inner) => ::std::option::Option::Some(_inner),
644 Self::InvalidSubnet(_inner) => ::std::option::Option::Some(_inner),
645 Self::InvalidVpcNetworkStateFault(_inner) => ::std::option::Option::Some(_inner),
646 Self::KmsKeyNotAccessibleFault(_inner) => ::std::option::Option::Some(_inner),
647 Self::NetworkTypeNotSupported(_inner) => ::std::option::Option::Some(_inner),
648 Self::OptionGroupNotFoundFault(_inner) => ::std::option::Option::Some(_inner),
649 Self::ProvisionedIopsNotAvailableInAzFault(_inner) => ::std::option::Option::Some(_inner),
650 Self::StorageQuotaExceededFault(_inner) => ::std::option::Option::Some(_inner),
651 Self::StorageTypeNotSupportedFault(_inner) => ::std::option::Option::Some(_inner),
652 Self::TenantDatabaseQuotaExceededFault(_inner) => ::std::option::Option::Some(_inner),
653 Self::VpcEncryptionControlViolationException(_inner) => ::std::option::Option::Some(_inner),
654 Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
655 }
656 }
657}
658impl ::std::fmt::Display for CreateDBInstanceReadReplicaError {
659 fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
660 match self {
661 Self::CertificateNotFoundFault(_inner) => _inner.fmt(f),
662 Self::DbClusterNotFoundFault(_inner) => _inner.fmt(f),
663 Self::DbInstanceAlreadyExistsFault(_inner) => _inner.fmt(f),
664 Self::DbInstanceNotFoundFault(_inner) => _inner.fmt(f),
665 Self::DbParameterGroupNotFoundFault(_inner) => _inner.fmt(f),
666 Self::DbSecurityGroupNotFoundFault(_inner) => _inner.fmt(f),
667 Self::DbSubnetGroupDoesNotCoverEnoughAZs(_inner) => _inner.fmt(f),
668 Self::DbSubnetGroupNotAllowedFault(_inner) => _inner.fmt(f),
669 Self::DbSubnetGroupNotFoundFault(_inner) => _inner.fmt(f),
670 Self::DomainNotFoundFault(_inner) => _inner.fmt(f),
671 Self::InstanceQuotaExceededFault(_inner) => _inner.fmt(f),
672 Self::InsufficientDbInstanceCapacityFault(_inner) => _inner.fmt(f),
673 Self::InvalidDbClusterStateFault(_inner) => _inner.fmt(f),
674 Self::InvalidDbInstanceStateFault(_inner) => _inner.fmt(f),
675 Self::InvalidDbSubnetGroupFault(_inner) => _inner.fmt(f),
676 Self::InvalidSubnet(_inner) => _inner.fmt(f),
677 Self::InvalidVpcNetworkStateFault(_inner) => _inner.fmt(f),
678 Self::KmsKeyNotAccessibleFault(_inner) => _inner.fmt(f),
679 Self::NetworkTypeNotSupported(_inner) => _inner.fmt(f),
680 Self::OptionGroupNotFoundFault(_inner) => _inner.fmt(f),
681 Self::ProvisionedIopsNotAvailableInAzFault(_inner) => _inner.fmt(f),
682 Self::StorageQuotaExceededFault(_inner) => _inner.fmt(f),
683 Self::StorageTypeNotSupportedFault(_inner) => _inner.fmt(f),
684 Self::TenantDatabaseQuotaExceededFault(_inner) => _inner.fmt(f),
685 Self::VpcEncryptionControlViolationException(_inner) => _inner.fmt(f),
686 Self::Unhandled(_inner) => {
687 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
688 write!(f, "unhandled error ({code})")
689 } else {
690 f.write_str("unhandled error")
691 }
692 }
693 }
694 }
695}
696impl ::aws_smithy_types::retry::ProvideErrorKind for CreateDBInstanceReadReplicaError {
697 fn code(&self) -> ::std::option::Option<&str> {
698 ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
699 }
700 fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
701 ::std::option::Option::None
702 }
703}
704impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for CreateDBInstanceReadReplicaError {
705 fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
706 match self {
707 Self::CertificateNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
708 Self::DbClusterNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
709 Self::DbInstanceAlreadyExistsFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
710 Self::DbInstanceNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
711 Self::DbParameterGroupNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
712 Self::DbSecurityGroupNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
713 Self::DbSubnetGroupDoesNotCoverEnoughAZs(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
714 Self::DbSubnetGroupNotAllowedFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
715 Self::DbSubnetGroupNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
716 Self::DomainNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
717 Self::InstanceQuotaExceededFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
718 Self::InsufficientDbInstanceCapacityFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
719 Self::InvalidDbClusterStateFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
720 Self::InvalidDbInstanceStateFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
721 Self::InvalidDbSubnetGroupFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
722 Self::InvalidSubnet(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
723 Self::InvalidVpcNetworkStateFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
724 Self::KmsKeyNotAccessibleFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
725 Self::NetworkTypeNotSupported(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
726 Self::OptionGroupNotFoundFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
727 Self::ProvisionedIopsNotAvailableInAzFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
728 Self::StorageQuotaExceededFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
729 Self::StorageTypeNotSupportedFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
730 Self::TenantDatabaseQuotaExceededFault(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
731 Self::VpcEncryptionControlViolationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
732 Self::Unhandled(_inner) => &_inner.meta,
733 }
734 }
735}
736impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for CreateDBInstanceReadReplicaError {
737 fn create_unhandled_error(
738 source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
739 meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
740 ) -> Self {
741 Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
742 source,
743 meta: meta.unwrap_or_default(),
744 })
745 }
746}
747impl ::aws_types::request_id::RequestId for crate::operation::create_db_instance_read_replica::CreateDBInstanceReadReplicaError {
748 fn request_id(&self) -> Option<&str> {
749 self.meta().request_id()
750 }
751}
752
753pub use crate::operation::create_db_instance_read_replica::_create_db_instance_read_replica_input::CreateDbInstanceReadReplicaInput;
754
755pub use crate::operation::create_db_instance_read_replica::_create_db_instance_read_replica_output::CreateDbInstanceReadReplicaOutput;
756
757mod _create_db_instance_read_replica_input;
758
759mod _create_db_instance_read_replica_output;
760
761pub mod builders;