1use std::error::Error;
14use std::fmt;
15
16use async_trait::async_trait;
17use rusoto_core::credential::ProvideAwsCredentials;
18use rusoto_core::region;
19use rusoto_core::request::{BufferedHttpResponse, DispatchSignedRequest};
20use rusoto_core::{Client, RusotoError};
21
22use rusoto_core::proto;
23use rusoto_core::request::HttpResponse;
24use rusoto_core::signature::SignedRequest;
25#[allow(unused_imports)]
26use serde::{Deserialize, Serialize};
27
28impl DatabaseMigrationServiceClient {
29 fn new_signed_request(&self, http_method: &str, request_uri: &str) -> SignedRequest {
30 let mut request = SignedRequest::new(http_method, "dms", &self.region, request_uri);
31
32 request.set_content_type("application/x-amz-json-1.1".to_owned());
33
34 request
35 }
36
37 async fn sign_and_dispatch<E>(
38 &self,
39 request: SignedRequest,
40 from_response: fn(BufferedHttpResponse) -> RusotoError<E>,
41 ) -> Result<HttpResponse, RusotoError<E>> {
42 let mut response = self.client.sign_and_dispatch(request).await?;
43 if !response.status.is_success() {
44 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
45 return Err(from_response(response));
46 }
47
48 Ok(response)
49 }
50}
51
52use serde_json;
53#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
55#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
56pub struct AccountQuota {
57 #[serde(rename = "AccountQuotaName")]
59 #[serde(skip_serializing_if = "Option::is_none")]
60 pub account_quota_name: Option<String>,
61 #[serde(rename = "Max")]
63 #[serde(skip_serializing_if = "Option::is_none")]
64 pub max: Option<i64>,
65 #[serde(rename = "Used")]
67 #[serde(skip_serializing_if = "Option::is_none")]
68 pub used: Option<i64>,
69}
70
71#[derive(Clone, Debug, Default, PartialEq, Serialize)]
73#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
74pub struct AddTagsToResourceMessage {
75 #[serde(rename = "ResourceArn")]
77 pub resource_arn: String,
78 #[serde(rename = "Tags")]
80 pub tags: Vec<Tag>,
81}
82
83#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
85#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
86pub struct AddTagsToResourceResponse {}
87
88#[derive(Clone, Debug, Default, PartialEq, Serialize)]
90#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
91pub struct ApplyPendingMaintenanceActionMessage {
92 #[serde(rename = "ApplyAction")]
94 pub apply_action: String,
95 #[serde(rename = "OptInType")]
97 pub opt_in_type: String,
98 #[serde(rename = "ReplicationInstanceArn")]
100 pub replication_instance_arn: String,
101}
102
103#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
105#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
106pub struct ApplyPendingMaintenanceActionResponse {
107 #[serde(rename = "ResourcePendingMaintenanceActions")]
109 #[serde(skip_serializing_if = "Option::is_none")]
110 pub resource_pending_maintenance_actions: Option<ResourcePendingMaintenanceActions>,
111}
112
113#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
115#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
116pub struct AvailabilityZone {
117 #[serde(rename = "Name")]
119 #[serde(skip_serializing_if = "Option::is_none")]
120 pub name: Option<String>,
121}
122
123#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
125#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
126pub struct Certificate {
127 #[serde(rename = "CertificateArn")]
129 #[serde(skip_serializing_if = "Option::is_none")]
130 pub certificate_arn: Option<String>,
131 #[serde(rename = "CertificateCreationDate")]
133 #[serde(skip_serializing_if = "Option::is_none")]
134 pub certificate_creation_date: Option<f64>,
135 #[serde(rename = "CertificateIdentifier")]
137 #[serde(skip_serializing_if = "Option::is_none")]
138 pub certificate_identifier: Option<String>,
139 #[serde(rename = "CertificateOwner")]
141 #[serde(skip_serializing_if = "Option::is_none")]
142 pub certificate_owner: Option<String>,
143 #[serde(rename = "CertificatePem")]
145 #[serde(skip_serializing_if = "Option::is_none")]
146 pub certificate_pem: Option<String>,
147 #[serde(rename = "CertificateWallet")]
149 #[serde(
150 deserialize_with = "::rusoto_core::serialization::SerdeBlob::deserialize_blob",
151 serialize_with = "::rusoto_core::serialization::SerdeBlob::serialize_blob",
152 default
153 )]
154 #[serde(skip_serializing_if = "Option::is_none")]
155 pub certificate_wallet: Option<bytes::Bytes>,
156 #[serde(rename = "KeyLength")]
158 #[serde(skip_serializing_if = "Option::is_none")]
159 pub key_length: Option<i64>,
160 #[serde(rename = "SigningAlgorithm")]
162 #[serde(skip_serializing_if = "Option::is_none")]
163 pub signing_algorithm: Option<String>,
164 #[serde(rename = "ValidFromDate")]
166 #[serde(skip_serializing_if = "Option::is_none")]
167 pub valid_from_date: Option<f64>,
168 #[serde(rename = "ValidToDate")]
170 #[serde(skip_serializing_if = "Option::is_none")]
171 pub valid_to_date: Option<f64>,
172}
173
174#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
176#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
177pub struct Connection {
178 #[serde(rename = "EndpointArn")]
180 #[serde(skip_serializing_if = "Option::is_none")]
181 pub endpoint_arn: Option<String>,
182 #[serde(rename = "EndpointIdentifier")]
184 #[serde(skip_serializing_if = "Option::is_none")]
185 pub endpoint_identifier: Option<String>,
186 #[serde(rename = "LastFailureMessage")]
188 #[serde(skip_serializing_if = "Option::is_none")]
189 pub last_failure_message: Option<String>,
190 #[serde(rename = "ReplicationInstanceArn")]
192 #[serde(skip_serializing_if = "Option::is_none")]
193 pub replication_instance_arn: Option<String>,
194 #[serde(rename = "ReplicationInstanceIdentifier")]
196 #[serde(skip_serializing_if = "Option::is_none")]
197 pub replication_instance_identifier: Option<String>,
198 #[serde(rename = "Status")]
200 #[serde(skip_serializing_if = "Option::is_none")]
201 pub status: Option<String>,
202}
203
204#[derive(Clone, Debug, Default, PartialEq, Serialize)]
206#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
207pub struct CreateEndpointMessage {
208 #[serde(rename = "CertificateArn")]
210 #[serde(skip_serializing_if = "Option::is_none")]
211 pub certificate_arn: Option<String>,
212 #[serde(rename = "DatabaseName")]
214 #[serde(skip_serializing_if = "Option::is_none")]
215 pub database_name: Option<String>,
216 #[serde(rename = "DmsTransferSettings")]
218 #[serde(skip_serializing_if = "Option::is_none")]
219 pub dms_transfer_settings: Option<DmsTransferSettings>,
220 #[serde(rename = "DynamoDbSettings")]
222 #[serde(skip_serializing_if = "Option::is_none")]
223 pub dynamo_db_settings: Option<DynamoDbSettings>,
224 #[serde(rename = "ElasticsearchSettings")]
226 #[serde(skip_serializing_if = "Option::is_none")]
227 pub elasticsearch_settings: Option<ElasticsearchSettings>,
228 #[serde(rename = "EndpointIdentifier")]
230 pub endpoint_identifier: String,
231 #[serde(rename = "EndpointType")]
233 pub endpoint_type: String,
234 #[serde(rename = "EngineName")]
236 pub engine_name: String,
237 #[serde(rename = "ExternalTableDefinition")]
239 #[serde(skip_serializing_if = "Option::is_none")]
240 pub external_table_definition: Option<String>,
241 #[serde(rename = "ExtraConnectionAttributes")]
243 #[serde(skip_serializing_if = "Option::is_none")]
244 pub extra_connection_attributes: Option<String>,
245 #[serde(rename = "KafkaSettings")]
247 #[serde(skip_serializing_if = "Option::is_none")]
248 pub kafka_settings: Option<KafkaSettings>,
249 #[serde(rename = "KinesisSettings")]
251 #[serde(skip_serializing_if = "Option::is_none")]
252 pub kinesis_settings: Option<KinesisSettings>,
253 #[serde(rename = "KmsKeyId")]
255 #[serde(skip_serializing_if = "Option::is_none")]
256 pub kms_key_id: Option<String>,
257 #[serde(rename = "MongoDbSettings")]
259 #[serde(skip_serializing_if = "Option::is_none")]
260 pub mongo_db_settings: Option<MongoDbSettings>,
261 #[serde(rename = "NeptuneSettings")]
263 #[serde(skip_serializing_if = "Option::is_none")]
264 pub neptune_settings: Option<NeptuneSettings>,
265 #[serde(rename = "Password")]
267 #[serde(skip_serializing_if = "Option::is_none")]
268 pub password: Option<String>,
269 #[serde(rename = "Port")]
271 #[serde(skip_serializing_if = "Option::is_none")]
272 pub port: Option<i64>,
273 #[serde(rename = "RedshiftSettings")]
274 #[serde(skip_serializing_if = "Option::is_none")]
275 pub redshift_settings: Option<RedshiftSettings>,
276 #[serde(rename = "S3Settings")]
278 #[serde(skip_serializing_if = "Option::is_none")]
279 pub s3_settings: Option<S3Settings>,
280 #[serde(rename = "ServerName")]
282 #[serde(skip_serializing_if = "Option::is_none")]
283 pub server_name: Option<String>,
284 #[serde(rename = "ServiceAccessRoleArn")]
286 #[serde(skip_serializing_if = "Option::is_none")]
287 pub service_access_role_arn: Option<String>,
288 #[serde(rename = "SslMode")]
290 #[serde(skip_serializing_if = "Option::is_none")]
291 pub ssl_mode: Option<String>,
292 #[serde(rename = "Tags")]
294 #[serde(skip_serializing_if = "Option::is_none")]
295 pub tags: Option<Vec<Tag>>,
296 #[serde(rename = "Username")]
298 #[serde(skip_serializing_if = "Option::is_none")]
299 pub username: Option<String>,
300}
301
302#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
304#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
305pub struct CreateEndpointResponse {
306 #[serde(rename = "Endpoint")]
308 #[serde(skip_serializing_if = "Option::is_none")]
309 pub endpoint: Option<Endpoint>,
310}
311
312#[derive(Clone, Debug, Default, PartialEq, Serialize)]
314#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
315pub struct CreateEventSubscriptionMessage {
316 #[serde(rename = "Enabled")]
318 #[serde(skip_serializing_if = "Option::is_none")]
319 pub enabled: Option<bool>,
320 #[serde(rename = "EventCategories")]
322 #[serde(skip_serializing_if = "Option::is_none")]
323 pub event_categories: Option<Vec<String>>,
324 #[serde(rename = "SnsTopicArn")]
326 pub sns_topic_arn: String,
327 #[serde(rename = "SourceIds")]
329 #[serde(skip_serializing_if = "Option::is_none")]
330 pub source_ids: Option<Vec<String>>,
331 #[serde(rename = "SourceType")]
333 #[serde(skip_serializing_if = "Option::is_none")]
334 pub source_type: Option<String>,
335 #[serde(rename = "SubscriptionName")]
337 pub subscription_name: String,
338 #[serde(rename = "Tags")]
340 #[serde(skip_serializing_if = "Option::is_none")]
341 pub tags: Option<Vec<Tag>>,
342}
343
344#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
346#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
347pub struct CreateEventSubscriptionResponse {
348 #[serde(rename = "EventSubscription")]
350 #[serde(skip_serializing_if = "Option::is_none")]
351 pub event_subscription: Option<EventSubscription>,
352}
353
354#[derive(Clone, Debug, Default, PartialEq, Serialize)]
356#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
357pub struct CreateReplicationInstanceMessage {
358 #[serde(rename = "AllocatedStorage")]
360 #[serde(skip_serializing_if = "Option::is_none")]
361 pub allocated_storage: Option<i64>,
362 #[serde(rename = "AutoMinorVersionUpgrade")]
364 #[serde(skip_serializing_if = "Option::is_none")]
365 pub auto_minor_version_upgrade: Option<bool>,
366 #[serde(rename = "AvailabilityZone")]
368 #[serde(skip_serializing_if = "Option::is_none")]
369 pub availability_zone: Option<String>,
370 #[serde(rename = "DnsNameServers")]
372 #[serde(skip_serializing_if = "Option::is_none")]
373 pub dns_name_servers: Option<String>,
374 #[serde(rename = "EngineVersion")]
376 #[serde(skip_serializing_if = "Option::is_none")]
377 pub engine_version: Option<String>,
378 #[serde(rename = "KmsKeyId")]
380 #[serde(skip_serializing_if = "Option::is_none")]
381 pub kms_key_id: Option<String>,
382 #[serde(rename = "MultiAZ")]
384 #[serde(skip_serializing_if = "Option::is_none")]
385 pub multi_az: Option<bool>,
386 #[serde(rename = "PreferredMaintenanceWindow")]
388 #[serde(skip_serializing_if = "Option::is_none")]
389 pub preferred_maintenance_window: Option<String>,
390 #[serde(rename = "PubliclyAccessible")]
392 #[serde(skip_serializing_if = "Option::is_none")]
393 pub publicly_accessible: Option<bool>,
394 #[serde(rename = "ReplicationInstanceClass")]
396 pub replication_instance_class: String,
397 #[serde(rename = "ReplicationInstanceIdentifier")]
399 pub replication_instance_identifier: String,
400 #[serde(rename = "ReplicationSubnetGroupIdentifier")]
402 #[serde(skip_serializing_if = "Option::is_none")]
403 pub replication_subnet_group_identifier: Option<String>,
404 #[serde(rename = "Tags")]
406 #[serde(skip_serializing_if = "Option::is_none")]
407 pub tags: Option<Vec<Tag>>,
408 #[serde(rename = "VpcSecurityGroupIds")]
410 #[serde(skip_serializing_if = "Option::is_none")]
411 pub vpc_security_group_ids: Option<Vec<String>>,
412}
413
414#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
416#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
417pub struct CreateReplicationInstanceResponse {
418 #[serde(rename = "ReplicationInstance")]
420 #[serde(skip_serializing_if = "Option::is_none")]
421 pub replication_instance: Option<ReplicationInstance>,
422}
423
424#[derive(Clone, Debug, Default, PartialEq, Serialize)]
426#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
427pub struct CreateReplicationSubnetGroupMessage {
428 #[serde(rename = "ReplicationSubnetGroupDescription")]
430 pub replication_subnet_group_description: String,
431 #[serde(rename = "ReplicationSubnetGroupIdentifier")]
433 pub replication_subnet_group_identifier: String,
434 #[serde(rename = "SubnetIds")]
436 pub subnet_ids: Vec<String>,
437 #[serde(rename = "Tags")]
439 #[serde(skip_serializing_if = "Option::is_none")]
440 pub tags: Option<Vec<Tag>>,
441}
442
443#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
445#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
446pub struct CreateReplicationSubnetGroupResponse {
447 #[serde(rename = "ReplicationSubnetGroup")]
449 #[serde(skip_serializing_if = "Option::is_none")]
450 pub replication_subnet_group: Option<ReplicationSubnetGroup>,
451}
452
453#[derive(Clone, Debug, Default, PartialEq, Serialize)]
455#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
456pub struct CreateReplicationTaskMessage {
457 #[serde(rename = "CdcStartPosition")]
459 #[serde(skip_serializing_if = "Option::is_none")]
460 pub cdc_start_position: Option<String>,
461 #[serde(rename = "CdcStartTime")]
463 #[serde(skip_serializing_if = "Option::is_none")]
464 pub cdc_start_time: Option<f64>,
465 #[serde(rename = "CdcStopPosition")]
467 #[serde(skip_serializing_if = "Option::is_none")]
468 pub cdc_stop_position: Option<String>,
469 #[serde(rename = "MigrationType")]
471 pub migration_type: String,
472 #[serde(rename = "ReplicationInstanceArn")]
474 pub replication_instance_arn: String,
475 #[serde(rename = "ReplicationTaskIdentifier")]
477 pub replication_task_identifier: String,
478 #[serde(rename = "ReplicationTaskSettings")]
480 #[serde(skip_serializing_if = "Option::is_none")]
481 pub replication_task_settings: Option<String>,
482 #[serde(rename = "SourceEndpointArn")]
484 pub source_endpoint_arn: String,
485 #[serde(rename = "TableMappings")]
487 pub table_mappings: String,
488 #[serde(rename = "Tags")]
490 #[serde(skip_serializing_if = "Option::is_none")]
491 pub tags: Option<Vec<Tag>>,
492 #[serde(rename = "TargetEndpointArn")]
494 pub target_endpoint_arn: String,
495 #[serde(rename = "TaskData")]
497 #[serde(skip_serializing_if = "Option::is_none")]
498 pub task_data: Option<String>,
499}
500
501#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
503#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
504pub struct CreateReplicationTaskResponse {
505 #[serde(rename = "ReplicationTask")]
507 #[serde(skip_serializing_if = "Option::is_none")]
508 pub replication_task: Option<ReplicationTask>,
509}
510
511#[derive(Clone, Debug, Default, PartialEq, Serialize)]
512#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
513pub struct DeleteCertificateMessage {
514 #[serde(rename = "CertificateArn")]
516 pub certificate_arn: String,
517}
518
519#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
520#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
521pub struct DeleteCertificateResponse {
522 #[serde(rename = "Certificate")]
524 #[serde(skip_serializing_if = "Option::is_none")]
525 pub certificate: Option<Certificate>,
526}
527
528#[derive(Clone, Debug, Default, PartialEq, Serialize)]
530#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
531pub struct DeleteConnectionMessage {
532 #[serde(rename = "EndpointArn")]
534 pub endpoint_arn: String,
535 #[serde(rename = "ReplicationInstanceArn")]
537 pub replication_instance_arn: String,
538}
539
540#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
542#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
543pub struct DeleteConnectionResponse {
544 #[serde(rename = "Connection")]
546 #[serde(skip_serializing_if = "Option::is_none")]
547 pub connection: Option<Connection>,
548}
549
550#[derive(Clone, Debug, Default, PartialEq, Serialize)]
552#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
553pub struct DeleteEndpointMessage {
554 #[serde(rename = "EndpointArn")]
556 pub endpoint_arn: String,
557}
558
559#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
561#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
562pub struct DeleteEndpointResponse {
563 #[serde(rename = "Endpoint")]
565 #[serde(skip_serializing_if = "Option::is_none")]
566 pub endpoint: Option<Endpoint>,
567}
568
569#[derive(Clone, Debug, Default, PartialEq, Serialize)]
571#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
572pub struct DeleteEventSubscriptionMessage {
573 #[serde(rename = "SubscriptionName")]
575 pub subscription_name: String,
576}
577
578#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
580#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
581pub struct DeleteEventSubscriptionResponse {
582 #[serde(rename = "EventSubscription")]
584 #[serde(skip_serializing_if = "Option::is_none")]
585 pub event_subscription: Option<EventSubscription>,
586}
587
588#[derive(Clone, Debug, Default, PartialEq, Serialize)]
590#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
591pub struct DeleteReplicationInstanceMessage {
592 #[serde(rename = "ReplicationInstanceArn")]
594 pub replication_instance_arn: String,
595}
596
597#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
599#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
600pub struct DeleteReplicationInstanceResponse {
601 #[serde(rename = "ReplicationInstance")]
603 #[serde(skip_serializing_if = "Option::is_none")]
604 pub replication_instance: Option<ReplicationInstance>,
605}
606
607#[derive(Clone, Debug, Default, PartialEq, Serialize)]
609#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
610pub struct DeleteReplicationSubnetGroupMessage {
611 #[serde(rename = "ReplicationSubnetGroupIdentifier")]
613 pub replication_subnet_group_identifier: String,
614}
615
616#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
618#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
619pub struct DeleteReplicationSubnetGroupResponse {}
620
621#[derive(Clone, Debug, Default, PartialEq, Serialize)]
623#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
624pub struct DeleteReplicationTaskMessage {
625 #[serde(rename = "ReplicationTaskArn")]
627 pub replication_task_arn: String,
628}
629
630#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
632#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
633pub struct DeleteReplicationTaskResponse {
634 #[serde(rename = "ReplicationTask")]
636 #[serde(skip_serializing_if = "Option::is_none")]
637 pub replication_task: Option<ReplicationTask>,
638}
639
640#[derive(Clone, Debug, Default, PartialEq, Serialize)]
642#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
643pub struct DescribeAccountAttributesMessage {}
644
645#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
647#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
648pub struct DescribeAccountAttributesResponse {
649 #[serde(rename = "AccountQuotas")]
651 #[serde(skip_serializing_if = "Option::is_none")]
652 pub account_quotas: Option<Vec<AccountQuota>>,
653 #[serde(rename = "UniqueAccountIdentifier")]
655 #[serde(skip_serializing_if = "Option::is_none")]
656 pub unique_account_identifier: Option<String>,
657}
658
659#[derive(Clone, Debug, Default, PartialEq, Serialize)]
660#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
661pub struct DescribeCertificatesMessage {
662 #[serde(rename = "Filters")]
664 #[serde(skip_serializing_if = "Option::is_none")]
665 pub filters: Option<Vec<Filter>>,
666 #[serde(rename = "Marker")]
668 #[serde(skip_serializing_if = "Option::is_none")]
669 pub marker: Option<String>,
670 #[serde(rename = "MaxRecords")]
672 #[serde(skip_serializing_if = "Option::is_none")]
673 pub max_records: Option<i64>,
674}
675
676#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
677#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
678pub struct DescribeCertificatesResponse {
679 #[serde(rename = "Certificates")]
681 #[serde(skip_serializing_if = "Option::is_none")]
682 pub certificates: Option<Vec<Certificate>>,
683 #[serde(rename = "Marker")]
685 #[serde(skip_serializing_if = "Option::is_none")]
686 pub marker: Option<String>,
687}
688
689#[derive(Clone, Debug, Default, PartialEq, Serialize)]
691#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
692pub struct DescribeConnectionsMessage {
693 #[serde(rename = "Filters")]
695 #[serde(skip_serializing_if = "Option::is_none")]
696 pub filters: Option<Vec<Filter>>,
697 #[serde(rename = "Marker")]
699 #[serde(skip_serializing_if = "Option::is_none")]
700 pub marker: Option<String>,
701 #[serde(rename = "MaxRecords")]
703 #[serde(skip_serializing_if = "Option::is_none")]
704 pub max_records: Option<i64>,
705}
706
707#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
709#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
710pub struct DescribeConnectionsResponse {
711 #[serde(rename = "Connections")]
713 #[serde(skip_serializing_if = "Option::is_none")]
714 pub connections: Option<Vec<Connection>>,
715 #[serde(rename = "Marker")]
717 #[serde(skip_serializing_if = "Option::is_none")]
718 pub marker: Option<String>,
719}
720
721#[derive(Clone, Debug, Default, PartialEq, Serialize)]
723#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
724pub struct DescribeEndpointTypesMessage {
725 #[serde(rename = "Filters")]
727 #[serde(skip_serializing_if = "Option::is_none")]
728 pub filters: Option<Vec<Filter>>,
729 #[serde(rename = "Marker")]
731 #[serde(skip_serializing_if = "Option::is_none")]
732 pub marker: Option<String>,
733 #[serde(rename = "MaxRecords")]
735 #[serde(skip_serializing_if = "Option::is_none")]
736 pub max_records: Option<i64>,
737}
738
739#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
741#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
742pub struct DescribeEndpointTypesResponse {
743 #[serde(rename = "Marker")]
745 #[serde(skip_serializing_if = "Option::is_none")]
746 pub marker: Option<String>,
747 #[serde(rename = "SupportedEndpointTypes")]
749 #[serde(skip_serializing_if = "Option::is_none")]
750 pub supported_endpoint_types: Option<Vec<SupportedEndpointType>>,
751}
752
753#[derive(Clone, Debug, Default, PartialEq, Serialize)]
755#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
756pub struct DescribeEndpointsMessage {
757 #[serde(rename = "Filters")]
759 #[serde(skip_serializing_if = "Option::is_none")]
760 pub filters: Option<Vec<Filter>>,
761 #[serde(rename = "Marker")]
763 #[serde(skip_serializing_if = "Option::is_none")]
764 pub marker: Option<String>,
765 #[serde(rename = "MaxRecords")]
767 #[serde(skip_serializing_if = "Option::is_none")]
768 pub max_records: Option<i64>,
769}
770
771#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
773#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
774pub struct DescribeEndpointsResponse {
775 #[serde(rename = "Endpoints")]
777 #[serde(skip_serializing_if = "Option::is_none")]
778 pub endpoints: Option<Vec<Endpoint>>,
779 #[serde(rename = "Marker")]
781 #[serde(skip_serializing_if = "Option::is_none")]
782 pub marker: Option<String>,
783}
784
785#[derive(Clone, Debug, Default, PartialEq, Serialize)]
787#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
788pub struct DescribeEventCategoriesMessage {
789 #[serde(rename = "Filters")]
791 #[serde(skip_serializing_if = "Option::is_none")]
792 pub filters: Option<Vec<Filter>>,
793 #[serde(rename = "SourceType")]
795 #[serde(skip_serializing_if = "Option::is_none")]
796 pub source_type: Option<String>,
797}
798
799#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
801#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
802pub struct DescribeEventCategoriesResponse {
803 #[serde(rename = "EventCategoryGroupList")]
805 #[serde(skip_serializing_if = "Option::is_none")]
806 pub event_category_group_list: Option<Vec<EventCategoryGroup>>,
807}
808
809#[derive(Clone, Debug, Default, PartialEq, Serialize)]
811#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
812pub struct DescribeEventSubscriptionsMessage {
813 #[serde(rename = "Filters")]
815 #[serde(skip_serializing_if = "Option::is_none")]
816 pub filters: Option<Vec<Filter>>,
817 #[serde(rename = "Marker")]
819 #[serde(skip_serializing_if = "Option::is_none")]
820 pub marker: Option<String>,
821 #[serde(rename = "MaxRecords")]
823 #[serde(skip_serializing_if = "Option::is_none")]
824 pub max_records: Option<i64>,
825 #[serde(rename = "SubscriptionName")]
827 #[serde(skip_serializing_if = "Option::is_none")]
828 pub subscription_name: Option<String>,
829}
830
831#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
833#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
834pub struct DescribeEventSubscriptionsResponse {
835 #[serde(rename = "EventSubscriptionsList")]
837 #[serde(skip_serializing_if = "Option::is_none")]
838 pub event_subscriptions_list: Option<Vec<EventSubscription>>,
839 #[serde(rename = "Marker")]
841 #[serde(skip_serializing_if = "Option::is_none")]
842 pub marker: Option<String>,
843}
844
845#[derive(Clone, Debug, Default, PartialEq, Serialize)]
847#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
848pub struct DescribeEventsMessage {
849 #[serde(rename = "Duration")]
851 #[serde(skip_serializing_if = "Option::is_none")]
852 pub duration: Option<i64>,
853 #[serde(rename = "EndTime")]
855 #[serde(skip_serializing_if = "Option::is_none")]
856 pub end_time: Option<f64>,
857 #[serde(rename = "EventCategories")]
859 #[serde(skip_serializing_if = "Option::is_none")]
860 pub event_categories: Option<Vec<String>>,
861 #[serde(rename = "Filters")]
863 #[serde(skip_serializing_if = "Option::is_none")]
864 pub filters: Option<Vec<Filter>>,
865 #[serde(rename = "Marker")]
867 #[serde(skip_serializing_if = "Option::is_none")]
868 pub marker: Option<String>,
869 #[serde(rename = "MaxRecords")]
871 #[serde(skip_serializing_if = "Option::is_none")]
872 pub max_records: Option<i64>,
873 #[serde(rename = "SourceIdentifier")]
875 #[serde(skip_serializing_if = "Option::is_none")]
876 pub source_identifier: Option<String>,
877 #[serde(rename = "SourceType")]
879 #[serde(skip_serializing_if = "Option::is_none")]
880 pub source_type: Option<String>,
881 #[serde(rename = "StartTime")]
883 #[serde(skip_serializing_if = "Option::is_none")]
884 pub start_time: Option<f64>,
885}
886
887#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
889#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
890pub struct DescribeEventsResponse {
891 #[serde(rename = "Events")]
893 #[serde(skip_serializing_if = "Option::is_none")]
894 pub events: Option<Vec<Event>>,
895 #[serde(rename = "Marker")]
897 #[serde(skip_serializing_if = "Option::is_none")]
898 pub marker: Option<String>,
899}
900
901#[derive(Clone, Debug, Default, PartialEq, Serialize)]
903#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
904pub struct DescribeOrderableReplicationInstancesMessage {
905 #[serde(rename = "Marker")]
907 #[serde(skip_serializing_if = "Option::is_none")]
908 pub marker: Option<String>,
909 #[serde(rename = "MaxRecords")]
911 #[serde(skip_serializing_if = "Option::is_none")]
912 pub max_records: Option<i64>,
913}
914
915#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
917#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
918pub struct DescribeOrderableReplicationInstancesResponse {
919 #[serde(rename = "Marker")]
921 #[serde(skip_serializing_if = "Option::is_none")]
922 pub marker: Option<String>,
923 #[serde(rename = "OrderableReplicationInstances")]
925 #[serde(skip_serializing_if = "Option::is_none")]
926 pub orderable_replication_instances: Option<Vec<OrderableReplicationInstance>>,
927}
928
929#[derive(Clone, Debug, Default, PartialEq, Serialize)]
931#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
932pub struct DescribePendingMaintenanceActionsMessage {
933 #[serde(rename = "Filters")]
935 #[serde(skip_serializing_if = "Option::is_none")]
936 pub filters: Option<Vec<Filter>>,
937 #[serde(rename = "Marker")]
939 #[serde(skip_serializing_if = "Option::is_none")]
940 pub marker: Option<String>,
941 #[serde(rename = "MaxRecords")]
943 #[serde(skip_serializing_if = "Option::is_none")]
944 pub max_records: Option<i64>,
945 #[serde(rename = "ReplicationInstanceArn")]
947 #[serde(skip_serializing_if = "Option::is_none")]
948 pub replication_instance_arn: Option<String>,
949}
950
951#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
953#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
954pub struct DescribePendingMaintenanceActionsResponse {
955 #[serde(rename = "Marker")]
957 #[serde(skip_serializing_if = "Option::is_none")]
958 pub marker: Option<String>,
959 #[serde(rename = "PendingMaintenanceActions")]
961 #[serde(skip_serializing_if = "Option::is_none")]
962 pub pending_maintenance_actions: Option<Vec<ResourcePendingMaintenanceActions>>,
963}
964
965#[derive(Clone, Debug, Default, PartialEq, Serialize)]
967#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
968pub struct DescribeRefreshSchemasStatusMessage {
969 #[serde(rename = "EndpointArn")]
971 pub endpoint_arn: String,
972}
973
974#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
976#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
977pub struct DescribeRefreshSchemasStatusResponse {
978 #[serde(rename = "RefreshSchemasStatus")]
980 #[serde(skip_serializing_if = "Option::is_none")]
981 pub refresh_schemas_status: Option<RefreshSchemasStatus>,
982}
983
984#[derive(Clone, Debug, Default, PartialEq, Serialize)]
985#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
986pub struct DescribeReplicationInstanceTaskLogsMessage {
987 #[serde(rename = "Marker")]
989 #[serde(skip_serializing_if = "Option::is_none")]
990 pub marker: Option<String>,
991 #[serde(rename = "MaxRecords")]
993 #[serde(skip_serializing_if = "Option::is_none")]
994 pub max_records: Option<i64>,
995 #[serde(rename = "ReplicationInstanceArn")]
997 pub replication_instance_arn: String,
998}
999
1000#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1001#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1002pub struct DescribeReplicationInstanceTaskLogsResponse {
1003 #[serde(rename = "Marker")]
1005 #[serde(skip_serializing_if = "Option::is_none")]
1006 pub marker: Option<String>,
1007 #[serde(rename = "ReplicationInstanceArn")]
1009 #[serde(skip_serializing_if = "Option::is_none")]
1010 pub replication_instance_arn: Option<String>,
1011 #[serde(rename = "ReplicationInstanceTaskLogs")]
1013 #[serde(skip_serializing_if = "Option::is_none")]
1014 pub replication_instance_task_logs: Option<Vec<ReplicationInstanceTaskLog>>,
1015}
1016
1017#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1019#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1020pub struct DescribeReplicationInstancesMessage {
1021 #[serde(rename = "Filters")]
1023 #[serde(skip_serializing_if = "Option::is_none")]
1024 pub filters: Option<Vec<Filter>>,
1025 #[serde(rename = "Marker")]
1027 #[serde(skip_serializing_if = "Option::is_none")]
1028 pub marker: Option<String>,
1029 #[serde(rename = "MaxRecords")]
1031 #[serde(skip_serializing_if = "Option::is_none")]
1032 pub max_records: Option<i64>,
1033}
1034
1035#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1037#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1038pub struct DescribeReplicationInstancesResponse {
1039 #[serde(rename = "Marker")]
1041 #[serde(skip_serializing_if = "Option::is_none")]
1042 pub marker: Option<String>,
1043 #[serde(rename = "ReplicationInstances")]
1045 #[serde(skip_serializing_if = "Option::is_none")]
1046 pub replication_instances: Option<Vec<ReplicationInstance>>,
1047}
1048
1049#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1051#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1052pub struct DescribeReplicationSubnetGroupsMessage {
1053 #[serde(rename = "Filters")]
1055 #[serde(skip_serializing_if = "Option::is_none")]
1056 pub filters: Option<Vec<Filter>>,
1057 #[serde(rename = "Marker")]
1059 #[serde(skip_serializing_if = "Option::is_none")]
1060 pub marker: Option<String>,
1061 #[serde(rename = "MaxRecords")]
1063 #[serde(skip_serializing_if = "Option::is_none")]
1064 pub max_records: Option<i64>,
1065}
1066
1067#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1069#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1070pub struct DescribeReplicationSubnetGroupsResponse {
1071 #[serde(rename = "Marker")]
1073 #[serde(skip_serializing_if = "Option::is_none")]
1074 pub marker: Option<String>,
1075 #[serde(rename = "ReplicationSubnetGroups")]
1077 #[serde(skip_serializing_if = "Option::is_none")]
1078 pub replication_subnet_groups: Option<Vec<ReplicationSubnetGroup>>,
1079}
1080
1081#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1083#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1084pub struct DescribeReplicationTaskAssessmentResultsMessage {
1085 #[serde(rename = "Marker")]
1087 #[serde(skip_serializing_if = "Option::is_none")]
1088 pub marker: Option<String>,
1089 #[serde(rename = "MaxRecords")]
1091 #[serde(skip_serializing_if = "Option::is_none")]
1092 pub max_records: Option<i64>,
1093 #[serde(rename = "ReplicationTaskArn")]
1095 #[serde(skip_serializing_if = "Option::is_none")]
1096 pub replication_task_arn: Option<String>,
1097}
1098
1099#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1101#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1102pub struct DescribeReplicationTaskAssessmentResultsResponse {
1103 #[serde(rename = "BucketName")]
1105 #[serde(skip_serializing_if = "Option::is_none")]
1106 pub bucket_name: Option<String>,
1107 #[serde(rename = "Marker")]
1109 #[serde(skip_serializing_if = "Option::is_none")]
1110 pub marker: Option<String>,
1111 #[serde(rename = "ReplicationTaskAssessmentResults")]
1113 #[serde(skip_serializing_if = "Option::is_none")]
1114 pub replication_task_assessment_results: Option<Vec<ReplicationTaskAssessmentResult>>,
1115}
1116
1117#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1119#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1120pub struct DescribeReplicationTasksMessage {
1121 #[serde(rename = "Filters")]
1123 #[serde(skip_serializing_if = "Option::is_none")]
1124 pub filters: Option<Vec<Filter>>,
1125 #[serde(rename = "Marker")]
1127 #[serde(skip_serializing_if = "Option::is_none")]
1128 pub marker: Option<String>,
1129 #[serde(rename = "MaxRecords")]
1131 #[serde(skip_serializing_if = "Option::is_none")]
1132 pub max_records: Option<i64>,
1133 #[serde(rename = "WithoutSettings")]
1135 #[serde(skip_serializing_if = "Option::is_none")]
1136 pub without_settings: Option<bool>,
1137}
1138
1139#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1141#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1142pub struct DescribeReplicationTasksResponse {
1143 #[serde(rename = "Marker")]
1145 #[serde(skip_serializing_if = "Option::is_none")]
1146 pub marker: Option<String>,
1147 #[serde(rename = "ReplicationTasks")]
1149 #[serde(skip_serializing_if = "Option::is_none")]
1150 pub replication_tasks: Option<Vec<ReplicationTask>>,
1151}
1152
1153#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1155#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1156pub struct DescribeSchemasMessage {
1157 #[serde(rename = "EndpointArn")]
1159 pub endpoint_arn: String,
1160 #[serde(rename = "Marker")]
1162 #[serde(skip_serializing_if = "Option::is_none")]
1163 pub marker: Option<String>,
1164 #[serde(rename = "MaxRecords")]
1166 #[serde(skip_serializing_if = "Option::is_none")]
1167 pub max_records: Option<i64>,
1168}
1169
1170#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1172#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1173pub struct DescribeSchemasResponse {
1174 #[serde(rename = "Marker")]
1176 #[serde(skip_serializing_if = "Option::is_none")]
1177 pub marker: Option<String>,
1178 #[serde(rename = "Schemas")]
1180 #[serde(skip_serializing_if = "Option::is_none")]
1181 pub schemas: Option<Vec<String>>,
1182}
1183
1184#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1186#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1187pub struct DescribeTableStatisticsMessage {
1188 #[serde(rename = "Filters")]
1190 #[serde(skip_serializing_if = "Option::is_none")]
1191 pub filters: Option<Vec<Filter>>,
1192 #[serde(rename = "Marker")]
1194 #[serde(skip_serializing_if = "Option::is_none")]
1195 pub marker: Option<String>,
1196 #[serde(rename = "MaxRecords")]
1198 #[serde(skip_serializing_if = "Option::is_none")]
1199 pub max_records: Option<i64>,
1200 #[serde(rename = "ReplicationTaskArn")]
1202 pub replication_task_arn: String,
1203}
1204
1205#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1207#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1208pub struct DescribeTableStatisticsResponse {
1209 #[serde(rename = "Marker")]
1211 #[serde(skip_serializing_if = "Option::is_none")]
1212 pub marker: Option<String>,
1213 #[serde(rename = "ReplicationTaskArn")]
1215 #[serde(skip_serializing_if = "Option::is_none")]
1216 pub replication_task_arn: Option<String>,
1217 #[serde(rename = "TableStatistics")]
1219 #[serde(skip_serializing_if = "Option::is_none")]
1220 pub table_statistics: Option<Vec<TableStatistics>>,
1221}
1222
1223#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1225pub struct DmsTransferSettings {
1226 #[serde(rename = "BucketName")]
1228 #[serde(skip_serializing_if = "Option::is_none")]
1229 pub bucket_name: Option<String>,
1230 #[serde(rename = "ServiceAccessRoleArn")]
1232 #[serde(skip_serializing_if = "Option::is_none")]
1233 pub service_access_role_arn: Option<String>,
1234}
1235
1236#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1238pub struct DynamoDbSettings {
1239 #[serde(rename = "ServiceAccessRoleArn")]
1241 pub service_access_role_arn: String,
1242}
1243
1244#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1246pub struct ElasticsearchSettings {
1247 #[serde(rename = "EndpointUri")]
1249 pub endpoint_uri: String,
1250 #[serde(rename = "ErrorRetryDuration")]
1252 #[serde(skip_serializing_if = "Option::is_none")]
1253 pub error_retry_duration: Option<i64>,
1254 #[serde(rename = "FullLoadErrorPercentage")]
1256 #[serde(skip_serializing_if = "Option::is_none")]
1257 pub full_load_error_percentage: Option<i64>,
1258 #[serde(rename = "ServiceAccessRoleArn")]
1260 pub service_access_role_arn: String,
1261}
1262
1263#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1265#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1266pub struct Endpoint {
1267 #[serde(rename = "CertificateArn")]
1269 #[serde(skip_serializing_if = "Option::is_none")]
1270 pub certificate_arn: Option<String>,
1271 #[serde(rename = "DatabaseName")]
1273 #[serde(skip_serializing_if = "Option::is_none")]
1274 pub database_name: Option<String>,
1275 #[serde(rename = "DmsTransferSettings")]
1277 #[serde(skip_serializing_if = "Option::is_none")]
1278 pub dms_transfer_settings: Option<DmsTransferSettings>,
1279 #[serde(rename = "DynamoDbSettings")]
1281 #[serde(skip_serializing_if = "Option::is_none")]
1282 pub dynamo_db_settings: Option<DynamoDbSettings>,
1283 #[serde(rename = "ElasticsearchSettings")]
1285 #[serde(skip_serializing_if = "Option::is_none")]
1286 pub elasticsearch_settings: Option<ElasticsearchSettings>,
1287 #[serde(rename = "EndpointArn")]
1289 #[serde(skip_serializing_if = "Option::is_none")]
1290 pub endpoint_arn: Option<String>,
1291 #[serde(rename = "EndpointIdentifier")]
1293 #[serde(skip_serializing_if = "Option::is_none")]
1294 pub endpoint_identifier: Option<String>,
1295 #[serde(rename = "EndpointType")]
1297 #[serde(skip_serializing_if = "Option::is_none")]
1298 pub endpoint_type: Option<String>,
1299 #[serde(rename = "EngineDisplayName")]
1301 #[serde(skip_serializing_if = "Option::is_none")]
1302 pub engine_display_name: Option<String>,
1303 #[serde(rename = "EngineName")]
1305 #[serde(skip_serializing_if = "Option::is_none")]
1306 pub engine_name: Option<String>,
1307 #[serde(rename = "ExternalId")]
1309 #[serde(skip_serializing_if = "Option::is_none")]
1310 pub external_id: Option<String>,
1311 #[serde(rename = "ExternalTableDefinition")]
1313 #[serde(skip_serializing_if = "Option::is_none")]
1314 pub external_table_definition: Option<String>,
1315 #[serde(rename = "ExtraConnectionAttributes")]
1317 #[serde(skip_serializing_if = "Option::is_none")]
1318 pub extra_connection_attributes: Option<String>,
1319 #[serde(rename = "KafkaSettings")]
1321 #[serde(skip_serializing_if = "Option::is_none")]
1322 pub kafka_settings: Option<KafkaSettings>,
1323 #[serde(rename = "KinesisSettings")]
1325 #[serde(skip_serializing_if = "Option::is_none")]
1326 pub kinesis_settings: Option<KinesisSettings>,
1327 #[serde(rename = "KmsKeyId")]
1329 #[serde(skip_serializing_if = "Option::is_none")]
1330 pub kms_key_id: Option<String>,
1331 #[serde(rename = "MongoDbSettings")]
1333 #[serde(skip_serializing_if = "Option::is_none")]
1334 pub mongo_db_settings: Option<MongoDbSettings>,
1335 #[serde(rename = "NeptuneSettings")]
1337 #[serde(skip_serializing_if = "Option::is_none")]
1338 pub neptune_settings: Option<NeptuneSettings>,
1339 #[serde(rename = "Port")]
1341 #[serde(skip_serializing_if = "Option::is_none")]
1342 pub port: Option<i64>,
1343 #[serde(rename = "RedshiftSettings")]
1345 #[serde(skip_serializing_if = "Option::is_none")]
1346 pub redshift_settings: Option<RedshiftSettings>,
1347 #[serde(rename = "S3Settings")]
1349 #[serde(skip_serializing_if = "Option::is_none")]
1350 pub s3_settings: Option<S3Settings>,
1351 #[serde(rename = "ServerName")]
1353 #[serde(skip_serializing_if = "Option::is_none")]
1354 pub server_name: Option<String>,
1355 #[serde(rename = "ServiceAccessRoleArn")]
1357 #[serde(skip_serializing_if = "Option::is_none")]
1358 pub service_access_role_arn: Option<String>,
1359 #[serde(rename = "SslMode")]
1361 #[serde(skip_serializing_if = "Option::is_none")]
1362 pub ssl_mode: Option<String>,
1363 #[serde(rename = "Status")]
1365 #[serde(skip_serializing_if = "Option::is_none")]
1366 pub status: Option<String>,
1367 #[serde(rename = "Username")]
1369 #[serde(skip_serializing_if = "Option::is_none")]
1370 pub username: Option<String>,
1371}
1372
1373#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1375#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1376pub struct Event {
1377 #[serde(rename = "Date")]
1379 #[serde(skip_serializing_if = "Option::is_none")]
1380 pub date: Option<f64>,
1381 #[serde(rename = "EventCategories")]
1383 #[serde(skip_serializing_if = "Option::is_none")]
1384 pub event_categories: Option<Vec<String>>,
1385 #[serde(rename = "Message")]
1387 #[serde(skip_serializing_if = "Option::is_none")]
1388 pub message: Option<String>,
1389 #[serde(rename = "SourceIdentifier")]
1391 #[serde(skip_serializing_if = "Option::is_none")]
1392 pub source_identifier: Option<String>,
1393 #[serde(rename = "SourceType")]
1395 #[serde(skip_serializing_if = "Option::is_none")]
1396 pub source_type: Option<String>,
1397}
1398
1399#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1401#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1402pub struct EventCategoryGroup {
1403 #[serde(rename = "EventCategories")]
1405 #[serde(skip_serializing_if = "Option::is_none")]
1406 pub event_categories: Option<Vec<String>>,
1407 #[serde(rename = "SourceType")]
1409 #[serde(skip_serializing_if = "Option::is_none")]
1410 pub source_type: Option<String>,
1411}
1412
1413#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1415#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1416pub struct EventSubscription {
1417 #[serde(rename = "CustSubscriptionId")]
1419 #[serde(skip_serializing_if = "Option::is_none")]
1420 pub cust_subscription_id: Option<String>,
1421 #[serde(rename = "CustomerAwsId")]
1423 #[serde(skip_serializing_if = "Option::is_none")]
1424 pub customer_aws_id: Option<String>,
1425 #[serde(rename = "Enabled")]
1427 #[serde(skip_serializing_if = "Option::is_none")]
1428 pub enabled: Option<bool>,
1429 #[serde(rename = "EventCategoriesList")]
1431 #[serde(skip_serializing_if = "Option::is_none")]
1432 pub event_categories_list: Option<Vec<String>>,
1433 #[serde(rename = "SnsTopicArn")]
1435 #[serde(skip_serializing_if = "Option::is_none")]
1436 pub sns_topic_arn: Option<String>,
1437 #[serde(rename = "SourceIdsList")]
1439 #[serde(skip_serializing_if = "Option::is_none")]
1440 pub source_ids_list: Option<Vec<String>>,
1441 #[serde(rename = "SourceType")]
1443 #[serde(skip_serializing_if = "Option::is_none")]
1444 pub source_type: Option<String>,
1445 #[serde(rename = "Status")]
1447 #[serde(skip_serializing_if = "Option::is_none")]
1448 pub status: Option<String>,
1449 #[serde(rename = "SubscriptionCreationTime")]
1451 #[serde(skip_serializing_if = "Option::is_none")]
1452 pub subscription_creation_time: Option<String>,
1453}
1454
1455#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1457#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1458pub struct Filter {
1459 #[serde(rename = "Name")]
1461 pub name: String,
1462 #[serde(rename = "Values")]
1464 pub values: Vec<String>,
1465}
1466
1467#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1468#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1469pub struct ImportCertificateMessage {
1470 #[serde(rename = "CertificateIdentifier")]
1472 pub certificate_identifier: String,
1473 #[serde(rename = "CertificatePem")]
1475 #[serde(skip_serializing_if = "Option::is_none")]
1476 pub certificate_pem: Option<String>,
1477 #[serde(rename = "CertificateWallet")]
1479 #[serde(
1480 deserialize_with = "::rusoto_core::serialization::SerdeBlob::deserialize_blob",
1481 serialize_with = "::rusoto_core::serialization::SerdeBlob::serialize_blob",
1482 default
1483 )]
1484 #[serde(skip_serializing_if = "Option::is_none")]
1485 pub certificate_wallet: Option<bytes::Bytes>,
1486 #[serde(rename = "Tags")]
1488 #[serde(skip_serializing_if = "Option::is_none")]
1489 pub tags: Option<Vec<Tag>>,
1490}
1491
1492#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1493#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1494pub struct ImportCertificateResponse {
1495 #[serde(rename = "Certificate")]
1497 #[serde(skip_serializing_if = "Option::is_none")]
1498 pub certificate: Option<Certificate>,
1499}
1500
1501#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1503pub struct KafkaSettings {
1504 #[serde(rename = "Broker")]
1506 #[serde(skip_serializing_if = "Option::is_none")]
1507 pub broker: Option<String>,
1508 #[serde(rename = "Topic")]
1510 #[serde(skip_serializing_if = "Option::is_none")]
1511 pub topic: Option<String>,
1512}
1513
1514#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1516pub struct KinesisSettings {
1517 #[serde(rename = "IncludeControlDetails")]
1519 #[serde(skip_serializing_if = "Option::is_none")]
1520 pub include_control_details: Option<bool>,
1521 #[serde(rename = "IncludePartitionValue")]
1523 #[serde(skip_serializing_if = "Option::is_none")]
1524 pub include_partition_value: Option<bool>,
1525 #[serde(rename = "IncludeTableAlterOperations")]
1527 #[serde(skip_serializing_if = "Option::is_none")]
1528 pub include_table_alter_operations: Option<bool>,
1529 #[serde(rename = "IncludeTransactionDetails")]
1531 #[serde(skip_serializing_if = "Option::is_none")]
1532 pub include_transaction_details: Option<bool>,
1533 #[serde(rename = "MessageFormat")]
1535 #[serde(skip_serializing_if = "Option::is_none")]
1536 pub message_format: Option<String>,
1537 #[serde(rename = "PartitionIncludeSchemaTable")]
1539 #[serde(skip_serializing_if = "Option::is_none")]
1540 pub partition_include_schema_table: Option<bool>,
1541 #[serde(rename = "ServiceAccessRoleArn")]
1543 #[serde(skip_serializing_if = "Option::is_none")]
1544 pub service_access_role_arn: Option<String>,
1545 #[serde(rename = "StreamArn")]
1547 #[serde(skip_serializing_if = "Option::is_none")]
1548 pub stream_arn: Option<String>,
1549}
1550
1551#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1553#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1554pub struct ListTagsForResourceMessage {
1555 #[serde(rename = "ResourceArn")]
1557 pub resource_arn: String,
1558}
1559
1560#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1562#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1563pub struct ListTagsForResourceResponse {
1564 #[serde(rename = "TagList")]
1566 #[serde(skip_serializing_if = "Option::is_none")]
1567 pub tag_list: Option<Vec<Tag>>,
1568}
1569
1570#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1572#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1573pub struct ModifyEndpointMessage {
1574 #[serde(rename = "CertificateArn")]
1576 #[serde(skip_serializing_if = "Option::is_none")]
1577 pub certificate_arn: Option<String>,
1578 #[serde(rename = "DatabaseName")]
1580 #[serde(skip_serializing_if = "Option::is_none")]
1581 pub database_name: Option<String>,
1582 #[serde(rename = "DmsTransferSettings")]
1584 #[serde(skip_serializing_if = "Option::is_none")]
1585 pub dms_transfer_settings: Option<DmsTransferSettings>,
1586 #[serde(rename = "DynamoDbSettings")]
1588 #[serde(skip_serializing_if = "Option::is_none")]
1589 pub dynamo_db_settings: Option<DynamoDbSettings>,
1590 #[serde(rename = "ElasticsearchSettings")]
1592 #[serde(skip_serializing_if = "Option::is_none")]
1593 pub elasticsearch_settings: Option<ElasticsearchSettings>,
1594 #[serde(rename = "EndpointArn")]
1596 pub endpoint_arn: String,
1597 #[serde(rename = "EndpointIdentifier")]
1599 #[serde(skip_serializing_if = "Option::is_none")]
1600 pub endpoint_identifier: Option<String>,
1601 #[serde(rename = "EndpointType")]
1603 #[serde(skip_serializing_if = "Option::is_none")]
1604 pub endpoint_type: Option<String>,
1605 #[serde(rename = "EngineName")]
1607 #[serde(skip_serializing_if = "Option::is_none")]
1608 pub engine_name: Option<String>,
1609 #[serde(rename = "ExternalTableDefinition")]
1611 #[serde(skip_serializing_if = "Option::is_none")]
1612 pub external_table_definition: Option<String>,
1613 #[serde(rename = "ExtraConnectionAttributes")]
1615 #[serde(skip_serializing_if = "Option::is_none")]
1616 pub extra_connection_attributes: Option<String>,
1617 #[serde(rename = "KafkaSettings")]
1619 #[serde(skip_serializing_if = "Option::is_none")]
1620 pub kafka_settings: Option<KafkaSettings>,
1621 #[serde(rename = "KinesisSettings")]
1623 #[serde(skip_serializing_if = "Option::is_none")]
1624 pub kinesis_settings: Option<KinesisSettings>,
1625 #[serde(rename = "MongoDbSettings")]
1627 #[serde(skip_serializing_if = "Option::is_none")]
1628 pub mongo_db_settings: Option<MongoDbSettings>,
1629 #[serde(rename = "NeptuneSettings")]
1631 #[serde(skip_serializing_if = "Option::is_none")]
1632 pub neptune_settings: Option<NeptuneSettings>,
1633 #[serde(rename = "Password")]
1635 #[serde(skip_serializing_if = "Option::is_none")]
1636 pub password: Option<String>,
1637 #[serde(rename = "Port")]
1639 #[serde(skip_serializing_if = "Option::is_none")]
1640 pub port: Option<i64>,
1641 #[serde(rename = "RedshiftSettings")]
1642 #[serde(skip_serializing_if = "Option::is_none")]
1643 pub redshift_settings: Option<RedshiftSettings>,
1644 #[serde(rename = "S3Settings")]
1646 #[serde(skip_serializing_if = "Option::is_none")]
1647 pub s3_settings: Option<S3Settings>,
1648 #[serde(rename = "ServerName")]
1650 #[serde(skip_serializing_if = "Option::is_none")]
1651 pub server_name: Option<String>,
1652 #[serde(rename = "ServiceAccessRoleArn")]
1654 #[serde(skip_serializing_if = "Option::is_none")]
1655 pub service_access_role_arn: Option<String>,
1656 #[serde(rename = "SslMode")]
1658 #[serde(skip_serializing_if = "Option::is_none")]
1659 pub ssl_mode: Option<String>,
1660 #[serde(rename = "Username")]
1662 #[serde(skip_serializing_if = "Option::is_none")]
1663 pub username: Option<String>,
1664}
1665
1666#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1668#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1669pub struct ModifyEndpointResponse {
1670 #[serde(rename = "Endpoint")]
1672 #[serde(skip_serializing_if = "Option::is_none")]
1673 pub endpoint: Option<Endpoint>,
1674}
1675
1676#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1678#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1679pub struct ModifyEventSubscriptionMessage {
1680 #[serde(rename = "Enabled")]
1682 #[serde(skip_serializing_if = "Option::is_none")]
1683 pub enabled: Option<bool>,
1684 #[serde(rename = "EventCategories")]
1686 #[serde(skip_serializing_if = "Option::is_none")]
1687 pub event_categories: Option<Vec<String>>,
1688 #[serde(rename = "SnsTopicArn")]
1690 #[serde(skip_serializing_if = "Option::is_none")]
1691 pub sns_topic_arn: Option<String>,
1692 #[serde(rename = "SourceType")]
1694 #[serde(skip_serializing_if = "Option::is_none")]
1695 pub source_type: Option<String>,
1696 #[serde(rename = "SubscriptionName")]
1698 pub subscription_name: String,
1699}
1700
1701#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1703#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1704pub struct ModifyEventSubscriptionResponse {
1705 #[serde(rename = "EventSubscription")]
1707 #[serde(skip_serializing_if = "Option::is_none")]
1708 pub event_subscription: Option<EventSubscription>,
1709}
1710
1711#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1713#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1714pub struct ModifyReplicationInstanceMessage {
1715 #[serde(rename = "AllocatedStorage")]
1717 #[serde(skip_serializing_if = "Option::is_none")]
1718 pub allocated_storage: Option<i64>,
1719 #[serde(rename = "AllowMajorVersionUpgrade")]
1721 #[serde(skip_serializing_if = "Option::is_none")]
1722 pub allow_major_version_upgrade: Option<bool>,
1723 #[serde(rename = "ApplyImmediately")]
1725 #[serde(skip_serializing_if = "Option::is_none")]
1726 pub apply_immediately: Option<bool>,
1727 #[serde(rename = "AutoMinorVersionUpgrade")]
1729 #[serde(skip_serializing_if = "Option::is_none")]
1730 pub auto_minor_version_upgrade: Option<bool>,
1731 #[serde(rename = "EngineVersion")]
1733 #[serde(skip_serializing_if = "Option::is_none")]
1734 pub engine_version: Option<String>,
1735 #[serde(rename = "MultiAZ")]
1737 #[serde(skip_serializing_if = "Option::is_none")]
1738 pub multi_az: Option<bool>,
1739 #[serde(rename = "PreferredMaintenanceWindow")]
1741 #[serde(skip_serializing_if = "Option::is_none")]
1742 pub preferred_maintenance_window: Option<String>,
1743 #[serde(rename = "ReplicationInstanceArn")]
1745 pub replication_instance_arn: String,
1746 #[serde(rename = "ReplicationInstanceClass")]
1748 #[serde(skip_serializing_if = "Option::is_none")]
1749 pub replication_instance_class: Option<String>,
1750 #[serde(rename = "ReplicationInstanceIdentifier")]
1752 #[serde(skip_serializing_if = "Option::is_none")]
1753 pub replication_instance_identifier: Option<String>,
1754 #[serde(rename = "VpcSecurityGroupIds")]
1756 #[serde(skip_serializing_if = "Option::is_none")]
1757 pub vpc_security_group_ids: Option<Vec<String>>,
1758}
1759
1760#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1762#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1763pub struct ModifyReplicationInstanceResponse {
1764 #[serde(rename = "ReplicationInstance")]
1766 #[serde(skip_serializing_if = "Option::is_none")]
1767 pub replication_instance: Option<ReplicationInstance>,
1768}
1769
1770#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1772#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1773pub struct ModifyReplicationSubnetGroupMessage {
1774 #[serde(rename = "ReplicationSubnetGroupDescription")]
1776 #[serde(skip_serializing_if = "Option::is_none")]
1777 pub replication_subnet_group_description: Option<String>,
1778 #[serde(rename = "ReplicationSubnetGroupIdentifier")]
1780 pub replication_subnet_group_identifier: String,
1781 #[serde(rename = "SubnetIds")]
1783 pub subnet_ids: Vec<String>,
1784}
1785
1786#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1788#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1789pub struct ModifyReplicationSubnetGroupResponse {
1790 #[serde(rename = "ReplicationSubnetGroup")]
1792 #[serde(skip_serializing_if = "Option::is_none")]
1793 pub replication_subnet_group: Option<ReplicationSubnetGroup>,
1794}
1795
1796#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1798#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1799pub struct ModifyReplicationTaskMessage {
1800 #[serde(rename = "CdcStartPosition")]
1802 #[serde(skip_serializing_if = "Option::is_none")]
1803 pub cdc_start_position: Option<String>,
1804 #[serde(rename = "CdcStartTime")]
1806 #[serde(skip_serializing_if = "Option::is_none")]
1807 pub cdc_start_time: Option<f64>,
1808 #[serde(rename = "CdcStopPosition")]
1810 #[serde(skip_serializing_if = "Option::is_none")]
1811 pub cdc_stop_position: Option<String>,
1812 #[serde(rename = "MigrationType")]
1814 #[serde(skip_serializing_if = "Option::is_none")]
1815 pub migration_type: Option<String>,
1816 #[serde(rename = "ReplicationTaskArn")]
1818 pub replication_task_arn: String,
1819 #[serde(rename = "ReplicationTaskIdentifier")]
1821 #[serde(skip_serializing_if = "Option::is_none")]
1822 pub replication_task_identifier: Option<String>,
1823 #[serde(rename = "ReplicationTaskSettings")]
1825 #[serde(skip_serializing_if = "Option::is_none")]
1826 pub replication_task_settings: Option<String>,
1827 #[serde(rename = "TableMappings")]
1829 #[serde(skip_serializing_if = "Option::is_none")]
1830 pub table_mappings: Option<String>,
1831 #[serde(rename = "TaskData")]
1833 #[serde(skip_serializing_if = "Option::is_none")]
1834 pub task_data: Option<String>,
1835}
1836
1837#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1839#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1840pub struct ModifyReplicationTaskResponse {
1841 #[serde(rename = "ReplicationTask")]
1843 #[serde(skip_serializing_if = "Option::is_none")]
1844 pub replication_task: Option<ReplicationTask>,
1845}
1846
1847#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1849pub struct MongoDbSettings {
1850 #[serde(rename = "AuthMechanism")]
1852 #[serde(skip_serializing_if = "Option::is_none")]
1853 pub auth_mechanism: Option<String>,
1854 #[serde(rename = "AuthSource")]
1856 #[serde(skip_serializing_if = "Option::is_none")]
1857 pub auth_source: Option<String>,
1858 #[serde(rename = "AuthType")]
1860 #[serde(skip_serializing_if = "Option::is_none")]
1861 pub auth_type: Option<String>,
1862 #[serde(rename = "DatabaseName")]
1864 #[serde(skip_serializing_if = "Option::is_none")]
1865 pub database_name: Option<String>,
1866 #[serde(rename = "DocsToInvestigate")]
1868 #[serde(skip_serializing_if = "Option::is_none")]
1869 pub docs_to_investigate: Option<String>,
1870 #[serde(rename = "ExtractDocId")]
1872 #[serde(skip_serializing_if = "Option::is_none")]
1873 pub extract_doc_id: Option<String>,
1874 #[serde(rename = "KmsKeyId")]
1876 #[serde(skip_serializing_if = "Option::is_none")]
1877 pub kms_key_id: Option<String>,
1878 #[serde(rename = "NestingLevel")]
1880 #[serde(skip_serializing_if = "Option::is_none")]
1881 pub nesting_level: Option<String>,
1882 #[serde(rename = "Password")]
1884 #[serde(skip_serializing_if = "Option::is_none")]
1885 pub password: Option<String>,
1886 #[serde(rename = "Port")]
1888 #[serde(skip_serializing_if = "Option::is_none")]
1889 pub port: Option<i64>,
1890 #[serde(rename = "ServerName")]
1892 #[serde(skip_serializing_if = "Option::is_none")]
1893 pub server_name: Option<String>,
1894 #[serde(rename = "Username")]
1896 #[serde(skip_serializing_if = "Option::is_none")]
1897 pub username: Option<String>,
1898}
1899
1900#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1902pub struct NeptuneSettings {
1903 #[serde(rename = "ErrorRetryDuration")]
1905 #[serde(skip_serializing_if = "Option::is_none")]
1906 pub error_retry_duration: Option<i64>,
1907 #[serde(rename = "IamAuthEnabled")]
1909 #[serde(skip_serializing_if = "Option::is_none")]
1910 pub iam_auth_enabled: Option<bool>,
1911 #[serde(rename = "MaxFileSize")]
1913 #[serde(skip_serializing_if = "Option::is_none")]
1914 pub max_file_size: Option<i64>,
1915 #[serde(rename = "MaxRetryCount")]
1917 #[serde(skip_serializing_if = "Option::is_none")]
1918 pub max_retry_count: Option<i64>,
1919 #[serde(rename = "S3BucketFolder")]
1921 pub s3_bucket_folder: String,
1922 #[serde(rename = "S3BucketName")]
1924 pub s3_bucket_name: String,
1925 #[serde(rename = "ServiceAccessRoleArn")]
1927 #[serde(skip_serializing_if = "Option::is_none")]
1928 pub service_access_role_arn: Option<String>,
1929}
1930
1931#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1933#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1934pub struct OrderableReplicationInstance {
1935 #[serde(rename = "AvailabilityZones")]
1937 #[serde(skip_serializing_if = "Option::is_none")]
1938 pub availability_zones: Option<Vec<String>>,
1939 #[serde(rename = "DefaultAllocatedStorage")]
1941 #[serde(skip_serializing_if = "Option::is_none")]
1942 pub default_allocated_storage: Option<i64>,
1943 #[serde(rename = "EngineVersion")]
1945 #[serde(skip_serializing_if = "Option::is_none")]
1946 pub engine_version: Option<String>,
1947 #[serde(rename = "IncludedAllocatedStorage")]
1949 #[serde(skip_serializing_if = "Option::is_none")]
1950 pub included_allocated_storage: Option<i64>,
1951 #[serde(rename = "MaxAllocatedStorage")]
1953 #[serde(skip_serializing_if = "Option::is_none")]
1954 pub max_allocated_storage: Option<i64>,
1955 #[serde(rename = "MinAllocatedStorage")]
1957 #[serde(skip_serializing_if = "Option::is_none")]
1958 pub min_allocated_storage: Option<i64>,
1959 #[serde(rename = "ReleaseStatus")]
1961 #[serde(skip_serializing_if = "Option::is_none")]
1962 pub release_status: Option<String>,
1963 #[serde(rename = "ReplicationInstanceClass")]
1965 #[serde(skip_serializing_if = "Option::is_none")]
1966 pub replication_instance_class: Option<String>,
1967 #[serde(rename = "StorageType")]
1969 #[serde(skip_serializing_if = "Option::is_none")]
1970 pub storage_type: Option<String>,
1971}
1972
1973#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1975#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1976pub struct PendingMaintenanceAction {
1977 #[serde(rename = "Action")]
1979 #[serde(skip_serializing_if = "Option::is_none")]
1980 pub action: Option<String>,
1981 #[serde(rename = "AutoAppliedAfterDate")]
1983 #[serde(skip_serializing_if = "Option::is_none")]
1984 pub auto_applied_after_date: Option<f64>,
1985 #[serde(rename = "CurrentApplyDate")]
1987 #[serde(skip_serializing_if = "Option::is_none")]
1988 pub current_apply_date: Option<f64>,
1989 #[serde(rename = "Description")]
1991 #[serde(skip_serializing_if = "Option::is_none")]
1992 pub description: Option<String>,
1993 #[serde(rename = "ForcedApplyDate")]
1995 #[serde(skip_serializing_if = "Option::is_none")]
1996 pub forced_apply_date: Option<f64>,
1997 #[serde(rename = "OptInStatus")]
1999 #[serde(skip_serializing_if = "Option::is_none")]
2000 pub opt_in_status: Option<String>,
2001}
2002
2003#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2004#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2005pub struct RebootReplicationInstanceMessage {
2006 #[serde(rename = "ForceFailover")]
2008 #[serde(skip_serializing_if = "Option::is_none")]
2009 pub force_failover: Option<bool>,
2010 #[serde(rename = "ReplicationInstanceArn")]
2012 pub replication_instance_arn: String,
2013}
2014
2015#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2016#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2017pub struct RebootReplicationInstanceResponse {
2018 #[serde(rename = "ReplicationInstance")]
2020 #[serde(skip_serializing_if = "Option::is_none")]
2021 pub replication_instance: Option<ReplicationInstance>,
2022}
2023
2024#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
2026pub struct RedshiftSettings {
2027 #[serde(rename = "AcceptAnyDate")]
2029 #[serde(skip_serializing_if = "Option::is_none")]
2030 pub accept_any_date: Option<bool>,
2031 #[serde(rename = "AfterConnectScript")]
2033 #[serde(skip_serializing_if = "Option::is_none")]
2034 pub after_connect_script: Option<String>,
2035 #[serde(rename = "BucketFolder")]
2037 #[serde(skip_serializing_if = "Option::is_none")]
2038 pub bucket_folder: Option<String>,
2039 #[serde(rename = "BucketName")]
2041 #[serde(skip_serializing_if = "Option::is_none")]
2042 pub bucket_name: Option<String>,
2043 #[serde(rename = "ConnectionTimeout")]
2045 #[serde(skip_serializing_if = "Option::is_none")]
2046 pub connection_timeout: Option<i64>,
2047 #[serde(rename = "DatabaseName")]
2049 #[serde(skip_serializing_if = "Option::is_none")]
2050 pub database_name: Option<String>,
2051 #[serde(rename = "DateFormat")]
2053 #[serde(skip_serializing_if = "Option::is_none")]
2054 pub date_format: Option<String>,
2055 #[serde(rename = "EmptyAsNull")]
2057 #[serde(skip_serializing_if = "Option::is_none")]
2058 pub empty_as_null: Option<bool>,
2059 #[serde(rename = "EncryptionMode")]
2061 #[serde(skip_serializing_if = "Option::is_none")]
2062 pub encryption_mode: Option<String>,
2063 #[serde(rename = "FileTransferUploadStreams")]
2065 #[serde(skip_serializing_if = "Option::is_none")]
2066 pub file_transfer_upload_streams: Option<i64>,
2067 #[serde(rename = "LoadTimeout")]
2069 #[serde(skip_serializing_if = "Option::is_none")]
2070 pub load_timeout: Option<i64>,
2071 #[serde(rename = "MaxFileSize")]
2073 #[serde(skip_serializing_if = "Option::is_none")]
2074 pub max_file_size: Option<i64>,
2075 #[serde(rename = "Password")]
2077 #[serde(skip_serializing_if = "Option::is_none")]
2078 pub password: Option<String>,
2079 #[serde(rename = "Port")]
2081 #[serde(skip_serializing_if = "Option::is_none")]
2082 pub port: Option<i64>,
2083 #[serde(rename = "RemoveQuotes")]
2085 #[serde(skip_serializing_if = "Option::is_none")]
2086 pub remove_quotes: Option<bool>,
2087 #[serde(rename = "ReplaceChars")]
2089 #[serde(skip_serializing_if = "Option::is_none")]
2090 pub replace_chars: Option<String>,
2091 #[serde(rename = "ReplaceInvalidChars")]
2093 #[serde(skip_serializing_if = "Option::is_none")]
2094 pub replace_invalid_chars: Option<String>,
2095 #[serde(rename = "ServerName")]
2097 #[serde(skip_serializing_if = "Option::is_none")]
2098 pub server_name: Option<String>,
2099 #[serde(rename = "ServerSideEncryptionKmsKeyId")]
2101 #[serde(skip_serializing_if = "Option::is_none")]
2102 pub server_side_encryption_kms_key_id: Option<String>,
2103 #[serde(rename = "ServiceAccessRoleArn")]
2105 #[serde(skip_serializing_if = "Option::is_none")]
2106 pub service_access_role_arn: Option<String>,
2107 #[serde(rename = "TimeFormat")]
2109 #[serde(skip_serializing_if = "Option::is_none")]
2110 pub time_format: Option<String>,
2111 #[serde(rename = "TrimBlanks")]
2113 #[serde(skip_serializing_if = "Option::is_none")]
2114 pub trim_blanks: Option<bool>,
2115 #[serde(rename = "TruncateColumns")]
2117 #[serde(skip_serializing_if = "Option::is_none")]
2118 pub truncate_columns: Option<bool>,
2119 #[serde(rename = "Username")]
2121 #[serde(skip_serializing_if = "Option::is_none")]
2122 pub username: Option<String>,
2123 #[serde(rename = "WriteBufferSize")]
2125 #[serde(skip_serializing_if = "Option::is_none")]
2126 pub write_buffer_size: Option<i64>,
2127}
2128
2129#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2131#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2132pub struct RefreshSchemasMessage {
2133 #[serde(rename = "EndpointArn")]
2135 pub endpoint_arn: String,
2136 #[serde(rename = "ReplicationInstanceArn")]
2138 pub replication_instance_arn: String,
2139}
2140
2141#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2143#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2144pub struct RefreshSchemasResponse {
2145 #[serde(rename = "RefreshSchemasStatus")]
2147 #[serde(skip_serializing_if = "Option::is_none")]
2148 pub refresh_schemas_status: Option<RefreshSchemasStatus>,
2149}
2150
2151#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2153#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2154pub struct RefreshSchemasStatus {
2155 #[serde(rename = "EndpointArn")]
2157 #[serde(skip_serializing_if = "Option::is_none")]
2158 pub endpoint_arn: Option<String>,
2159 #[serde(rename = "LastFailureMessage")]
2161 #[serde(skip_serializing_if = "Option::is_none")]
2162 pub last_failure_message: Option<String>,
2163 #[serde(rename = "LastRefreshDate")]
2165 #[serde(skip_serializing_if = "Option::is_none")]
2166 pub last_refresh_date: Option<f64>,
2167 #[serde(rename = "ReplicationInstanceArn")]
2169 #[serde(skip_serializing_if = "Option::is_none")]
2170 pub replication_instance_arn: Option<String>,
2171 #[serde(rename = "Status")]
2173 #[serde(skip_serializing_if = "Option::is_none")]
2174 pub status: Option<String>,
2175}
2176
2177#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2178#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2179pub struct ReloadTablesMessage {
2180 #[serde(rename = "ReloadOption")]
2182 #[serde(skip_serializing_if = "Option::is_none")]
2183 pub reload_option: Option<String>,
2184 #[serde(rename = "ReplicationTaskArn")]
2186 pub replication_task_arn: String,
2187 #[serde(rename = "TablesToReload")]
2189 pub tables_to_reload: Vec<TableToReload>,
2190}
2191
2192#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2193#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2194pub struct ReloadTablesResponse {
2195 #[serde(rename = "ReplicationTaskArn")]
2197 #[serde(skip_serializing_if = "Option::is_none")]
2198 pub replication_task_arn: Option<String>,
2199}
2200
2201#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2203#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2204pub struct RemoveTagsFromResourceMessage {
2205 #[serde(rename = "ResourceArn")]
2207 pub resource_arn: String,
2208 #[serde(rename = "TagKeys")]
2210 pub tag_keys: Vec<String>,
2211}
2212
2213#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2215#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2216pub struct RemoveTagsFromResourceResponse {}
2217
2218#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2220#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2221pub struct ReplicationInstance {
2222 #[serde(rename = "AllocatedStorage")]
2224 #[serde(skip_serializing_if = "Option::is_none")]
2225 pub allocated_storage: Option<i64>,
2226 #[serde(rename = "AutoMinorVersionUpgrade")]
2228 #[serde(skip_serializing_if = "Option::is_none")]
2229 pub auto_minor_version_upgrade: Option<bool>,
2230 #[serde(rename = "AvailabilityZone")]
2232 #[serde(skip_serializing_if = "Option::is_none")]
2233 pub availability_zone: Option<String>,
2234 #[serde(rename = "DnsNameServers")]
2236 #[serde(skip_serializing_if = "Option::is_none")]
2237 pub dns_name_servers: Option<String>,
2238 #[serde(rename = "EngineVersion")]
2240 #[serde(skip_serializing_if = "Option::is_none")]
2241 pub engine_version: Option<String>,
2242 #[serde(rename = "FreeUntil")]
2244 #[serde(skip_serializing_if = "Option::is_none")]
2245 pub free_until: Option<f64>,
2246 #[serde(rename = "InstanceCreateTime")]
2248 #[serde(skip_serializing_if = "Option::is_none")]
2249 pub instance_create_time: Option<f64>,
2250 #[serde(rename = "KmsKeyId")]
2252 #[serde(skip_serializing_if = "Option::is_none")]
2253 pub kms_key_id: Option<String>,
2254 #[serde(rename = "MultiAZ")]
2256 #[serde(skip_serializing_if = "Option::is_none")]
2257 pub multi_az: Option<bool>,
2258 #[serde(rename = "PendingModifiedValues")]
2260 #[serde(skip_serializing_if = "Option::is_none")]
2261 pub pending_modified_values: Option<ReplicationPendingModifiedValues>,
2262 #[serde(rename = "PreferredMaintenanceWindow")]
2264 #[serde(skip_serializing_if = "Option::is_none")]
2265 pub preferred_maintenance_window: Option<String>,
2266 #[serde(rename = "PubliclyAccessible")]
2268 #[serde(skip_serializing_if = "Option::is_none")]
2269 pub publicly_accessible: Option<bool>,
2270 #[serde(rename = "ReplicationInstanceArn")]
2272 #[serde(skip_serializing_if = "Option::is_none")]
2273 pub replication_instance_arn: Option<String>,
2274 #[serde(rename = "ReplicationInstanceClass")]
2276 #[serde(skip_serializing_if = "Option::is_none")]
2277 pub replication_instance_class: Option<String>,
2278 #[serde(rename = "ReplicationInstanceIdentifier")]
2280 #[serde(skip_serializing_if = "Option::is_none")]
2281 pub replication_instance_identifier: Option<String>,
2282 #[serde(rename = "ReplicationInstancePrivateIpAddresses")]
2284 #[serde(skip_serializing_if = "Option::is_none")]
2285 pub replication_instance_private_ip_addresses: Option<Vec<String>>,
2286 #[serde(rename = "ReplicationInstancePublicIpAddresses")]
2288 #[serde(skip_serializing_if = "Option::is_none")]
2289 pub replication_instance_public_ip_addresses: Option<Vec<String>>,
2290 #[serde(rename = "ReplicationInstanceStatus")]
2292 #[serde(skip_serializing_if = "Option::is_none")]
2293 pub replication_instance_status: Option<String>,
2294 #[serde(rename = "ReplicationSubnetGroup")]
2296 #[serde(skip_serializing_if = "Option::is_none")]
2297 pub replication_subnet_group: Option<ReplicationSubnetGroup>,
2298 #[serde(rename = "SecondaryAvailabilityZone")]
2300 #[serde(skip_serializing_if = "Option::is_none")]
2301 pub secondary_availability_zone: Option<String>,
2302 #[serde(rename = "VpcSecurityGroups")]
2304 #[serde(skip_serializing_if = "Option::is_none")]
2305 pub vpc_security_groups: Option<Vec<VpcSecurityGroupMembership>>,
2306}
2307
2308#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2310#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2311pub struct ReplicationInstanceTaskLog {
2312 #[serde(rename = "ReplicationInstanceTaskLogSize")]
2314 #[serde(skip_serializing_if = "Option::is_none")]
2315 pub replication_instance_task_log_size: Option<i64>,
2316 #[serde(rename = "ReplicationTaskArn")]
2318 #[serde(skip_serializing_if = "Option::is_none")]
2319 pub replication_task_arn: Option<String>,
2320 #[serde(rename = "ReplicationTaskName")]
2322 #[serde(skip_serializing_if = "Option::is_none")]
2323 pub replication_task_name: Option<String>,
2324}
2325
2326#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2328#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2329pub struct ReplicationPendingModifiedValues {
2330 #[serde(rename = "AllocatedStorage")]
2332 #[serde(skip_serializing_if = "Option::is_none")]
2333 pub allocated_storage: Option<i64>,
2334 #[serde(rename = "EngineVersion")]
2336 #[serde(skip_serializing_if = "Option::is_none")]
2337 pub engine_version: Option<String>,
2338 #[serde(rename = "MultiAZ")]
2340 #[serde(skip_serializing_if = "Option::is_none")]
2341 pub multi_az: Option<bool>,
2342 #[serde(rename = "ReplicationInstanceClass")]
2344 #[serde(skip_serializing_if = "Option::is_none")]
2345 pub replication_instance_class: Option<String>,
2346}
2347
2348#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2350#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2351pub struct ReplicationSubnetGroup {
2352 #[serde(rename = "ReplicationSubnetGroupDescription")]
2354 #[serde(skip_serializing_if = "Option::is_none")]
2355 pub replication_subnet_group_description: Option<String>,
2356 #[serde(rename = "ReplicationSubnetGroupIdentifier")]
2358 #[serde(skip_serializing_if = "Option::is_none")]
2359 pub replication_subnet_group_identifier: Option<String>,
2360 #[serde(rename = "SubnetGroupStatus")]
2362 #[serde(skip_serializing_if = "Option::is_none")]
2363 pub subnet_group_status: Option<String>,
2364 #[serde(rename = "Subnets")]
2366 #[serde(skip_serializing_if = "Option::is_none")]
2367 pub subnets: Option<Vec<Subnet>>,
2368 #[serde(rename = "VpcId")]
2370 #[serde(skip_serializing_if = "Option::is_none")]
2371 pub vpc_id: Option<String>,
2372}
2373
2374#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2376#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2377pub struct ReplicationTask {
2378 #[serde(rename = "CdcStartPosition")]
2380 #[serde(skip_serializing_if = "Option::is_none")]
2381 pub cdc_start_position: Option<String>,
2382 #[serde(rename = "CdcStopPosition")]
2384 #[serde(skip_serializing_if = "Option::is_none")]
2385 pub cdc_stop_position: Option<String>,
2386 #[serde(rename = "LastFailureMessage")]
2388 #[serde(skip_serializing_if = "Option::is_none")]
2389 pub last_failure_message: Option<String>,
2390 #[serde(rename = "MigrationType")]
2392 #[serde(skip_serializing_if = "Option::is_none")]
2393 pub migration_type: Option<String>,
2394 #[serde(rename = "RecoveryCheckpoint")]
2396 #[serde(skip_serializing_if = "Option::is_none")]
2397 pub recovery_checkpoint: Option<String>,
2398 #[serde(rename = "ReplicationInstanceArn")]
2400 #[serde(skip_serializing_if = "Option::is_none")]
2401 pub replication_instance_arn: Option<String>,
2402 #[serde(rename = "ReplicationTaskArn")]
2404 #[serde(skip_serializing_if = "Option::is_none")]
2405 pub replication_task_arn: Option<String>,
2406 #[serde(rename = "ReplicationTaskCreationDate")]
2408 #[serde(skip_serializing_if = "Option::is_none")]
2409 pub replication_task_creation_date: Option<f64>,
2410 #[serde(rename = "ReplicationTaskIdentifier")]
2412 #[serde(skip_serializing_if = "Option::is_none")]
2413 pub replication_task_identifier: Option<String>,
2414 #[serde(rename = "ReplicationTaskSettings")]
2416 #[serde(skip_serializing_if = "Option::is_none")]
2417 pub replication_task_settings: Option<String>,
2418 #[serde(rename = "ReplicationTaskStartDate")]
2420 #[serde(skip_serializing_if = "Option::is_none")]
2421 pub replication_task_start_date: Option<f64>,
2422 #[serde(rename = "ReplicationTaskStats")]
2424 #[serde(skip_serializing_if = "Option::is_none")]
2425 pub replication_task_stats: Option<ReplicationTaskStats>,
2426 #[serde(rename = "SourceEndpointArn")]
2428 #[serde(skip_serializing_if = "Option::is_none")]
2429 pub source_endpoint_arn: Option<String>,
2430 #[serde(rename = "Status")]
2432 #[serde(skip_serializing_if = "Option::is_none")]
2433 pub status: Option<String>,
2434 #[serde(rename = "StopReason")]
2436 #[serde(skip_serializing_if = "Option::is_none")]
2437 pub stop_reason: Option<String>,
2438 #[serde(rename = "TableMappings")]
2440 #[serde(skip_serializing_if = "Option::is_none")]
2441 pub table_mappings: Option<String>,
2442 #[serde(rename = "TargetEndpointArn")]
2444 #[serde(skip_serializing_if = "Option::is_none")]
2445 pub target_endpoint_arn: Option<String>,
2446 #[serde(rename = "TaskData")]
2448 #[serde(skip_serializing_if = "Option::is_none")]
2449 pub task_data: Option<String>,
2450}
2451
2452#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2454#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2455pub struct ReplicationTaskAssessmentResult {
2456 #[serde(rename = "AssessmentResults")]
2458 #[serde(skip_serializing_if = "Option::is_none")]
2459 pub assessment_results: Option<String>,
2460 #[serde(rename = "AssessmentResultsFile")]
2462 #[serde(skip_serializing_if = "Option::is_none")]
2463 pub assessment_results_file: Option<String>,
2464 #[serde(rename = "AssessmentStatus")]
2466 #[serde(skip_serializing_if = "Option::is_none")]
2467 pub assessment_status: Option<String>,
2468 #[serde(rename = "ReplicationTaskArn")]
2470 #[serde(skip_serializing_if = "Option::is_none")]
2471 pub replication_task_arn: Option<String>,
2472 #[serde(rename = "ReplicationTaskIdentifier")]
2474 #[serde(skip_serializing_if = "Option::is_none")]
2475 pub replication_task_identifier: Option<String>,
2476 #[serde(rename = "ReplicationTaskLastAssessmentDate")]
2478 #[serde(skip_serializing_if = "Option::is_none")]
2479 pub replication_task_last_assessment_date: Option<f64>,
2480 #[serde(rename = "S3ObjectUrl")]
2482 #[serde(skip_serializing_if = "Option::is_none")]
2483 pub s3_object_url: Option<String>,
2484}
2485
2486#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2488#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2489pub struct ReplicationTaskStats {
2490 #[serde(rename = "ElapsedTimeMillis")]
2492 #[serde(skip_serializing_if = "Option::is_none")]
2493 pub elapsed_time_millis: Option<i64>,
2494 #[serde(rename = "FreshStartDate")]
2496 #[serde(skip_serializing_if = "Option::is_none")]
2497 pub fresh_start_date: Option<f64>,
2498 #[serde(rename = "FullLoadFinishDate")]
2500 #[serde(skip_serializing_if = "Option::is_none")]
2501 pub full_load_finish_date: Option<f64>,
2502 #[serde(rename = "FullLoadProgressPercent")]
2504 #[serde(skip_serializing_if = "Option::is_none")]
2505 pub full_load_progress_percent: Option<i64>,
2506 #[serde(rename = "FullLoadStartDate")]
2508 #[serde(skip_serializing_if = "Option::is_none")]
2509 pub full_load_start_date: Option<f64>,
2510 #[serde(rename = "StartDate")]
2512 #[serde(skip_serializing_if = "Option::is_none")]
2513 pub start_date: Option<f64>,
2514 #[serde(rename = "StopDate")]
2516 #[serde(skip_serializing_if = "Option::is_none")]
2517 pub stop_date: Option<f64>,
2518 #[serde(rename = "TablesErrored")]
2520 #[serde(skip_serializing_if = "Option::is_none")]
2521 pub tables_errored: Option<i64>,
2522 #[serde(rename = "TablesLoaded")]
2524 #[serde(skip_serializing_if = "Option::is_none")]
2525 pub tables_loaded: Option<i64>,
2526 #[serde(rename = "TablesLoading")]
2528 #[serde(skip_serializing_if = "Option::is_none")]
2529 pub tables_loading: Option<i64>,
2530 #[serde(rename = "TablesQueued")]
2532 #[serde(skip_serializing_if = "Option::is_none")]
2533 pub tables_queued: Option<i64>,
2534}
2535
2536#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2538#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2539pub struct ResourcePendingMaintenanceActions {
2540 #[serde(rename = "PendingMaintenanceActionDetails")]
2542 #[serde(skip_serializing_if = "Option::is_none")]
2543 pub pending_maintenance_action_details: Option<Vec<PendingMaintenanceAction>>,
2544 #[serde(rename = "ResourceIdentifier")]
2546 #[serde(skip_serializing_if = "Option::is_none")]
2547 pub resource_identifier: Option<String>,
2548}
2549
2550#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
2552pub struct S3Settings {
2553 #[serde(rename = "BucketFolder")]
2555 #[serde(skip_serializing_if = "Option::is_none")]
2556 pub bucket_folder: Option<String>,
2557 #[serde(rename = "BucketName")]
2559 #[serde(skip_serializing_if = "Option::is_none")]
2560 pub bucket_name: Option<String>,
2561 #[serde(rename = "CdcInsertsAndUpdates")]
2563 #[serde(skip_serializing_if = "Option::is_none")]
2564 pub cdc_inserts_and_updates: Option<bool>,
2565 #[serde(rename = "CdcInsertsOnly")]
2567 #[serde(skip_serializing_if = "Option::is_none")]
2568 pub cdc_inserts_only: Option<bool>,
2569 #[serde(rename = "CompressionType")]
2571 #[serde(skip_serializing_if = "Option::is_none")]
2572 pub compression_type: Option<String>,
2573 #[serde(rename = "CsvDelimiter")]
2575 #[serde(skip_serializing_if = "Option::is_none")]
2576 pub csv_delimiter: Option<String>,
2577 #[serde(rename = "CsvRowDelimiter")]
2579 #[serde(skip_serializing_if = "Option::is_none")]
2580 pub csv_row_delimiter: Option<String>,
2581 #[serde(rename = "DataFormat")]
2583 #[serde(skip_serializing_if = "Option::is_none")]
2584 pub data_format: Option<String>,
2585 #[serde(rename = "DataPageSize")]
2587 #[serde(skip_serializing_if = "Option::is_none")]
2588 pub data_page_size: Option<i64>,
2589 #[serde(rename = "DictPageSizeLimit")]
2591 #[serde(skip_serializing_if = "Option::is_none")]
2592 pub dict_page_size_limit: Option<i64>,
2593 #[serde(rename = "EnableStatistics")]
2595 #[serde(skip_serializing_if = "Option::is_none")]
2596 pub enable_statistics: Option<bool>,
2597 #[serde(rename = "EncodingType")]
2599 #[serde(skip_serializing_if = "Option::is_none")]
2600 pub encoding_type: Option<String>,
2601 #[serde(rename = "EncryptionMode")]
2603 #[serde(skip_serializing_if = "Option::is_none")]
2604 pub encryption_mode: Option<String>,
2605 #[serde(rename = "ExternalTableDefinition")]
2607 #[serde(skip_serializing_if = "Option::is_none")]
2608 pub external_table_definition: Option<String>,
2609 #[serde(rename = "IncludeOpForFullLoad")]
2611 #[serde(skip_serializing_if = "Option::is_none")]
2612 pub include_op_for_full_load: Option<bool>,
2613 #[serde(rename = "ParquetTimestampInMillisecond")]
2615 #[serde(skip_serializing_if = "Option::is_none")]
2616 pub parquet_timestamp_in_millisecond: Option<bool>,
2617 #[serde(rename = "ParquetVersion")]
2619 #[serde(skip_serializing_if = "Option::is_none")]
2620 pub parquet_version: Option<String>,
2621 #[serde(rename = "RowGroupLength")]
2623 #[serde(skip_serializing_if = "Option::is_none")]
2624 pub row_group_length: Option<i64>,
2625 #[serde(rename = "ServerSideEncryptionKmsKeyId")]
2627 #[serde(skip_serializing_if = "Option::is_none")]
2628 pub server_side_encryption_kms_key_id: Option<String>,
2629 #[serde(rename = "ServiceAccessRoleArn")]
2631 #[serde(skip_serializing_if = "Option::is_none")]
2632 pub service_access_role_arn: Option<String>,
2633 #[serde(rename = "TimestampColumnName")]
2635 #[serde(skip_serializing_if = "Option::is_none")]
2636 pub timestamp_column_name: Option<String>,
2637}
2638
2639#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2641#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2642pub struct StartReplicationTaskAssessmentMessage {
2643 #[serde(rename = "ReplicationTaskArn")]
2645 pub replication_task_arn: String,
2646}
2647
2648#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2650#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2651pub struct StartReplicationTaskAssessmentResponse {
2652 #[serde(rename = "ReplicationTask")]
2654 #[serde(skip_serializing_if = "Option::is_none")]
2655 pub replication_task: Option<ReplicationTask>,
2656}
2657
2658#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2660#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2661pub struct StartReplicationTaskMessage {
2662 #[serde(rename = "CdcStartPosition")]
2664 #[serde(skip_serializing_if = "Option::is_none")]
2665 pub cdc_start_position: Option<String>,
2666 #[serde(rename = "CdcStartTime")]
2668 #[serde(skip_serializing_if = "Option::is_none")]
2669 pub cdc_start_time: Option<f64>,
2670 #[serde(rename = "CdcStopPosition")]
2672 #[serde(skip_serializing_if = "Option::is_none")]
2673 pub cdc_stop_position: Option<String>,
2674 #[serde(rename = "ReplicationTaskArn")]
2676 pub replication_task_arn: String,
2677 #[serde(rename = "StartReplicationTaskType")]
2679 pub start_replication_task_type: String,
2680}
2681
2682#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2684#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2685pub struct StartReplicationTaskResponse {
2686 #[serde(rename = "ReplicationTask")]
2688 #[serde(skip_serializing_if = "Option::is_none")]
2689 pub replication_task: Option<ReplicationTask>,
2690}
2691
2692#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2694#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2695pub struct StopReplicationTaskMessage {
2696 #[serde(rename = "ReplicationTaskArn")]
2698 pub replication_task_arn: String,
2699}
2700
2701#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2703#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2704pub struct StopReplicationTaskResponse {
2705 #[serde(rename = "ReplicationTask")]
2707 #[serde(skip_serializing_if = "Option::is_none")]
2708 pub replication_task: Option<ReplicationTask>,
2709}
2710
2711#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2713#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2714pub struct Subnet {
2715 #[serde(rename = "SubnetAvailabilityZone")]
2717 #[serde(skip_serializing_if = "Option::is_none")]
2718 pub subnet_availability_zone: Option<AvailabilityZone>,
2719 #[serde(rename = "SubnetIdentifier")]
2721 #[serde(skip_serializing_if = "Option::is_none")]
2722 pub subnet_identifier: Option<String>,
2723 #[serde(rename = "SubnetStatus")]
2725 #[serde(skip_serializing_if = "Option::is_none")]
2726 pub subnet_status: Option<String>,
2727}
2728
2729#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2731#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2732pub struct SupportedEndpointType {
2733 #[serde(rename = "EndpointType")]
2735 #[serde(skip_serializing_if = "Option::is_none")]
2736 pub endpoint_type: Option<String>,
2737 #[serde(rename = "EngineDisplayName")]
2739 #[serde(skip_serializing_if = "Option::is_none")]
2740 pub engine_display_name: Option<String>,
2741 #[serde(rename = "EngineName")]
2743 #[serde(skip_serializing_if = "Option::is_none")]
2744 pub engine_name: Option<String>,
2745 #[serde(rename = "ReplicationInstanceEngineMinimumVersion")]
2747 #[serde(skip_serializing_if = "Option::is_none")]
2748 pub replication_instance_engine_minimum_version: Option<String>,
2749 #[serde(rename = "SupportsCDC")]
2751 #[serde(skip_serializing_if = "Option::is_none")]
2752 pub supports_cdc: Option<bool>,
2753}
2754
2755#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2757#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2758pub struct TableStatistics {
2759 #[serde(rename = "Ddls")]
2761 #[serde(skip_serializing_if = "Option::is_none")]
2762 pub ddls: Option<i64>,
2763 #[serde(rename = "Deletes")]
2765 #[serde(skip_serializing_if = "Option::is_none")]
2766 pub deletes: Option<i64>,
2767 #[serde(rename = "FullLoadCondtnlChkFailedRows")]
2769 #[serde(skip_serializing_if = "Option::is_none")]
2770 pub full_load_condtnl_chk_failed_rows: Option<i64>,
2771 #[serde(rename = "FullLoadEndTime")]
2773 #[serde(skip_serializing_if = "Option::is_none")]
2774 pub full_load_end_time: Option<f64>,
2775 #[serde(rename = "FullLoadErrorRows")]
2777 #[serde(skip_serializing_if = "Option::is_none")]
2778 pub full_load_error_rows: Option<i64>,
2779 #[serde(rename = "FullLoadReloaded")]
2781 #[serde(skip_serializing_if = "Option::is_none")]
2782 pub full_load_reloaded: Option<bool>,
2783 #[serde(rename = "FullLoadRows")]
2785 #[serde(skip_serializing_if = "Option::is_none")]
2786 pub full_load_rows: Option<i64>,
2787 #[serde(rename = "FullLoadStartTime")]
2789 #[serde(skip_serializing_if = "Option::is_none")]
2790 pub full_load_start_time: Option<f64>,
2791 #[serde(rename = "Inserts")]
2793 #[serde(skip_serializing_if = "Option::is_none")]
2794 pub inserts: Option<i64>,
2795 #[serde(rename = "LastUpdateTime")]
2797 #[serde(skip_serializing_if = "Option::is_none")]
2798 pub last_update_time: Option<f64>,
2799 #[serde(rename = "SchemaName")]
2801 #[serde(skip_serializing_if = "Option::is_none")]
2802 pub schema_name: Option<String>,
2803 #[serde(rename = "TableName")]
2805 #[serde(skip_serializing_if = "Option::is_none")]
2806 pub table_name: Option<String>,
2807 #[serde(rename = "TableState")]
2809 #[serde(skip_serializing_if = "Option::is_none")]
2810 pub table_state: Option<String>,
2811 #[serde(rename = "Updates")]
2813 #[serde(skip_serializing_if = "Option::is_none")]
2814 pub updates: Option<i64>,
2815 #[serde(rename = "ValidationFailedRecords")]
2817 #[serde(skip_serializing_if = "Option::is_none")]
2818 pub validation_failed_records: Option<i64>,
2819 #[serde(rename = "ValidationPendingRecords")]
2821 #[serde(skip_serializing_if = "Option::is_none")]
2822 pub validation_pending_records: Option<i64>,
2823 #[serde(rename = "ValidationState")]
2825 #[serde(skip_serializing_if = "Option::is_none")]
2826 pub validation_state: Option<String>,
2827 #[serde(rename = "ValidationStateDetails")]
2829 #[serde(skip_serializing_if = "Option::is_none")]
2830 pub validation_state_details: Option<String>,
2831 #[serde(rename = "ValidationSuspendedRecords")]
2833 #[serde(skip_serializing_if = "Option::is_none")]
2834 pub validation_suspended_records: Option<i64>,
2835}
2836
2837#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2839#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2840pub struct TableToReload {
2841 #[serde(rename = "SchemaName")]
2843 #[serde(skip_serializing_if = "Option::is_none")]
2844 pub schema_name: Option<String>,
2845 #[serde(rename = "TableName")]
2847 #[serde(skip_serializing_if = "Option::is_none")]
2848 pub table_name: Option<String>,
2849}
2850
2851#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
2853pub struct Tag {
2854 #[serde(rename = "Key")]
2856 #[serde(skip_serializing_if = "Option::is_none")]
2857 pub key: Option<String>,
2858 #[serde(rename = "Value")]
2860 #[serde(skip_serializing_if = "Option::is_none")]
2861 pub value: Option<String>,
2862}
2863
2864#[derive(Clone, Debug, Default, PartialEq, Serialize)]
2866#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
2867pub struct TestConnectionMessage {
2868 #[serde(rename = "EndpointArn")]
2870 pub endpoint_arn: String,
2871 #[serde(rename = "ReplicationInstanceArn")]
2873 pub replication_instance_arn: String,
2874}
2875
2876#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2878#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2879pub struct TestConnectionResponse {
2880 #[serde(rename = "Connection")]
2882 #[serde(skip_serializing_if = "Option::is_none")]
2883 pub connection: Option<Connection>,
2884}
2885
2886#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
2888#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
2889pub struct VpcSecurityGroupMembership {
2890 #[serde(rename = "Status")]
2892 #[serde(skip_serializing_if = "Option::is_none")]
2893 pub status: Option<String>,
2894 #[serde(rename = "VpcSecurityGroupId")]
2896 #[serde(skip_serializing_if = "Option::is_none")]
2897 pub vpc_security_group_id: Option<String>,
2898}
2899
2900#[derive(Debug, PartialEq)]
2902pub enum AddTagsToResourceError {
2903 ResourceNotFoundFault(String),
2905}
2906
2907impl AddTagsToResourceError {
2908 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<AddTagsToResourceError> {
2909 if let Some(err) = proto::json::Error::parse(&res) {
2910 match err.typ.as_str() {
2911 "ResourceNotFoundFault" => {
2912 return RusotoError::Service(AddTagsToResourceError::ResourceNotFoundFault(
2913 err.msg,
2914 ))
2915 }
2916 "ValidationException" => return RusotoError::Validation(err.msg),
2917 _ => {}
2918 }
2919 }
2920 RusotoError::Unknown(res)
2921 }
2922}
2923impl fmt::Display for AddTagsToResourceError {
2924 #[allow(unused_variables)]
2925 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2926 match *self {
2927 AddTagsToResourceError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
2928 }
2929 }
2930}
2931impl Error for AddTagsToResourceError {}
2932#[derive(Debug, PartialEq)]
2934pub enum ApplyPendingMaintenanceActionError {
2935 ResourceNotFoundFault(String),
2937}
2938
2939impl ApplyPendingMaintenanceActionError {
2940 pub fn from_response(
2941 res: BufferedHttpResponse,
2942 ) -> RusotoError<ApplyPendingMaintenanceActionError> {
2943 if let Some(err) = proto::json::Error::parse(&res) {
2944 match err.typ.as_str() {
2945 "ResourceNotFoundFault" => {
2946 return RusotoError::Service(
2947 ApplyPendingMaintenanceActionError::ResourceNotFoundFault(err.msg),
2948 )
2949 }
2950 "ValidationException" => return RusotoError::Validation(err.msg),
2951 _ => {}
2952 }
2953 }
2954 RusotoError::Unknown(res)
2955 }
2956}
2957impl fmt::Display for ApplyPendingMaintenanceActionError {
2958 #[allow(unused_variables)]
2959 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2960 match *self {
2961 ApplyPendingMaintenanceActionError::ResourceNotFoundFault(ref cause) => {
2962 write!(f, "{}", cause)
2963 }
2964 }
2965 }
2966}
2967impl Error for ApplyPendingMaintenanceActionError {}
2968#[derive(Debug, PartialEq)]
2970pub enum CreateEndpointError {
2971 AccessDeniedFault(String),
2973 InvalidResourceStateFault(String),
2975 KMSKeyNotAccessibleFault(String),
2977 ResourceAlreadyExistsFault(String),
2979 ResourceNotFoundFault(String),
2981 ResourceQuotaExceededFault(String),
2983}
2984
2985impl CreateEndpointError {
2986 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateEndpointError> {
2987 if let Some(err) = proto::json::Error::parse(&res) {
2988 match err.typ.as_str() {
2989 "AccessDeniedFault" => {
2990 return RusotoError::Service(CreateEndpointError::AccessDeniedFault(err.msg))
2991 }
2992 "InvalidResourceStateFault" => {
2993 return RusotoError::Service(CreateEndpointError::InvalidResourceStateFault(
2994 err.msg,
2995 ))
2996 }
2997 "KMSKeyNotAccessibleFault" => {
2998 return RusotoError::Service(CreateEndpointError::KMSKeyNotAccessibleFault(
2999 err.msg,
3000 ))
3001 }
3002 "ResourceAlreadyExistsFault" => {
3003 return RusotoError::Service(CreateEndpointError::ResourceAlreadyExistsFault(
3004 err.msg,
3005 ))
3006 }
3007 "ResourceNotFoundFault" => {
3008 return RusotoError::Service(CreateEndpointError::ResourceNotFoundFault(
3009 err.msg,
3010 ))
3011 }
3012 "ResourceQuotaExceededFault" => {
3013 return RusotoError::Service(CreateEndpointError::ResourceQuotaExceededFault(
3014 err.msg,
3015 ))
3016 }
3017 "ValidationException" => return RusotoError::Validation(err.msg),
3018 _ => {}
3019 }
3020 }
3021 RusotoError::Unknown(res)
3022 }
3023}
3024impl fmt::Display for CreateEndpointError {
3025 #[allow(unused_variables)]
3026 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3027 match *self {
3028 CreateEndpointError::AccessDeniedFault(ref cause) => write!(f, "{}", cause),
3029 CreateEndpointError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
3030 CreateEndpointError::KMSKeyNotAccessibleFault(ref cause) => write!(f, "{}", cause),
3031 CreateEndpointError::ResourceAlreadyExistsFault(ref cause) => write!(f, "{}", cause),
3032 CreateEndpointError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3033 CreateEndpointError::ResourceQuotaExceededFault(ref cause) => write!(f, "{}", cause),
3034 }
3035 }
3036}
3037impl Error for CreateEndpointError {}
3038#[derive(Debug, PartialEq)]
3040pub enum CreateEventSubscriptionError {
3041 KMSAccessDeniedFault(String),
3043 KMSDisabledFault(String),
3045 KMSInvalidStateFault(String),
3047 KMSNotFoundFault(String),
3049 KMSThrottlingFault(String),
3051 ResourceAlreadyExistsFault(String),
3053 ResourceNotFoundFault(String),
3055 ResourceQuotaExceededFault(String),
3057 SNSInvalidTopicFault(String),
3059 SNSNoAuthorizationFault(String),
3061}
3062
3063impl CreateEventSubscriptionError {
3064 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateEventSubscriptionError> {
3065 if let Some(err) = proto::json::Error::parse(&res) {
3066 match err.typ.as_str() {
3067 "KMSAccessDeniedFault" => {
3068 return RusotoError::Service(
3069 CreateEventSubscriptionError::KMSAccessDeniedFault(err.msg),
3070 )
3071 }
3072 "KMSDisabledFault" => {
3073 return RusotoError::Service(CreateEventSubscriptionError::KMSDisabledFault(
3074 err.msg,
3075 ))
3076 }
3077 "KMSInvalidStateFault" => {
3078 return RusotoError::Service(
3079 CreateEventSubscriptionError::KMSInvalidStateFault(err.msg),
3080 )
3081 }
3082 "KMSNotFoundFault" => {
3083 return RusotoError::Service(CreateEventSubscriptionError::KMSNotFoundFault(
3084 err.msg,
3085 ))
3086 }
3087 "KMSThrottlingFault" => {
3088 return RusotoError::Service(CreateEventSubscriptionError::KMSThrottlingFault(
3089 err.msg,
3090 ))
3091 }
3092 "ResourceAlreadyExistsFault" => {
3093 return RusotoError::Service(
3094 CreateEventSubscriptionError::ResourceAlreadyExistsFault(err.msg),
3095 )
3096 }
3097 "ResourceNotFoundFault" => {
3098 return RusotoError::Service(
3099 CreateEventSubscriptionError::ResourceNotFoundFault(err.msg),
3100 )
3101 }
3102 "ResourceQuotaExceededFault" => {
3103 return RusotoError::Service(
3104 CreateEventSubscriptionError::ResourceQuotaExceededFault(err.msg),
3105 )
3106 }
3107 "SNSInvalidTopicFault" => {
3108 return RusotoError::Service(
3109 CreateEventSubscriptionError::SNSInvalidTopicFault(err.msg),
3110 )
3111 }
3112 "SNSNoAuthorizationFault" => {
3113 return RusotoError::Service(
3114 CreateEventSubscriptionError::SNSNoAuthorizationFault(err.msg),
3115 )
3116 }
3117 "ValidationException" => return RusotoError::Validation(err.msg),
3118 _ => {}
3119 }
3120 }
3121 RusotoError::Unknown(res)
3122 }
3123}
3124impl fmt::Display for CreateEventSubscriptionError {
3125 #[allow(unused_variables)]
3126 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3127 match *self {
3128 CreateEventSubscriptionError::KMSAccessDeniedFault(ref cause) => write!(f, "{}", cause),
3129 CreateEventSubscriptionError::KMSDisabledFault(ref cause) => write!(f, "{}", cause),
3130 CreateEventSubscriptionError::KMSInvalidStateFault(ref cause) => write!(f, "{}", cause),
3131 CreateEventSubscriptionError::KMSNotFoundFault(ref cause) => write!(f, "{}", cause),
3132 CreateEventSubscriptionError::KMSThrottlingFault(ref cause) => write!(f, "{}", cause),
3133 CreateEventSubscriptionError::ResourceAlreadyExistsFault(ref cause) => {
3134 write!(f, "{}", cause)
3135 }
3136 CreateEventSubscriptionError::ResourceNotFoundFault(ref cause) => {
3137 write!(f, "{}", cause)
3138 }
3139 CreateEventSubscriptionError::ResourceQuotaExceededFault(ref cause) => {
3140 write!(f, "{}", cause)
3141 }
3142 CreateEventSubscriptionError::SNSInvalidTopicFault(ref cause) => write!(f, "{}", cause),
3143 CreateEventSubscriptionError::SNSNoAuthorizationFault(ref cause) => {
3144 write!(f, "{}", cause)
3145 }
3146 }
3147 }
3148}
3149impl Error for CreateEventSubscriptionError {}
3150#[derive(Debug, PartialEq)]
3152pub enum CreateReplicationInstanceError {
3153 AccessDeniedFault(String),
3155 InsufficientResourceCapacityFault(String),
3157 InvalidResourceStateFault(String),
3159 InvalidSubnet(String),
3161 KMSKeyNotAccessibleFault(String),
3163 ReplicationSubnetGroupDoesNotCoverEnoughAZs(String),
3165 ResourceAlreadyExistsFault(String),
3167 ResourceNotFoundFault(String),
3169 ResourceQuotaExceededFault(String),
3171 StorageQuotaExceededFault(String),
3173}
3174
3175impl CreateReplicationInstanceError {
3176 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateReplicationInstanceError> {
3177 if let Some(err) = proto::json::Error::parse(&res) {
3178 match err.typ.as_str() {
3179 "AccessDeniedFault" => {
3180 return RusotoError::Service(CreateReplicationInstanceError::AccessDeniedFault(
3181 err.msg,
3182 ))
3183 }
3184 "InsufficientResourceCapacityFault" => {
3185 return RusotoError::Service(
3186 CreateReplicationInstanceError::InsufficientResourceCapacityFault(err.msg),
3187 )
3188 }
3189 "InvalidResourceStateFault" => {
3190 return RusotoError::Service(
3191 CreateReplicationInstanceError::InvalidResourceStateFault(err.msg),
3192 )
3193 }
3194 "InvalidSubnet" => {
3195 return RusotoError::Service(CreateReplicationInstanceError::InvalidSubnet(
3196 err.msg,
3197 ))
3198 }
3199 "KMSKeyNotAccessibleFault" => {
3200 return RusotoError::Service(
3201 CreateReplicationInstanceError::KMSKeyNotAccessibleFault(err.msg),
3202 )
3203 }
3204 "ReplicationSubnetGroupDoesNotCoverEnoughAZs" => {
3205 return RusotoError::Service(
3206 CreateReplicationInstanceError::ReplicationSubnetGroupDoesNotCoverEnoughAZs(
3207 err.msg,
3208 ),
3209 )
3210 }
3211 "ResourceAlreadyExistsFault" => {
3212 return RusotoError::Service(
3213 CreateReplicationInstanceError::ResourceAlreadyExistsFault(err.msg),
3214 )
3215 }
3216 "ResourceNotFoundFault" => {
3217 return RusotoError::Service(
3218 CreateReplicationInstanceError::ResourceNotFoundFault(err.msg),
3219 )
3220 }
3221 "ResourceQuotaExceededFault" => {
3222 return RusotoError::Service(
3223 CreateReplicationInstanceError::ResourceQuotaExceededFault(err.msg),
3224 )
3225 }
3226 "StorageQuotaExceededFault" => {
3227 return RusotoError::Service(
3228 CreateReplicationInstanceError::StorageQuotaExceededFault(err.msg),
3229 )
3230 }
3231 "ValidationException" => return RusotoError::Validation(err.msg),
3232 _ => {}
3233 }
3234 }
3235 RusotoError::Unknown(res)
3236 }
3237}
3238impl fmt::Display for CreateReplicationInstanceError {
3239 #[allow(unused_variables)]
3240 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3241 match *self {
3242 CreateReplicationInstanceError::AccessDeniedFault(ref cause) => write!(f, "{}", cause),
3243 CreateReplicationInstanceError::InsufficientResourceCapacityFault(ref cause) => {
3244 write!(f, "{}", cause)
3245 }
3246 CreateReplicationInstanceError::InvalidResourceStateFault(ref cause) => {
3247 write!(f, "{}", cause)
3248 }
3249 CreateReplicationInstanceError::InvalidSubnet(ref cause) => write!(f, "{}", cause),
3250 CreateReplicationInstanceError::KMSKeyNotAccessibleFault(ref cause) => {
3251 write!(f, "{}", cause)
3252 }
3253 CreateReplicationInstanceError::ReplicationSubnetGroupDoesNotCoverEnoughAZs(
3254 ref cause,
3255 ) => write!(f, "{}", cause),
3256 CreateReplicationInstanceError::ResourceAlreadyExistsFault(ref cause) => {
3257 write!(f, "{}", cause)
3258 }
3259 CreateReplicationInstanceError::ResourceNotFoundFault(ref cause) => {
3260 write!(f, "{}", cause)
3261 }
3262 CreateReplicationInstanceError::ResourceQuotaExceededFault(ref cause) => {
3263 write!(f, "{}", cause)
3264 }
3265 CreateReplicationInstanceError::StorageQuotaExceededFault(ref cause) => {
3266 write!(f, "{}", cause)
3267 }
3268 }
3269 }
3270}
3271impl Error for CreateReplicationInstanceError {}
3272#[derive(Debug, PartialEq)]
3274pub enum CreateReplicationSubnetGroupError {
3275 AccessDeniedFault(String),
3277 InvalidSubnet(String),
3279 ReplicationSubnetGroupDoesNotCoverEnoughAZs(String),
3281 ResourceAlreadyExistsFault(String),
3283 ResourceNotFoundFault(String),
3285 ResourceQuotaExceededFault(String),
3287}
3288
3289impl CreateReplicationSubnetGroupError {
3290 pub fn from_response(
3291 res: BufferedHttpResponse,
3292 ) -> RusotoError<CreateReplicationSubnetGroupError> {
3293 if let Some(err) = proto::json::Error::parse(&res) {
3294 match err.typ.as_str() {
3295 "AccessDeniedFault" => {
3296 return RusotoError::Service(
3297 CreateReplicationSubnetGroupError::AccessDeniedFault(err.msg),
3298 )
3299 }
3300 "InvalidSubnet" => {
3301 return RusotoError::Service(CreateReplicationSubnetGroupError::InvalidSubnet(
3302 err.msg,
3303 ))
3304 }
3305 "ReplicationSubnetGroupDoesNotCoverEnoughAZs" => return RusotoError::Service(
3306 CreateReplicationSubnetGroupError::ReplicationSubnetGroupDoesNotCoverEnoughAZs(
3307 err.msg,
3308 ),
3309 ),
3310 "ResourceAlreadyExistsFault" => {
3311 return RusotoError::Service(
3312 CreateReplicationSubnetGroupError::ResourceAlreadyExistsFault(err.msg),
3313 )
3314 }
3315 "ResourceNotFoundFault" => {
3316 return RusotoError::Service(
3317 CreateReplicationSubnetGroupError::ResourceNotFoundFault(err.msg),
3318 )
3319 }
3320 "ResourceQuotaExceededFault" => {
3321 return RusotoError::Service(
3322 CreateReplicationSubnetGroupError::ResourceQuotaExceededFault(err.msg),
3323 )
3324 }
3325 "ValidationException" => return RusotoError::Validation(err.msg),
3326 _ => {}
3327 }
3328 }
3329 RusotoError::Unknown(res)
3330 }
3331}
3332impl fmt::Display for CreateReplicationSubnetGroupError {
3333 #[allow(unused_variables)]
3334 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3335 match *self {
3336 CreateReplicationSubnetGroupError::AccessDeniedFault(ref cause) => {
3337 write!(f, "{}", cause)
3338 }
3339 CreateReplicationSubnetGroupError::InvalidSubnet(ref cause) => write!(f, "{}", cause),
3340 CreateReplicationSubnetGroupError::ReplicationSubnetGroupDoesNotCoverEnoughAZs(
3341 ref cause,
3342 ) => write!(f, "{}", cause),
3343 CreateReplicationSubnetGroupError::ResourceAlreadyExistsFault(ref cause) => {
3344 write!(f, "{}", cause)
3345 }
3346 CreateReplicationSubnetGroupError::ResourceNotFoundFault(ref cause) => {
3347 write!(f, "{}", cause)
3348 }
3349 CreateReplicationSubnetGroupError::ResourceQuotaExceededFault(ref cause) => {
3350 write!(f, "{}", cause)
3351 }
3352 }
3353 }
3354}
3355impl Error for CreateReplicationSubnetGroupError {}
3356#[derive(Debug, PartialEq)]
3358pub enum CreateReplicationTaskError {
3359 AccessDeniedFault(String),
3361 InvalidResourceStateFault(String),
3363 KMSKeyNotAccessibleFault(String),
3365 ResourceAlreadyExistsFault(String),
3367 ResourceNotFoundFault(String),
3369 ResourceQuotaExceededFault(String),
3371}
3372
3373impl CreateReplicationTaskError {
3374 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateReplicationTaskError> {
3375 if let Some(err) = proto::json::Error::parse(&res) {
3376 match err.typ.as_str() {
3377 "AccessDeniedFault" => {
3378 return RusotoError::Service(CreateReplicationTaskError::AccessDeniedFault(
3379 err.msg,
3380 ))
3381 }
3382 "InvalidResourceStateFault" => {
3383 return RusotoError::Service(
3384 CreateReplicationTaskError::InvalidResourceStateFault(err.msg),
3385 )
3386 }
3387 "KMSKeyNotAccessibleFault" => {
3388 return RusotoError::Service(
3389 CreateReplicationTaskError::KMSKeyNotAccessibleFault(err.msg),
3390 )
3391 }
3392 "ResourceAlreadyExistsFault" => {
3393 return RusotoError::Service(
3394 CreateReplicationTaskError::ResourceAlreadyExistsFault(err.msg),
3395 )
3396 }
3397 "ResourceNotFoundFault" => {
3398 return RusotoError::Service(CreateReplicationTaskError::ResourceNotFoundFault(
3399 err.msg,
3400 ))
3401 }
3402 "ResourceQuotaExceededFault" => {
3403 return RusotoError::Service(
3404 CreateReplicationTaskError::ResourceQuotaExceededFault(err.msg),
3405 )
3406 }
3407 "ValidationException" => return RusotoError::Validation(err.msg),
3408 _ => {}
3409 }
3410 }
3411 RusotoError::Unknown(res)
3412 }
3413}
3414impl fmt::Display for CreateReplicationTaskError {
3415 #[allow(unused_variables)]
3416 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3417 match *self {
3418 CreateReplicationTaskError::AccessDeniedFault(ref cause) => write!(f, "{}", cause),
3419 CreateReplicationTaskError::InvalidResourceStateFault(ref cause) => {
3420 write!(f, "{}", cause)
3421 }
3422 CreateReplicationTaskError::KMSKeyNotAccessibleFault(ref cause) => {
3423 write!(f, "{}", cause)
3424 }
3425 CreateReplicationTaskError::ResourceAlreadyExistsFault(ref cause) => {
3426 write!(f, "{}", cause)
3427 }
3428 CreateReplicationTaskError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3429 CreateReplicationTaskError::ResourceQuotaExceededFault(ref cause) => {
3430 write!(f, "{}", cause)
3431 }
3432 }
3433 }
3434}
3435impl Error for CreateReplicationTaskError {}
3436#[derive(Debug, PartialEq)]
3438pub enum DeleteCertificateError {
3439 InvalidResourceStateFault(String),
3441 ResourceNotFoundFault(String),
3443}
3444
3445impl DeleteCertificateError {
3446 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteCertificateError> {
3447 if let Some(err) = proto::json::Error::parse(&res) {
3448 match err.typ.as_str() {
3449 "InvalidResourceStateFault" => {
3450 return RusotoError::Service(DeleteCertificateError::InvalidResourceStateFault(
3451 err.msg,
3452 ))
3453 }
3454 "ResourceNotFoundFault" => {
3455 return RusotoError::Service(DeleteCertificateError::ResourceNotFoundFault(
3456 err.msg,
3457 ))
3458 }
3459 "ValidationException" => return RusotoError::Validation(err.msg),
3460 _ => {}
3461 }
3462 }
3463 RusotoError::Unknown(res)
3464 }
3465}
3466impl fmt::Display for DeleteCertificateError {
3467 #[allow(unused_variables)]
3468 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3469 match *self {
3470 DeleteCertificateError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
3471 DeleteCertificateError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3472 }
3473 }
3474}
3475impl Error for DeleteCertificateError {}
3476#[derive(Debug, PartialEq)]
3478pub enum DeleteConnectionError {
3479 AccessDeniedFault(String),
3481 InvalidResourceStateFault(String),
3483 ResourceNotFoundFault(String),
3485}
3486
3487impl DeleteConnectionError {
3488 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteConnectionError> {
3489 if let Some(err) = proto::json::Error::parse(&res) {
3490 match err.typ.as_str() {
3491 "AccessDeniedFault" => {
3492 return RusotoError::Service(DeleteConnectionError::AccessDeniedFault(err.msg))
3493 }
3494 "InvalidResourceStateFault" => {
3495 return RusotoError::Service(DeleteConnectionError::InvalidResourceStateFault(
3496 err.msg,
3497 ))
3498 }
3499 "ResourceNotFoundFault" => {
3500 return RusotoError::Service(DeleteConnectionError::ResourceNotFoundFault(
3501 err.msg,
3502 ))
3503 }
3504 "ValidationException" => return RusotoError::Validation(err.msg),
3505 _ => {}
3506 }
3507 }
3508 RusotoError::Unknown(res)
3509 }
3510}
3511impl fmt::Display for DeleteConnectionError {
3512 #[allow(unused_variables)]
3513 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3514 match *self {
3515 DeleteConnectionError::AccessDeniedFault(ref cause) => write!(f, "{}", cause),
3516 DeleteConnectionError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
3517 DeleteConnectionError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3518 }
3519 }
3520}
3521impl Error for DeleteConnectionError {}
3522#[derive(Debug, PartialEq)]
3524pub enum DeleteEndpointError {
3525 InvalidResourceStateFault(String),
3527 ResourceNotFoundFault(String),
3529}
3530
3531impl DeleteEndpointError {
3532 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteEndpointError> {
3533 if let Some(err) = proto::json::Error::parse(&res) {
3534 match err.typ.as_str() {
3535 "InvalidResourceStateFault" => {
3536 return RusotoError::Service(DeleteEndpointError::InvalidResourceStateFault(
3537 err.msg,
3538 ))
3539 }
3540 "ResourceNotFoundFault" => {
3541 return RusotoError::Service(DeleteEndpointError::ResourceNotFoundFault(
3542 err.msg,
3543 ))
3544 }
3545 "ValidationException" => return RusotoError::Validation(err.msg),
3546 _ => {}
3547 }
3548 }
3549 RusotoError::Unknown(res)
3550 }
3551}
3552impl fmt::Display for DeleteEndpointError {
3553 #[allow(unused_variables)]
3554 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3555 match *self {
3556 DeleteEndpointError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
3557 DeleteEndpointError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3558 }
3559 }
3560}
3561impl Error for DeleteEndpointError {}
3562#[derive(Debug, PartialEq)]
3564pub enum DeleteEventSubscriptionError {
3565 InvalidResourceStateFault(String),
3567 ResourceNotFoundFault(String),
3569}
3570
3571impl DeleteEventSubscriptionError {
3572 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteEventSubscriptionError> {
3573 if let Some(err) = proto::json::Error::parse(&res) {
3574 match err.typ.as_str() {
3575 "InvalidResourceStateFault" => {
3576 return RusotoError::Service(
3577 DeleteEventSubscriptionError::InvalidResourceStateFault(err.msg),
3578 )
3579 }
3580 "ResourceNotFoundFault" => {
3581 return RusotoError::Service(
3582 DeleteEventSubscriptionError::ResourceNotFoundFault(err.msg),
3583 )
3584 }
3585 "ValidationException" => return RusotoError::Validation(err.msg),
3586 _ => {}
3587 }
3588 }
3589 RusotoError::Unknown(res)
3590 }
3591}
3592impl fmt::Display for DeleteEventSubscriptionError {
3593 #[allow(unused_variables)]
3594 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3595 match *self {
3596 DeleteEventSubscriptionError::InvalidResourceStateFault(ref cause) => {
3597 write!(f, "{}", cause)
3598 }
3599 DeleteEventSubscriptionError::ResourceNotFoundFault(ref cause) => {
3600 write!(f, "{}", cause)
3601 }
3602 }
3603 }
3604}
3605impl Error for DeleteEventSubscriptionError {}
3606#[derive(Debug, PartialEq)]
3608pub enum DeleteReplicationInstanceError {
3609 InvalidResourceStateFault(String),
3611 ResourceNotFoundFault(String),
3613}
3614
3615impl DeleteReplicationInstanceError {
3616 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteReplicationInstanceError> {
3617 if let Some(err) = proto::json::Error::parse(&res) {
3618 match err.typ.as_str() {
3619 "InvalidResourceStateFault" => {
3620 return RusotoError::Service(
3621 DeleteReplicationInstanceError::InvalidResourceStateFault(err.msg),
3622 )
3623 }
3624 "ResourceNotFoundFault" => {
3625 return RusotoError::Service(
3626 DeleteReplicationInstanceError::ResourceNotFoundFault(err.msg),
3627 )
3628 }
3629 "ValidationException" => return RusotoError::Validation(err.msg),
3630 _ => {}
3631 }
3632 }
3633 RusotoError::Unknown(res)
3634 }
3635}
3636impl fmt::Display for DeleteReplicationInstanceError {
3637 #[allow(unused_variables)]
3638 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3639 match *self {
3640 DeleteReplicationInstanceError::InvalidResourceStateFault(ref cause) => {
3641 write!(f, "{}", cause)
3642 }
3643 DeleteReplicationInstanceError::ResourceNotFoundFault(ref cause) => {
3644 write!(f, "{}", cause)
3645 }
3646 }
3647 }
3648}
3649impl Error for DeleteReplicationInstanceError {}
3650#[derive(Debug, PartialEq)]
3652pub enum DeleteReplicationSubnetGroupError {
3653 InvalidResourceStateFault(String),
3655 ResourceNotFoundFault(String),
3657}
3658
3659impl DeleteReplicationSubnetGroupError {
3660 pub fn from_response(
3661 res: BufferedHttpResponse,
3662 ) -> RusotoError<DeleteReplicationSubnetGroupError> {
3663 if let Some(err) = proto::json::Error::parse(&res) {
3664 match err.typ.as_str() {
3665 "InvalidResourceStateFault" => {
3666 return RusotoError::Service(
3667 DeleteReplicationSubnetGroupError::InvalidResourceStateFault(err.msg),
3668 )
3669 }
3670 "ResourceNotFoundFault" => {
3671 return RusotoError::Service(
3672 DeleteReplicationSubnetGroupError::ResourceNotFoundFault(err.msg),
3673 )
3674 }
3675 "ValidationException" => return RusotoError::Validation(err.msg),
3676 _ => {}
3677 }
3678 }
3679 RusotoError::Unknown(res)
3680 }
3681}
3682impl fmt::Display for DeleteReplicationSubnetGroupError {
3683 #[allow(unused_variables)]
3684 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3685 match *self {
3686 DeleteReplicationSubnetGroupError::InvalidResourceStateFault(ref cause) => {
3687 write!(f, "{}", cause)
3688 }
3689 DeleteReplicationSubnetGroupError::ResourceNotFoundFault(ref cause) => {
3690 write!(f, "{}", cause)
3691 }
3692 }
3693 }
3694}
3695impl Error for DeleteReplicationSubnetGroupError {}
3696#[derive(Debug, PartialEq)]
3698pub enum DeleteReplicationTaskError {
3699 InvalidResourceStateFault(String),
3701 ResourceNotFoundFault(String),
3703}
3704
3705impl DeleteReplicationTaskError {
3706 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteReplicationTaskError> {
3707 if let Some(err) = proto::json::Error::parse(&res) {
3708 match err.typ.as_str() {
3709 "InvalidResourceStateFault" => {
3710 return RusotoError::Service(
3711 DeleteReplicationTaskError::InvalidResourceStateFault(err.msg),
3712 )
3713 }
3714 "ResourceNotFoundFault" => {
3715 return RusotoError::Service(DeleteReplicationTaskError::ResourceNotFoundFault(
3716 err.msg,
3717 ))
3718 }
3719 "ValidationException" => return RusotoError::Validation(err.msg),
3720 _ => {}
3721 }
3722 }
3723 RusotoError::Unknown(res)
3724 }
3725}
3726impl fmt::Display for DeleteReplicationTaskError {
3727 #[allow(unused_variables)]
3728 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3729 match *self {
3730 DeleteReplicationTaskError::InvalidResourceStateFault(ref cause) => {
3731 write!(f, "{}", cause)
3732 }
3733 DeleteReplicationTaskError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3734 }
3735 }
3736}
3737impl Error for DeleteReplicationTaskError {}
3738#[derive(Debug, PartialEq)]
3740pub enum DescribeAccountAttributesError {}
3741
3742impl DescribeAccountAttributesError {
3743 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeAccountAttributesError> {
3744 if let Some(err) = proto::json::Error::parse(&res) {
3745 match err.typ.as_str() {
3746 "ValidationException" => return RusotoError::Validation(err.msg),
3747 _ => {}
3748 }
3749 }
3750 RusotoError::Unknown(res)
3751 }
3752}
3753impl fmt::Display for DescribeAccountAttributesError {
3754 #[allow(unused_variables)]
3755 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3756 match *self {}
3757 }
3758}
3759impl Error for DescribeAccountAttributesError {}
3760#[derive(Debug, PartialEq)]
3762pub enum DescribeCertificatesError {
3763 ResourceNotFoundFault(String),
3765}
3766
3767impl DescribeCertificatesError {
3768 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeCertificatesError> {
3769 if let Some(err) = proto::json::Error::parse(&res) {
3770 match err.typ.as_str() {
3771 "ResourceNotFoundFault" => {
3772 return RusotoError::Service(DescribeCertificatesError::ResourceNotFoundFault(
3773 err.msg,
3774 ))
3775 }
3776 "ValidationException" => return RusotoError::Validation(err.msg),
3777 _ => {}
3778 }
3779 }
3780 RusotoError::Unknown(res)
3781 }
3782}
3783impl fmt::Display for DescribeCertificatesError {
3784 #[allow(unused_variables)]
3785 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3786 match *self {
3787 DescribeCertificatesError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3788 }
3789 }
3790}
3791impl Error for DescribeCertificatesError {}
3792#[derive(Debug, PartialEq)]
3794pub enum DescribeConnectionsError {
3795 ResourceNotFoundFault(String),
3797}
3798
3799impl DescribeConnectionsError {
3800 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeConnectionsError> {
3801 if let Some(err) = proto::json::Error::parse(&res) {
3802 match err.typ.as_str() {
3803 "ResourceNotFoundFault" => {
3804 return RusotoError::Service(DescribeConnectionsError::ResourceNotFoundFault(
3805 err.msg,
3806 ))
3807 }
3808 "ValidationException" => return RusotoError::Validation(err.msg),
3809 _ => {}
3810 }
3811 }
3812 RusotoError::Unknown(res)
3813 }
3814}
3815impl fmt::Display for DescribeConnectionsError {
3816 #[allow(unused_variables)]
3817 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3818 match *self {
3819 DescribeConnectionsError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3820 }
3821 }
3822}
3823impl Error for DescribeConnectionsError {}
3824#[derive(Debug, PartialEq)]
3826pub enum DescribeEndpointTypesError {}
3827
3828impl DescribeEndpointTypesError {
3829 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeEndpointTypesError> {
3830 if let Some(err) = proto::json::Error::parse(&res) {
3831 match err.typ.as_str() {
3832 "ValidationException" => return RusotoError::Validation(err.msg),
3833 _ => {}
3834 }
3835 }
3836 RusotoError::Unknown(res)
3837 }
3838}
3839impl fmt::Display for DescribeEndpointTypesError {
3840 #[allow(unused_variables)]
3841 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3842 match *self {}
3843 }
3844}
3845impl Error for DescribeEndpointTypesError {}
3846#[derive(Debug, PartialEq)]
3848pub enum DescribeEndpointsError {
3849 ResourceNotFoundFault(String),
3851}
3852
3853impl DescribeEndpointsError {
3854 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeEndpointsError> {
3855 if let Some(err) = proto::json::Error::parse(&res) {
3856 match err.typ.as_str() {
3857 "ResourceNotFoundFault" => {
3858 return RusotoError::Service(DescribeEndpointsError::ResourceNotFoundFault(
3859 err.msg,
3860 ))
3861 }
3862 "ValidationException" => return RusotoError::Validation(err.msg),
3863 _ => {}
3864 }
3865 }
3866 RusotoError::Unknown(res)
3867 }
3868}
3869impl fmt::Display for DescribeEndpointsError {
3870 #[allow(unused_variables)]
3871 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3872 match *self {
3873 DescribeEndpointsError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
3874 }
3875 }
3876}
3877impl Error for DescribeEndpointsError {}
3878#[derive(Debug, PartialEq)]
3880pub enum DescribeEventCategoriesError {}
3881
3882impl DescribeEventCategoriesError {
3883 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeEventCategoriesError> {
3884 if let Some(err) = proto::json::Error::parse(&res) {
3885 match err.typ.as_str() {
3886 "ValidationException" => return RusotoError::Validation(err.msg),
3887 _ => {}
3888 }
3889 }
3890 RusotoError::Unknown(res)
3891 }
3892}
3893impl fmt::Display for DescribeEventCategoriesError {
3894 #[allow(unused_variables)]
3895 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3896 match *self {}
3897 }
3898}
3899impl Error for DescribeEventCategoriesError {}
3900#[derive(Debug, PartialEq)]
3902pub enum DescribeEventSubscriptionsError {
3903 ResourceNotFoundFault(String),
3905}
3906
3907impl DescribeEventSubscriptionsError {
3908 pub fn from_response(
3909 res: BufferedHttpResponse,
3910 ) -> RusotoError<DescribeEventSubscriptionsError> {
3911 if let Some(err) = proto::json::Error::parse(&res) {
3912 match err.typ.as_str() {
3913 "ResourceNotFoundFault" => {
3914 return RusotoError::Service(
3915 DescribeEventSubscriptionsError::ResourceNotFoundFault(err.msg),
3916 )
3917 }
3918 "ValidationException" => return RusotoError::Validation(err.msg),
3919 _ => {}
3920 }
3921 }
3922 RusotoError::Unknown(res)
3923 }
3924}
3925impl fmt::Display for DescribeEventSubscriptionsError {
3926 #[allow(unused_variables)]
3927 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3928 match *self {
3929 DescribeEventSubscriptionsError::ResourceNotFoundFault(ref cause) => {
3930 write!(f, "{}", cause)
3931 }
3932 }
3933 }
3934}
3935impl Error for DescribeEventSubscriptionsError {}
3936#[derive(Debug, PartialEq)]
3938pub enum DescribeEventsError {}
3939
3940impl DescribeEventsError {
3941 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeEventsError> {
3942 if let Some(err) = proto::json::Error::parse(&res) {
3943 match err.typ.as_str() {
3944 "ValidationException" => return RusotoError::Validation(err.msg),
3945 _ => {}
3946 }
3947 }
3948 RusotoError::Unknown(res)
3949 }
3950}
3951impl fmt::Display for DescribeEventsError {
3952 #[allow(unused_variables)]
3953 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3954 match *self {}
3955 }
3956}
3957impl Error for DescribeEventsError {}
3958#[derive(Debug, PartialEq)]
3960pub enum DescribeOrderableReplicationInstancesError {}
3961
3962impl DescribeOrderableReplicationInstancesError {
3963 pub fn from_response(
3964 res: BufferedHttpResponse,
3965 ) -> RusotoError<DescribeOrderableReplicationInstancesError> {
3966 if let Some(err) = proto::json::Error::parse(&res) {
3967 match err.typ.as_str() {
3968 "ValidationException" => return RusotoError::Validation(err.msg),
3969 _ => {}
3970 }
3971 }
3972 RusotoError::Unknown(res)
3973 }
3974}
3975impl fmt::Display for DescribeOrderableReplicationInstancesError {
3976 #[allow(unused_variables)]
3977 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3978 match *self {}
3979 }
3980}
3981impl Error for DescribeOrderableReplicationInstancesError {}
3982#[derive(Debug, PartialEq)]
3984pub enum DescribePendingMaintenanceActionsError {
3985 ResourceNotFoundFault(String),
3987}
3988
3989impl DescribePendingMaintenanceActionsError {
3990 pub fn from_response(
3991 res: BufferedHttpResponse,
3992 ) -> RusotoError<DescribePendingMaintenanceActionsError> {
3993 if let Some(err) = proto::json::Error::parse(&res) {
3994 match err.typ.as_str() {
3995 "ResourceNotFoundFault" => {
3996 return RusotoError::Service(
3997 DescribePendingMaintenanceActionsError::ResourceNotFoundFault(err.msg),
3998 )
3999 }
4000 "ValidationException" => return RusotoError::Validation(err.msg),
4001 _ => {}
4002 }
4003 }
4004 RusotoError::Unknown(res)
4005 }
4006}
4007impl fmt::Display for DescribePendingMaintenanceActionsError {
4008 #[allow(unused_variables)]
4009 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4010 match *self {
4011 DescribePendingMaintenanceActionsError::ResourceNotFoundFault(ref cause) => {
4012 write!(f, "{}", cause)
4013 }
4014 }
4015 }
4016}
4017impl Error for DescribePendingMaintenanceActionsError {}
4018#[derive(Debug, PartialEq)]
4020pub enum DescribeRefreshSchemasStatusError {
4021 InvalidResourceStateFault(String),
4023 ResourceNotFoundFault(String),
4025}
4026
4027impl DescribeRefreshSchemasStatusError {
4028 pub fn from_response(
4029 res: BufferedHttpResponse,
4030 ) -> RusotoError<DescribeRefreshSchemasStatusError> {
4031 if let Some(err) = proto::json::Error::parse(&res) {
4032 match err.typ.as_str() {
4033 "InvalidResourceStateFault" => {
4034 return RusotoError::Service(
4035 DescribeRefreshSchemasStatusError::InvalidResourceStateFault(err.msg),
4036 )
4037 }
4038 "ResourceNotFoundFault" => {
4039 return RusotoError::Service(
4040 DescribeRefreshSchemasStatusError::ResourceNotFoundFault(err.msg),
4041 )
4042 }
4043 "ValidationException" => return RusotoError::Validation(err.msg),
4044 _ => {}
4045 }
4046 }
4047 RusotoError::Unknown(res)
4048 }
4049}
4050impl fmt::Display for DescribeRefreshSchemasStatusError {
4051 #[allow(unused_variables)]
4052 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4053 match *self {
4054 DescribeRefreshSchemasStatusError::InvalidResourceStateFault(ref cause) => {
4055 write!(f, "{}", cause)
4056 }
4057 DescribeRefreshSchemasStatusError::ResourceNotFoundFault(ref cause) => {
4058 write!(f, "{}", cause)
4059 }
4060 }
4061 }
4062}
4063impl Error for DescribeRefreshSchemasStatusError {}
4064#[derive(Debug, PartialEq)]
4066pub enum DescribeReplicationInstanceTaskLogsError {
4067 InvalidResourceStateFault(String),
4069 ResourceNotFoundFault(String),
4071}
4072
4073impl DescribeReplicationInstanceTaskLogsError {
4074 pub fn from_response(
4075 res: BufferedHttpResponse,
4076 ) -> RusotoError<DescribeReplicationInstanceTaskLogsError> {
4077 if let Some(err) = proto::json::Error::parse(&res) {
4078 match err.typ.as_str() {
4079 "InvalidResourceStateFault" => {
4080 return RusotoError::Service(
4081 DescribeReplicationInstanceTaskLogsError::InvalidResourceStateFault(
4082 err.msg,
4083 ),
4084 )
4085 }
4086 "ResourceNotFoundFault" => {
4087 return RusotoError::Service(
4088 DescribeReplicationInstanceTaskLogsError::ResourceNotFoundFault(err.msg),
4089 )
4090 }
4091 "ValidationException" => return RusotoError::Validation(err.msg),
4092 _ => {}
4093 }
4094 }
4095 RusotoError::Unknown(res)
4096 }
4097}
4098impl fmt::Display for DescribeReplicationInstanceTaskLogsError {
4099 #[allow(unused_variables)]
4100 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4101 match *self {
4102 DescribeReplicationInstanceTaskLogsError::InvalidResourceStateFault(ref cause) => {
4103 write!(f, "{}", cause)
4104 }
4105 DescribeReplicationInstanceTaskLogsError::ResourceNotFoundFault(ref cause) => {
4106 write!(f, "{}", cause)
4107 }
4108 }
4109 }
4110}
4111impl Error for DescribeReplicationInstanceTaskLogsError {}
4112#[derive(Debug, PartialEq)]
4114pub enum DescribeReplicationInstancesError {
4115 ResourceNotFoundFault(String),
4117}
4118
4119impl DescribeReplicationInstancesError {
4120 pub fn from_response(
4121 res: BufferedHttpResponse,
4122 ) -> RusotoError<DescribeReplicationInstancesError> {
4123 if let Some(err) = proto::json::Error::parse(&res) {
4124 match err.typ.as_str() {
4125 "ResourceNotFoundFault" => {
4126 return RusotoError::Service(
4127 DescribeReplicationInstancesError::ResourceNotFoundFault(err.msg),
4128 )
4129 }
4130 "ValidationException" => return RusotoError::Validation(err.msg),
4131 _ => {}
4132 }
4133 }
4134 RusotoError::Unknown(res)
4135 }
4136}
4137impl fmt::Display for DescribeReplicationInstancesError {
4138 #[allow(unused_variables)]
4139 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4140 match *self {
4141 DescribeReplicationInstancesError::ResourceNotFoundFault(ref cause) => {
4142 write!(f, "{}", cause)
4143 }
4144 }
4145 }
4146}
4147impl Error for DescribeReplicationInstancesError {}
4148#[derive(Debug, PartialEq)]
4150pub enum DescribeReplicationSubnetGroupsError {
4151 ResourceNotFoundFault(String),
4153}
4154
4155impl DescribeReplicationSubnetGroupsError {
4156 pub fn from_response(
4157 res: BufferedHttpResponse,
4158 ) -> RusotoError<DescribeReplicationSubnetGroupsError> {
4159 if let Some(err) = proto::json::Error::parse(&res) {
4160 match err.typ.as_str() {
4161 "ResourceNotFoundFault" => {
4162 return RusotoError::Service(
4163 DescribeReplicationSubnetGroupsError::ResourceNotFoundFault(err.msg),
4164 )
4165 }
4166 "ValidationException" => return RusotoError::Validation(err.msg),
4167 _ => {}
4168 }
4169 }
4170 RusotoError::Unknown(res)
4171 }
4172}
4173impl fmt::Display for DescribeReplicationSubnetGroupsError {
4174 #[allow(unused_variables)]
4175 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4176 match *self {
4177 DescribeReplicationSubnetGroupsError::ResourceNotFoundFault(ref cause) => {
4178 write!(f, "{}", cause)
4179 }
4180 }
4181 }
4182}
4183impl Error for DescribeReplicationSubnetGroupsError {}
4184#[derive(Debug, PartialEq)]
4186pub enum DescribeReplicationTaskAssessmentResultsError {
4187 ResourceNotFoundFault(String),
4189}
4190
4191impl DescribeReplicationTaskAssessmentResultsError {
4192 pub fn from_response(
4193 res: BufferedHttpResponse,
4194 ) -> RusotoError<DescribeReplicationTaskAssessmentResultsError> {
4195 if let Some(err) = proto::json::Error::parse(&res) {
4196 match err.typ.as_str() {
4197 "ResourceNotFoundFault" => {
4198 return RusotoError::Service(
4199 DescribeReplicationTaskAssessmentResultsError::ResourceNotFoundFault(
4200 err.msg,
4201 ),
4202 )
4203 }
4204 "ValidationException" => return RusotoError::Validation(err.msg),
4205 _ => {}
4206 }
4207 }
4208 RusotoError::Unknown(res)
4209 }
4210}
4211impl fmt::Display for DescribeReplicationTaskAssessmentResultsError {
4212 #[allow(unused_variables)]
4213 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4214 match *self {
4215 DescribeReplicationTaskAssessmentResultsError::ResourceNotFoundFault(ref cause) => {
4216 write!(f, "{}", cause)
4217 }
4218 }
4219 }
4220}
4221impl Error for DescribeReplicationTaskAssessmentResultsError {}
4222#[derive(Debug, PartialEq)]
4224pub enum DescribeReplicationTasksError {
4225 ResourceNotFoundFault(String),
4227}
4228
4229impl DescribeReplicationTasksError {
4230 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeReplicationTasksError> {
4231 if let Some(err) = proto::json::Error::parse(&res) {
4232 match err.typ.as_str() {
4233 "ResourceNotFoundFault" => {
4234 return RusotoError::Service(
4235 DescribeReplicationTasksError::ResourceNotFoundFault(err.msg),
4236 )
4237 }
4238 "ValidationException" => return RusotoError::Validation(err.msg),
4239 _ => {}
4240 }
4241 }
4242 RusotoError::Unknown(res)
4243 }
4244}
4245impl fmt::Display for DescribeReplicationTasksError {
4246 #[allow(unused_variables)]
4247 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4248 match *self {
4249 DescribeReplicationTasksError::ResourceNotFoundFault(ref cause) => {
4250 write!(f, "{}", cause)
4251 }
4252 }
4253 }
4254}
4255impl Error for DescribeReplicationTasksError {}
4256#[derive(Debug, PartialEq)]
4258pub enum DescribeSchemasError {
4259 InvalidResourceStateFault(String),
4261 ResourceNotFoundFault(String),
4263}
4264
4265impl DescribeSchemasError {
4266 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeSchemasError> {
4267 if let Some(err) = proto::json::Error::parse(&res) {
4268 match err.typ.as_str() {
4269 "InvalidResourceStateFault" => {
4270 return RusotoError::Service(DescribeSchemasError::InvalidResourceStateFault(
4271 err.msg,
4272 ))
4273 }
4274 "ResourceNotFoundFault" => {
4275 return RusotoError::Service(DescribeSchemasError::ResourceNotFoundFault(
4276 err.msg,
4277 ))
4278 }
4279 "ValidationException" => return RusotoError::Validation(err.msg),
4280 _ => {}
4281 }
4282 }
4283 RusotoError::Unknown(res)
4284 }
4285}
4286impl fmt::Display for DescribeSchemasError {
4287 #[allow(unused_variables)]
4288 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4289 match *self {
4290 DescribeSchemasError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
4291 DescribeSchemasError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
4292 }
4293 }
4294}
4295impl Error for DescribeSchemasError {}
4296#[derive(Debug, PartialEq)]
4298pub enum DescribeTableStatisticsError {
4299 InvalidResourceStateFault(String),
4301 ResourceNotFoundFault(String),
4303}
4304
4305impl DescribeTableStatisticsError {
4306 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeTableStatisticsError> {
4307 if let Some(err) = proto::json::Error::parse(&res) {
4308 match err.typ.as_str() {
4309 "InvalidResourceStateFault" => {
4310 return RusotoError::Service(
4311 DescribeTableStatisticsError::InvalidResourceStateFault(err.msg),
4312 )
4313 }
4314 "ResourceNotFoundFault" => {
4315 return RusotoError::Service(
4316 DescribeTableStatisticsError::ResourceNotFoundFault(err.msg),
4317 )
4318 }
4319 "ValidationException" => return RusotoError::Validation(err.msg),
4320 _ => {}
4321 }
4322 }
4323 RusotoError::Unknown(res)
4324 }
4325}
4326impl fmt::Display for DescribeTableStatisticsError {
4327 #[allow(unused_variables)]
4328 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4329 match *self {
4330 DescribeTableStatisticsError::InvalidResourceStateFault(ref cause) => {
4331 write!(f, "{}", cause)
4332 }
4333 DescribeTableStatisticsError::ResourceNotFoundFault(ref cause) => {
4334 write!(f, "{}", cause)
4335 }
4336 }
4337 }
4338}
4339impl Error for DescribeTableStatisticsError {}
4340#[derive(Debug, PartialEq)]
4342pub enum ImportCertificateError {
4343 InvalidCertificateFault(String),
4345 ResourceAlreadyExistsFault(String),
4347 ResourceQuotaExceededFault(String),
4349}
4350
4351impl ImportCertificateError {
4352 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ImportCertificateError> {
4353 if let Some(err) = proto::json::Error::parse(&res) {
4354 match err.typ.as_str() {
4355 "InvalidCertificateFault" => {
4356 return RusotoError::Service(ImportCertificateError::InvalidCertificateFault(
4357 err.msg,
4358 ))
4359 }
4360 "ResourceAlreadyExistsFault" => {
4361 return RusotoError::Service(
4362 ImportCertificateError::ResourceAlreadyExistsFault(err.msg),
4363 )
4364 }
4365 "ResourceQuotaExceededFault" => {
4366 return RusotoError::Service(
4367 ImportCertificateError::ResourceQuotaExceededFault(err.msg),
4368 )
4369 }
4370 "ValidationException" => return RusotoError::Validation(err.msg),
4371 _ => {}
4372 }
4373 }
4374 RusotoError::Unknown(res)
4375 }
4376}
4377impl fmt::Display for ImportCertificateError {
4378 #[allow(unused_variables)]
4379 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4380 match *self {
4381 ImportCertificateError::InvalidCertificateFault(ref cause) => write!(f, "{}", cause),
4382 ImportCertificateError::ResourceAlreadyExistsFault(ref cause) => write!(f, "{}", cause),
4383 ImportCertificateError::ResourceQuotaExceededFault(ref cause) => write!(f, "{}", cause),
4384 }
4385 }
4386}
4387impl Error for ImportCertificateError {}
4388#[derive(Debug, PartialEq)]
4390pub enum ListTagsForResourceError {
4391 ResourceNotFoundFault(String),
4393}
4394
4395impl ListTagsForResourceError {
4396 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListTagsForResourceError> {
4397 if let Some(err) = proto::json::Error::parse(&res) {
4398 match err.typ.as_str() {
4399 "ResourceNotFoundFault" => {
4400 return RusotoError::Service(ListTagsForResourceError::ResourceNotFoundFault(
4401 err.msg,
4402 ))
4403 }
4404 "ValidationException" => return RusotoError::Validation(err.msg),
4405 _ => {}
4406 }
4407 }
4408 RusotoError::Unknown(res)
4409 }
4410}
4411impl fmt::Display for ListTagsForResourceError {
4412 #[allow(unused_variables)]
4413 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4414 match *self {
4415 ListTagsForResourceError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
4416 }
4417 }
4418}
4419impl Error for ListTagsForResourceError {}
4420#[derive(Debug, PartialEq)]
4422pub enum ModifyEndpointError {
4423 AccessDeniedFault(String),
4425 InvalidResourceStateFault(String),
4427 KMSKeyNotAccessibleFault(String),
4429 ResourceAlreadyExistsFault(String),
4431 ResourceNotFoundFault(String),
4433}
4434
4435impl ModifyEndpointError {
4436 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ModifyEndpointError> {
4437 if let Some(err) = proto::json::Error::parse(&res) {
4438 match err.typ.as_str() {
4439 "AccessDeniedFault" => {
4440 return RusotoError::Service(ModifyEndpointError::AccessDeniedFault(err.msg))
4441 }
4442 "InvalidResourceStateFault" => {
4443 return RusotoError::Service(ModifyEndpointError::InvalidResourceStateFault(
4444 err.msg,
4445 ))
4446 }
4447 "KMSKeyNotAccessibleFault" => {
4448 return RusotoError::Service(ModifyEndpointError::KMSKeyNotAccessibleFault(
4449 err.msg,
4450 ))
4451 }
4452 "ResourceAlreadyExistsFault" => {
4453 return RusotoError::Service(ModifyEndpointError::ResourceAlreadyExistsFault(
4454 err.msg,
4455 ))
4456 }
4457 "ResourceNotFoundFault" => {
4458 return RusotoError::Service(ModifyEndpointError::ResourceNotFoundFault(
4459 err.msg,
4460 ))
4461 }
4462 "ValidationException" => return RusotoError::Validation(err.msg),
4463 _ => {}
4464 }
4465 }
4466 RusotoError::Unknown(res)
4467 }
4468}
4469impl fmt::Display for ModifyEndpointError {
4470 #[allow(unused_variables)]
4471 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4472 match *self {
4473 ModifyEndpointError::AccessDeniedFault(ref cause) => write!(f, "{}", cause),
4474 ModifyEndpointError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
4475 ModifyEndpointError::KMSKeyNotAccessibleFault(ref cause) => write!(f, "{}", cause),
4476 ModifyEndpointError::ResourceAlreadyExistsFault(ref cause) => write!(f, "{}", cause),
4477 ModifyEndpointError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
4478 }
4479 }
4480}
4481impl Error for ModifyEndpointError {}
4482#[derive(Debug, PartialEq)]
4484pub enum ModifyEventSubscriptionError {
4485 KMSAccessDeniedFault(String),
4487 KMSDisabledFault(String),
4489 KMSInvalidStateFault(String),
4491 KMSNotFoundFault(String),
4493 KMSThrottlingFault(String),
4495 ResourceNotFoundFault(String),
4497 ResourceQuotaExceededFault(String),
4499 SNSInvalidTopicFault(String),
4501 SNSNoAuthorizationFault(String),
4503}
4504
4505impl ModifyEventSubscriptionError {
4506 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ModifyEventSubscriptionError> {
4507 if let Some(err) = proto::json::Error::parse(&res) {
4508 match err.typ.as_str() {
4509 "KMSAccessDeniedFault" => {
4510 return RusotoError::Service(
4511 ModifyEventSubscriptionError::KMSAccessDeniedFault(err.msg),
4512 )
4513 }
4514 "KMSDisabledFault" => {
4515 return RusotoError::Service(ModifyEventSubscriptionError::KMSDisabledFault(
4516 err.msg,
4517 ))
4518 }
4519 "KMSInvalidStateFault" => {
4520 return RusotoError::Service(
4521 ModifyEventSubscriptionError::KMSInvalidStateFault(err.msg),
4522 )
4523 }
4524 "KMSNotFoundFault" => {
4525 return RusotoError::Service(ModifyEventSubscriptionError::KMSNotFoundFault(
4526 err.msg,
4527 ))
4528 }
4529 "KMSThrottlingFault" => {
4530 return RusotoError::Service(ModifyEventSubscriptionError::KMSThrottlingFault(
4531 err.msg,
4532 ))
4533 }
4534 "ResourceNotFoundFault" => {
4535 return RusotoError::Service(
4536 ModifyEventSubscriptionError::ResourceNotFoundFault(err.msg),
4537 )
4538 }
4539 "ResourceQuotaExceededFault" => {
4540 return RusotoError::Service(
4541 ModifyEventSubscriptionError::ResourceQuotaExceededFault(err.msg),
4542 )
4543 }
4544 "SNSInvalidTopicFault" => {
4545 return RusotoError::Service(
4546 ModifyEventSubscriptionError::SNSInvalidTopicFault(err.msg),
4547 )
4548 }
4549 "SNSNoAuthorizationFault" => {
4550 return RusotoError::Service(
4551 ModifyEventSubscriptionError::SNSNoAuthorizationFault(err.msg),
4552 )
4553 }
4554 "ValidationException" => return RusotoError::Validation(err.msg),
4555 _ => {}
4556 }
4557 }
4558 RusotoError::Unknown(res)
4559 }
4560}
4561impl fmt::Display for ModifyEventSubscriptionError {
4562 #[allow(unused_variables)]
4563 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4564 match *self {
4565 ModifyEventSubscriptionError::KMSAccessDeniedFault(ref cause) => write!(f, "{}", cause),
4566 ModifyEventSubscriptionError::KMSDisabledFault(ref cause) => write!(f, "{}", cause),
4567 ModifyEventSubscriptionError::KMSInvalidStateFault(ref cause) => write!(f, "{}", cause),
4568 ModifyEventSubscriptionError::KMSNotFoundFault(ref cause) => write!(f, "{}", cause),
4569 ModifyEventSubscriptionError::KMSThrottlingFault(ref cause) => write!(f, "{}", cause),
4570 ModifyEventSubscriptionError::ResourceNotFoundFault(ref cause) => {
4571 write!(f, "{}", cause)
4572 }
4573 ModifyEventSubscriptionError::ResourceQuotaExceededFault(ref cause) => {
4574 write!(f, "{}", cause)
4575 }
4576 ModifyEventSubscriptionError::SNSInvalidTopicFault(ref cause) => write!(f, "{}", cause),
4577 ModifyEventSubscriptionError::SNSNoAuthorizationFault(ref cause) => {
4578 write!(f, "{}", cause)
4579 }
4580 }
4581 }
4582}
4583impl Error for ModifyEventSubscriptionError {}
4584#[derive(Debug, PartialEq)]
4586pub enum ModifyReplicationInstanceError {
4587 AccessDeniedFault(String),
4589 InsufficientResourceCapacityFault(String),
4591 InvalidResourceStateFault(String),
4593 ResourceAlreadyExistsFault(String),
4595 ResourceNotFoundFault(String),
4597 StorageQuotaExceededFault(String),
4599 UpgradeDependencyFailureFault(String),
4601}
4602
4603impl ModifyReplicationInstanceError {
4604 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ModifyReplicationInstanceError> {
4605 if let Some(err) = proto::json::Error::parse(&res) {
4606 match err.typ.as_str() {
4607 "AccessDeniedFault" => {
4608 return RusotoError::Service(ModifyReplicationInstanceError::AccessDeniedFault(
4609 err.msg,
4610 ))
4611 }
4612 "InsufficientResourceCapacityFault" => {
4613 return RusotoError::Service(
4614 ModifyReplicationInstanceError::InsufficientResourceCapacityFault(err.msg),
4615 )
4616 }
4617 "InvalidResourceStateFault" => {
4618 return RusotoError::Service(
4619 ModifyReplicationInstanceError::InvalidResourceStateFault(err.msg),
4620 )
4621 }
4622 "ResourceAlreadyExistsFault" => {
4623 return RusotoError::Service(
4624 ModifyReplicationInstanceError::ResourceAlreadyExistsFault(err.msg),
4625 )
4626 }
4627 "ResourceNotFoundFault" => {
4628 return RusotoError::Service(
4629 ModifyReplicationInstanceError::ResourceNotFoundFault(err.msg),
4630 )
4631 }
4632 "StorageQuotaExceededFault" => {
4633 return RusotoError::Service(
4634 ModifyReplicationInstanceError::StorageQuotaExceededFault(err.msg),
4635 )
4636 }
4637 "UpgradeDependencyFailureFault" => {
4638 return RusotoError::Service(
4639 ModifyReplicationInstanceError::UpgradeDependencyFailureFault(err.msg),
4640 )
4641 }
4642 "ValidationException" => return RusotoError::Validation(err.msg),
4643 _ => {}
4644 }
4645 }
4646 RusotoError::Unknown(res)
4647 }
4648}
4649impl fmt::Display for ModifyReplicationInstanceError {
4650 #[allow(unused_variables)]
4651 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4652 match *self {
4653 ModifyReplicationInstanceError::AccessDeniedFault(ref cause) => write!(f, "{}", cause),
4654 ModifyReplicationInstanceError::InsufficientResourceCapacityFault(ref cause) => {
4655 write!(f, "{}", cause)
4656 }
4657 ModifyReplicationInstanceError::InvalidResourceStateFault(ref cause) => {
4658 write!(f, "{}", cause)
4659 }
4660 ModifyReplicationInstanceError::ResourceAlreadyExistsFault(ref cause) => {
4661 write!(f, "{}", cause)
4662 }
4663 ModifyReplicationInstanceError::ResourceNotFoundFault(ref cause) => {
4664 write!(f, "{}", cause)
4665 }
4666 ModifyReplicationInstanceError::StorageQuotaExceededFault(ref cause) => {
4667 write!(f, "{}", cause)
4668 }
4669 ModifyReplicationInstanceError::UpgradeDependencyFailureFault(ref cause) => {
4670 write!(f, "{}", cause)
4671 }
4672 }
4673 }
4674}
4675impl Error for ModifyReplicationInstanceError {}
4676#[derive(Debug, PartialEq)]
4678pub enum ModifyReplicationSubnetGroupError {
4679 AccessDeniedFault(String),
4681 InvalidSubnet(String),
4683 ReplicationSubnetGroupDoesNotCoverEnoughAZs(String),
4685 ResourceNotFoundFault(String),
4687 ResourceQuotaExceededFault(String),
4689 SubnetAlreadyInUse(String),
4691}
4692
4693impl ModifyReplicationSubnetGroupError {
4694 pub fn from_response(
4695 res: BufferedHttpResponse,
4696 ) -> RusotoError<ModifyReplicationSubnetGroupError> {
4697 if let Some(err) = proto::json::Error::parse(&res) {
4698 match err.typ.as_str() {
4699 "AccessDeniedFault" => {
4700 return RusotoError::Service(
4701 ModifyReplicationSubnetGroupError::AccessDeniedFault(err.msg),
4702 )
4703 }
4704 "InvalidSubnet" => {
4705 return RusotoError::Service(ModifyReplicationSubnetGroupError::InvalidSubnet(
4706 err.msg,
4707 ))
4708 }
4709 "ReplicationSubnetGroupDoesNotCoverEnoughAZs" => return RusotoError::Service(
4710 ModifyReplicationSubnetGroupError::ReplicationSubnetGroupDoesNotCoverEnoughAZs(
4711 err.msg,
4712 ),
4713 ),
4714 "ResourceNotFoundFault" => {
4715 return RusotoError::Service(
4716 ModifyReplicationSubnetGroupError::ResourceNotFoundFault(err.msg),
4717 )
4718 }
4719 "ResourceQuotaExceededFault" => {
4720 return RusotoError::Service(
4721 ModifyReplicationSubnetGroupError::ResourceQuotaExceededFault(err.msg),
4722 )
4723 }
4724 "SubnetAlreadyInUse" => {
4725 return RusotoError::Service(
4726 ModifyReplicationSubnetGroupError::SubnetAlreadyInUse(err.msg),
4727 )
4728 }
4729 "ValidationException" => return RusotoError::Validation(err.msg),
4730 _ => {}
4731 }
4732 }
4733 RusotoError::Unknown(res)
4734 }
4735}
4736impl fmt::Display for ModifyReplicationSubnetGroupError {
4737 #[allow(unused_variables)]
4738 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4739 match *self {
4740 ModifyReplicationSubnetGroupError::AccessDeniedFault(ref cause) => {
4741 write!(f, "{}", cause)
4742 }
4743 ModifyReplicationSubnetGroupError::InvalidSubnet(ref cause) => write!(f, "{}", cause),
4744 ModifyReplicationSubnetGroupError::ReplicationSubnetGroupDoesNotCoverEnoughAZs(
4745 ref cause,
4746 ) => write!(f, "{}", cause),
4747 ModifyReplicationSubnetGroupError::ResourceNotFoundFault(ref cause) => {
4748 write!(f, "{}", cause)
4749 }
4750 ModifyReplicationSubnetGroupError::ResourceQuotaExceededFault(ref cause) => {
4751 write!(f, "{}", cause)
4752 }
4753 ModifyReplicationSubnetGroupError::SubnetAlreadyInUse(ref cause) => {
4754 write!(f, "{}", cause)
4755 }
4756 }
4757 }
4758}
4759impl Error for ModifyReplicationSubnetGroupError {}
4760#[derive(Debug, PartialEq)]
4762pub enum ModifyReplicationTaskError {
4763 InvalidResourceStateFault(String),
4765 KMSKeyNotAccessibleFault(String),
4767 ResourceAlreadyExistsFault(String),
4769 ResourceNotFoundFault(String),
4771}
4772
4773impl ModifyReplicationTaskError {
4774 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ModifyReplicationTaskError> {
4775 if let Some(err) = proto::json::Error::parse(&res) {
4776 match err.typ.as_str() {
4777 "InvalidResourceStateFault" => {
4778 return RusotoError::Service(
4779 ModifyReplicationTaskError::InvalidResourceStateFault(err.msg),
4780 )
4781 }
4782 "KMSKeyNotAccessibleFault" => {
4783 return RusotoError::Service(
4784 ModifyReplicationTaskError::KMSKeyNotAccessibleFault(err.msg),
4785 )
4786 }
4787 "ResourceAlreadyExistsFault" => {
4788 return RusotoError::Service(
4789 ModifyReplicationTaskError::ResourceAlreadyExistsFault(err.msg),
4790 )
4791 }
4792 "ResourceNotFoundFault" => {
4793 return RusotoError::Service(ModifyReplicationTaskError::ResourceNotFoundFault(
4794 err.msg,
4795 ))
4796 }
4797 "ValidationException" => return RusotoError::Validation(err.msg),
4798 _ => {}
4799 }
4800 }
4801 RusotoError::Unknown(res)
4802 }
4803}
4804impl fmt::Display for ModifyReplicationTaskError {
4805 #[allow(unused_variables)]
4806 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4807 match *self {
4808 ModifyReplicationTaskError::InvalidResourceStateFault(ref cause) => {
4809 write!(f, "{}", cause)
4810 }
4811 ModifyReplicationTaskError::KMSKeyNotAccessibleFault(ref cause) => {
4812 write!(f, "{}", cause)
4813 }
4814 ModifyReplicationTaskError::ResourceAlreadyExistsFault(ref cause) => {
4815 write!(f, "{}", cause)
4816 }
4817 ModifyReplicationTaskError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
4818 }
4819 }
4820}
4821impl Error for ModifyReplicationTaskError {}
4822#[derive(Debug, PartialEq)]
4824pub enum RebootReplicationInstanceError {
4825 InvalidResourceStateFault(String),
4827 ResourceNotFoundFault(String),
4829}
4830
4831impl RebootReplicationInstanceError {
4832 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<RebootReplicationInstanceError> {
4833 if let Some(err) = proto::json::Error::parse(&res) {
4834 match err.typ.as_str() {
4835 "InvalidResourceStateFault" => {
4836 return RusotoError::Service(
4837 RebootReplicationInstanceError::InvalidResourceStateFault(err.msg),
4838 )
4839 }
4840 "ResourceNotFoundFault" => {
4841 return RusotoError::Service(
4842 RebootReplicationInstanceError::ResourceNotFoundFault(err.msg),
4843 )
4844 }
4845 "ValidationException" => return RusotoError::Validation(err.msg),
4846 _ => {}
4847 }
4848 }
4849 RusotoError::Unknown(res)
4850 }
4851}
4852impl fmt::Display for RebootReplicationInstanceError {
4853 #[allow(unused_variables)]
4854 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4855 match *self {
4856 RebootReplicationInstanceError::InvalidResourceStateFault(ref cause) => {
4857 write!(f, "{}", cause)
4858 }
4859 RebootReplicationInstanceError::ResourceNotFoundFault(ref cause) => {
4860 write!(f, "{}", cause)
4861 }
4862 }
4863 }
4864}
4865impl Error for RebootReplicationInstanceError {}
4866#[derive(Debug, PartialEq)]
4868pub enum RefreshSchemasError {
4869 InvalidResourceStateFault(String),
4871 KMSKeyNotAccessibleFault(String),
4873 ResourceNotFoundFault(String),
4875 ResourceQuotaExceededFault(String),
4877}
4878
4879impl RefreshSchemasError {
4880 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<RefreshSchemasError> {
4881 if let Some(err) = proto::json::Error::parse(&res) {
4882 match err.typ.as_str() {
4883 "InvalidResourceStateFault" => {
4884 return RusotoError::Service(RefreshSchemasError::InvalidResourceStateFault(
4885 err.msg,
4886 ))
4887 }
4888 "KMSKeyNotAccessibleFault" => {
4889 return RusotoError::Service(RefreshSchemasError::KMSKeyNotAccessibleFault(
4890 err.msg,
4891 ))
4892 }
4893 "ResourceNotFoundFault" => {
4894 return RusotoError::Service(RefreshSchemasError::ResourceNotFoundFault(
4895 err.msg,
4896 ))
4897 }
4898 "ResourceQuotaExceededFault" => {
4899 return RusotoError::Service(RefreshSchemasError::ResourceQuotaExceededFault(
4900 err.msg,
4901 ))
4902 }
4903 "ValidationException" => return RusotoError::Validation(err.msg),
4904 _ => {}
4905 }
4906 }
4907 RusotoError::Unknown(res)
4908 }
4909}
4910impl fmt::Display for RefreshSchemasError {
4911 #[allow(unused_variables)]
4912 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4913 match *self {
4914 RefreshSchemasError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
4915 RefreshSchemasError::KMSKeyNotAccessibleFault(ref cause) => write!(f, "{}", cause),
4916 RefreshSchemasError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
4917 RefreshSchemasError::ResourceQuotaExceededFault(ref cause) => write!(f, "{}", cause),
4918 }
4919 }
4920}
4921impl Error for RefreshSchemasError {}
4922#[derive(Debug, PartialEq)]
4924pub enum ReloadTablesError {
4925 InvalidResourceStateFault(String),
4927 ResourceNotFoundFault(String),
4929}
4930
4931impl ReloadTablesError {
4932 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ReloadTablesError> {
4933 if let Some(err) = proto::json::Error::parse(&res) {
4934 match err.typ.as_str() {
4935 "InvalidResourceStateFault" => {
4936 return RusotoError::Service(ReloadTablesError::InvalidResourceStateFault(
4937 err.msg,
4938 ))
4939 }
4940 "ResourceNotFoundFault" => {
4941 return RusotoError::Service(ReloadTablesError::ResourceNotFoundFault(err.msg))
4942 }
4943 "ValidationException" => return RusotoError::Validation(err.msg),
4944 _ => {}
4945 }
4946 }
4947 RusotoError::Unknown(res)
4948 }
4949}
4950impl fmt::Display for ReloadTablesError {
4951 #[allow(unused_variables)]
4952 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4953 match *self {
4954 ReloadTablesError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
4955 ReloadTablesError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
4956 }
4957 }
4958}
4959impl Error for ReloadTablesError {}
4960#[derive(Debug, PartialEq)]
4962pub enum RemoveTagsFromResourceError {
4963 ResourceNotFoundFault(String),
4965}
4966
4967impl RemoveTagsFromResourceError {
4968 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<RemoveTagsFromResourceError> {
4969 if let Some(err) = proto::json::Error::parse(&res) {
4970 match err.typ.as_str() {
4971 "ResourceNotFoundFault" => {
4972 return RusotoError::Service(
4973 RemoveTagsFromResourceError::ResourceNotFoundFault(err.msg),
4974 )
4975 }
4976 "ValidationException" => return RusotoError::Validation(err.msg),
4977 _ => {}
4978 }
4979 }
4980 RusotoError::Unknown(res)
4981 }
4982}
4983impl fmt::Display for RemoveTagsFromResourceError {
4984 #[allow(unused_variables)]
4985 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4986 match *self {
4987 RemoveTagsFromResourceError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
4988 }
4989 }
4990}
4991impl Error for RemoveTagsFromResourceError {}
4992#[derive(Debug, PartialEq)]
4994pub enum StartReplicationTaskError {
4995 AccessDeniedFault(String),
4997 InvalidResourceStateFault(String),
4999 ResourceNotFoundFault(String),
5001}
5002
5003impl StartReplicationTaskError {
5004 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<StartReplicationTaskError> {
5005 if let Some(err) = proto::json::Error::parse(&res) {
5006 match err.typ.as_str() {
5007 "AccessDeniedFault" => {
5008 return RusotoError::Service(StartReplicationTaskError::AccessDeniedFault(
5009 err.msg,
5010 ))
5011 }
5012 "InvalidResourceStateFault" => {
5013 return RusotoError::Service(
5014 StartReplicationTaskError::InvalidResourceStateFault(err.msg),
5015 )
5016 }
5017 "ResourceNotFoundFault" => {
5018 return RusotoError::Service(StartReplicationTaskError::ResourceNotFoundFault(
5019 err.msg,
5020 ))
5021 }
5022 "ValidationException" => return RusotoError::Validation(err.msg),
5023 _ => {}
5024 }
5025 }
5026 RusotoError::Unknown(res)
5027 }
5028}
5029impl fmt::Display for StartReplicationTaskError {
5030 #[allow(unused_variables)]
5031 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
5032 match *self {
5033 StartReplicationTaskError::AccessDeniedFault(ref cause) => write!(f, "{}", cause),
5034 StartReplicationTaskError::InvalidResourceStateFault(ref cause) => {
5035 write!(f, "{}", cause)
5036 }
5037 StartReplicationTaskError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
5038 }
5039 }
5040}
5041impl Error for StartReplicationTaskError {}
5042#[derive(Debug, PartialEq)]
5044pub enum StartReplicationTaskAssessmentError {
5045 InvalidResourceStateFault(String),
5047 ResourceNotFoundFault(String),
5049}
5050
5051impl StartReplicationTaskAssessmentError {
5052 pub fn from_response(
5053 res: BufferedHttpResponse,
5054 ) -> RusotoError<StartReplicationTaskAssessmentError> {
5055 if let Some(err) = proto::json::Error::parse(&res) {
5056 match err.typ.as_str() {
5057 "InvalidResourceStateFault" => {
5058 return RusotoError::Service(
5059 StartReplicationTaskAssessmentError::InvalidResourceStateFault(err.msg),
5060 )
5061 }
5062 "ResourceNotFoundFault" => {
5063 return RusotoError::Service(
5064 StartReplicationTaskAssessmentError::ResourceNotFoundFault(err.msg),
5065 )
5066 }
5067 "ValidationException" => return RusotoError::Validation(err.msg),
5068 _ => {}
5069 }
5070 }
5071 RusotoError::Unknown(res)
5072 }
5073}
5074impl fmt::Display for StartReplicationTaskAssessmentError {
5075 #[allow(unused_variables)]
5076 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
5077 match *self {
5078 StartReplicationTaskAssessmentError::InvalidResourceStateFault(ref cause) => {
5079 write!(f, "{}", cause)
5080 }
5081 StartReplicationTaskAssessmentError::ResourceNotFoundFault(ref cause) => {
5082 write!(f, "{}", cause)
5083 }
5084 }
5085 }
5086}
5087impl Error for StartReplicationTaskAssessmentError {}
5088#[derive(Debug, PartialEq)]
5090pub enum StopReplicationTaskError {
5091 InvalidResourceStateFault(String),
5093 ResourceNotFoundFault(String),
5095}
5096
5097impl StopReplicationTaskError {
5098 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<StopReplicationTaskError> {
5099 if let Some(err) = proto::json::Error::parse(&res) {
5100 match err.typ.as_str() {
5101 "InvalidResourceStateFault" => {
5102 return RusotoError::Service(
5103 StopReplicationTaskError::InvalidResourceStateFault(err.msg),
5104 )
5105 }
5106 "ResourceNotFoundFault" => {
5107 return RusotoError::Service(StopReplicationTaskError::ResourceNotFoundFault(
5108 err.msg,
5109 ))
5110 }
5111 "ValidationException" => return RusotoError::Validation(err.msg),
5112 _ => {}
5113 }
5114 }
5115 RusotoError::Unknown(res)
5116 }
5117}
5118impl fmt::Display for StopReplicationTaskError {
5119 #[allow(unused_variables)]
5120 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
5121 match *self {
5122 StopReplicationTaskError::InvalidResourceStateFault(ref cause) => {
5123 write!(f, "{}", cause)
5124 }
5125 StopReplicationTaskError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
5126 }
5127 }
5128}
5129impl Error for StopReplicationTaskError {}
5130#[derive(Debug, PartialEq)]
5132pub enum TestConnectionError {
5133 InvalidResourceStateFault(String),
5135 KMSKeyNotAccessibleFault(String),
5137 ResourceNotFoundFault(String),
5139 ResourceQuotaExceededFault(String),
5141}
5142
5143impl TestConnectionError {
5144 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<TestConnectionError> {
5145 if let Some(err) = proto::json::Error::parse(&res) {
5146 match err.typ.as_str() {
5147 "InvalidResourceStateFault" => {
5148 return RusotoError::Service(TestConnectionError::InvalidResourceStateFault(
5149 err.msg,
5150 ))
5151 }
5152 "KMSKeyNotAccessibleFault" => {
5153 return RusotoError::Service(TestConnectionError::KMSKeyNotAccessibleFault(
5154 err.msg,
5155 ))
5156 }
5157 "ResourceNotFoundFault" => {
5158 return RusotoError::Service(TestConnectionError::ResourceNotFoundFault(
5159 err.msg,
5160 ))
5161 }
5162 "ResourceQuotaExceededFault" => {
5163 return RusotoError::Service(TestConnectionError::ResourceQuotaExceededFault(
5164 err.msg,
5165 ))
5166 }
5167 "ValidationException" => return RusotoError::Validation(err.msg),
5168 _ => {}
5169 }
5170 }
5171 RusotoError::Unknown(res)
5172 }
5173}
5174impl fmt::Display for TestConnectionError {
5175 #[allow(unused_variables)]
5176 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
5177 match *self {
5178 TestConnectionError::InvalidResourceStateFault(ref cause) => write!(f, "{}", cause),
5179 TestConnectionError::KMSKeyNotAccessibleFault(ref cause) => write!(f, "{}", cause),
5180 TestConnectionError::ResourceNotFoundFault(ref cause) => write!(f, "{}", cause),
5181 TestConnectionError::ResourceQuotaExceededFault(ref cause) => write!(f, "{}", cause),
5182 }
5183 }
5184}
5185impl Error for TestConnectionError {}
5186#[async_trait]
5188pub trait DatabaseMigrationService {
5189 async fn add_tags_to_resource(
5191 &self,
5192 input: AddTagsToResourceMessage,
5193 ) -> Result<AddTagsToResourceResponse, RusotoError<AddTagsToResourceError>>;
5194
5195 async fn apply_pending_maintenance_action(
5197 &self,
5198 input: ApplyPendingMaintenanceActionMessage,
5199 ) -> Result<
5200 ApplyPendingMaintenanceActionResponse,
5201 RusotoError<ApplyPendingMaintenanceActionError>,
5202 >;
5203
5204 async fn create_endpoint(
5206 &self,
5207 input: CreateEndpointMessage,
5208 ) -> Result<CreateEndpointResponse, RusotoError<CreateEndpointError>>;
5209
5210 async fn create_event_subscription(
5212 &self,
5213 input: CreateEventSubscriptionMessage,
5214 ) -> Result<CreateEventSubscriptionResponse, RusotoError<CreateEventSubscriptionError>>;
5215
5216 async fn create_replication_instance(
5218 &self,
5219 input: CreateReplicationInstanceMessage,
5220 ) -> Result<CreateReplicationInstanceResponse, RusotoError<CreateReplicationInstanceError>>;
5221
5222 async fn create_replication_subnet_group(
5224 &self,
5225 input: CreateReplicationSubnetGroupMessage,
5226 ) -> Result<CreateReplicationSubnetGroupResponse, RusotoError<CreateReplicationSubnetGroupError>>;
5227
5228 async fn create_replication_task(
5230 &self,
5231 input: CreateReplicationTaskMessage,
5232 ) -> Result<CreateReplicationTaskResponse, RusotoError<CreateReplicationTaskError>>;
5233
5234 async fn delete_certificate(
5236 &self,
5237 input: DeleteCertificateMessage,
5238 ) -> Result<DeleteCertificateResponse, RusotoError<DeleteCertificateError>>;
5239
5240 async fn delete_connection(
5242 &self,
5243 input: DeleteConnectionMessage,
5244 ) -> Result<DeleteConnectionResponse, RusotoError<DeleteConnectionError>>;
5245
5246 async fn delete_endpoint(
5248 &self,
5249 input: DeleteEndpointMessage,
5250 ) -> Result<DeleteEndpointResponse, RusotoError<DeleteEndpointError>>;
5251
5252 async fn delete_event_subscription(
5254 &self,
5255 input: DeleteEventSubscriptionMessage,
5256 ) -> Result<DeleteEventSubscriptionResponse, RusotoError<DeleteEventSubscriptionError>>;
5257
5258 async fn delete_replication_instance(
5260 &self,
5261 input: DeleteReplicationInstanceMessage,
5262 ) -> Result<DeleteReplicationInstanceResponse, RusotoError<DeleteReplicationInstanceError>>;
5263
5264 async fn delete_replication_subnet_group(
5266 &self,
5267 input: DeleteReplicationSubnetGroupMessage,
5268 ) -> Result<DeleteReplicationSubnetGroupResponse, RusotoError<DeleteReplicationSubnetGroupError>>;
5269
5270 async fn delete_replication_task(
5272 &self,
5273 input: DeleteReplicationTaskMessage,
5274 ) -> Result<DeleteReplicationTaskResponse, RusotoError<DeleteReplicationTaskError>>;
5275
5276 async fn describe_account_attributes(
5278 &self,
5279 ) -> Result<DescribeAccountAttributesResponse, RusotoError<DescribeAccountAttributesError>>;
5280
5281 async fn describe_certificates(
5283 &self,
5284 input: DescribeCertificatesMessage,
5285 ) -> Result<DescribeCertificatesResponse, RusotoError<DescribeCertificatesError>>;
5286
5287 async fn describe_connections(
5289 &self,
5290 input: DescribeConnectionsMessage,
5291 ) -> Result<DescribeConnectionsResponse, RusotoError<DescribeConnectionsError>>;
5292
5293 async fn describe_endpoint_types(
5295 &self,
5296 input: DescribeEndpointTypesMessage,
5297 ) -> Result<DescribeEndpointTypesResponse, RusotoError<DescribeEndpointTypesError>>;
5298
5299 async fn describe_endpoints(
5301 &self,
5302 input: DescribeEndpointsMessage,
5303 ) -> Result<DescribeEndpointsResponse, RusotoError<DescribeEndpointsError>>;
5304
5305 async fn describe_event_categories(
5307 &self,
5308 input: DescribeEventCategoriesMessage,
5309 ) -> Result<DescribeEventCategoriesResponse, RusotoError<DescribeEventCategoriesError>>;
5310
5311 async fn describe_event_subscriptions(
5313 &self,
5314 input: DescribeEventSubscriptionsMessage,
5315 ) -> Result<DescribeEventSubscriptionsResponse, RusotoError<DescribeEventSubscriptionsError>>;
5316
5317 async fn describe_events(
5319 &self,
5320 input: DescribeEventsMessage,
5321 ) -> Result<DescribeEventsResponse, RusotoError<DescribeEventsError>>;
5322
5323 async fn describe_orderable_replication_instances(
5325 &self,
5326 input: DescribeOrderableReplicationInstancesMessage,
5327 ) -> Result<
5328 DescribeOrderableReplicationInstancesResponse,
5329 RusotoError<DescribeOrderableReplicationInstancesError>,
5330 >;
5331
5332 async fn describe_pending_maintenance_actions(
5334 &self,
5335 input: DescribePendingMaintenanceActionsMessage,
5336 ) -> Result<
5337 DescribePendingMaintenanceActionsResponse,
5338 RusotoError<DescribePendingMaintenanceActionsError>,
5339 >;
5340
5341 async fn describe_refresh_schemas_status(
5343 &self,
5344 input: DescribeRefreshSchemasStatusMessage,
5345 ) -> Result<DescribeRefreshSchemasStatusResponse, RusotoError<DescribeRefreshSchemasStatusError>>;
5346
5347 async fn describe_replication_instance_task_logs(
5349 &self,
5350 input: DescribeReplicationInstanceTaskLogsMessage,
5351 ) -> Result<
5352 DescribeReplicationInstanceTaskLogsResponse,
5353 RusotoError<DescribeReplicationInstanceTaskLogsError>,
5354 >;
5355
5356 async fn describe_replication_instances(
5358 &self,
5359 input: DescribeReplicationInstancesMessage,
5360 ) -> Result<DescribeReplicationInstancesResponse, RusotoError<DescribeReplicationInstancesError>>;
5361
5362 async fn describe_replication_subnet_groups(
5364 &self,
5365 input: DescribeReplicationSubnetGroupsMessage,
5366 ) -> Result<
5367 DescribeReplicationSubnetGroupsResponse,
5368 RusotoError<DescribeReplicationSubnetGroupsError>,
5369 >;
5370
5371 async fn describe_replication_task_assessment_results(
5373 &self,
5374 input: DescribeReplicationTaskAssessmentResultsMessage,
5375 ) -> Result<
5376 DescribeReplicationTaskAssessmentResultsResponse,
5377 RusotoError<DescribeReplicationTaskAssessmentResultsError>,
5378 >;
5379
5380 async fn describe_replication_tasks(
5382 &self,
5383 input: DescribeReplicationTasksMessage,
5384 ) -> Result<DescribeReplicationTasksResponse, RusotoError<DescribeReplicationTasksError>>;
5385
5386 async fn describe_schemas(
5388 &self,
5389 input: DescribeSchemasMessage,
5390 ) -> Result<DescribeSchemasResponse, RusotoError<DescribeSchemasError>>;
5391
5392 async fn describe_table_statistics(
5394 &self,
5395 input: DescribeTableStatisticsMessage,
5396 ) -> Result<DescribeTableStatisticsResponse, RusotoError<DescribeTableStatisticsError>>;
5397
5398 async fn import_certificate(
5400 &self,
5401 input: ImportCertificateMessage,
5402 ) -> Result<ImportCertificateResponse, RusotoError<ImportCertificateError>>;
5403
5404 async fn list_tags_for_resource(
5406 &self,
5407 input: ListTagsForResourceMessage,
5408 ) -> Result<ListTagsForResourceResponse, RusotoError<ListTagsForResourceError>>;
5409
5410 async fn modify_endpoint(
5412 &self,
5413 input: ModifyEndpointMessage,
5414 ) -> Result<ModifyEndpointResponse, RusotoError<ModifyEndpointError>>;
5415
5416 async fn modify_event_subscription(
5418 &self,
5419 input: ModifyEventSubscriptionMessage,
5420 ) -> Result<ModifyEventSubscriptionResponse, RusotoError<ModifyEventSubscriptionError>>;
5421
5422 async fn modify_replication_instance(
5424 &self,
5425 input: ModifyReplicationInstanceMessage,
5426 ) -> Result<ModifyReplicationInstanceResponse, RusotoError<ModifyReplicationInstanceError>>;
5427
5428 async fn modify_replication_subnet_group(
5430 &self,
5431 input: ModifyReplicationSubnetGroupMessage,
5432 ) -> Result<ModifyReplicationSubnetGroupResponse, RusotoError<ModifyReplicationSubnetGroupError>>;
5433
5434 async fn modify_replication_task(
5436 &self,
5437 input: ModifyReplicationTaskMessage,
5438 ) -> Result<ModifyReplicationTaskResponse, RusotoError<ModifyReplicationTaskError>>;
5439
5440 async fn reboot_replication_instance(
5442 &self,
5443 input: RebootReplicationInstanceMessage,
5444 ) -> Result<RebootReplicationInstanceResponse, RusotoError<RebootReplicationInstanceError>>;
5445
5446 async fn refresh_schemas(
5448 &self,
5449 input: RefreshSchemasMessage,
5450 ) -> Result<RefreshSchemasResponse, RusotoError<RefreshSchemasError>>;
5451
5452 async fn reload_tables(
5454 &self,
5455 input: ReloadTablesMessage,
5456 ) -> Result<ReloadTablesResponse, RusotoError<ReloadTablesError>>;
5457
5458 async fn remove_tags_from_resource(
5460 &self,
5461 input: RemoveTagsFromResourceMessage,
5462 ) -> Result<RemoveTagsFromResourceResponse, RusotoError<RemoveTagsFromResourceError>>;
5463
5464 async fn start_replication_task(
5466 &self,
5467 input: StartReplicationTaskMessage,
5468 ) -> Result<StartReplicationTaskResponse, RusotoError<StartReplicationTaskError>>;
5469
5470 async fn start_replication_task_assessment(
5472 &self,
5473 input: StartReplicationTaskAssessmentMessage,
5474 ) -> Result<
5475 StartReplicationTaskAssessmentResponse,
5476 RusotoError<StartReplicationTaskAssessmentError>,
5477 >;
5478
5479 async fn stop_replication_task(
5481 &self,
5482 input: StopReplicationTaskMessage,
5483 ) -> Result<StopReplicationTaskResponse, RusotoError<StopReplicationTaskError>>;
5484
5485 async fn test_connection(
5487 &self,
5488 input: TestConnectionMessage,
5489 ) -> Result<TestConnectionResponse, RusotoError<TestConnectionError>>;
5490}
5491#[derive(Clone)]
5493pub struct DatabaseMigrationServiceClient {
5494 client: Client,
5495 region: region::Region,
5496}
5497
5498impl DatabaseMigrationServiceClient {
5499 pub fn new(region: region::Region) -> DatabaseMigrationServiceClient {
5503 DatabaseMigrationServiceClient {
5504 client: Client::shared(),
5505 region,
5506 }
5507 }
5508
5509 pub fn new_with<P, D>(
5510 request_dispatcher: D,
5511 credentials_provider: P,
5512 region: region::Region,
5513 ) -> DatabaseMigrationServiceClient
5514 where
5515 P: ProvideAwsCredentials + Send + Sync + 'static,
5516 D: DispatchSignedRequest + Send + Sync + 'static,
5517 {
5518 DatabaseMigrationServiceClient {
5519 client: Client::new_with(credentials_provider, request_dispatcher),
5520 region,
5521 }
5522 }
5523
5524 pub fn new_with_client(
5525 client: Client,
5526 region: region::Region,
5527 ) -> DatabaseMigrationServiceClient {
5528 DatabaseMigrationServiceClient { client, region }
5529 }
5530}
5531
5532#[async_trait]
5533impl DatabaseMigrationService for DatabaseMigrationServiceClient {
5534 async fn add_tags_to_resource(
5536 &self,
5537 input: AddTagsToResourceMessage,
5538 ) -> Result<AddTagsToResourceResponse, RusotoError<AddTagsToResourceError>> {
5539 let mut request = self.new_signed_request("POST", "/");
5540 request.add_header("x-amz-target", "AmazonDMSv20160101.AddTagsToResource");
5541 let encoded = serde_json::to_string(&input).unwrap();
5542 request.set_payload(Some(encoded));
5543
5544 let response = self
5545 .sign_and_dispatch(request, AddTagsToResourceError::from_response)
5546 .await?;
5547 let mut response = response;
5548 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5549 proto::json::ResponsePayload::new(&response).deserialize::<AddTagsToResourceResponse, _>()
5550 }
5551
5552 async fn apply_pending_maintenance_action(
5554 &self,
5555 input: ApplyPendingMaintenanceActionMessage,
5556 ) -> Result<
5557 ApplyPendingMaintenanceActionResponse,
5558 RusotoError<ApplyPendingMaintenanceActionError>,
5559 > {
5560 let mut request = self.new_signed_request("POST", "/");
5561 request.add_header(
5562 "x-amz-target",
5563 "AmazonDMSv20160101.ApplyPendingMaintenanceAction",
5564 );
5565 let encoded = serde_json::to_string(&input).unwrap();
5566 request.set_payload(Some(encoded));
5567
5568 let response = self
5569 .sign_and_dispatch(request, ApplyPendingMaintenanceActionError::from_response)
5570 .await?;
5571 let mut response = response;
5572 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5573 proto::json::ResponsePayload::new(&response)
5574 .deserialize::<ApplyPendingMaintenanceActionResponse, _>()
5575 }
5576
5577 async fn create_endpoint(
5579 &self,
5580 input: CreateEndpointMessage,
5581 ) -> Result<CreateEndpointResponse, RusotoError<CreateEndpointError>> {
5582 let mut request = self.new_signed_request("POST", "/");
5583 request.add_header("x-amz-target", "AmazonDMSv20160101.CreateEndpoint");
5584 let encoded = serde_json::to_string(&input).unwrap();
5585 request.set_payload(Some(encoded));
5586
5587 let response = self
5588 .sign_and_dispatch(request, CreateEndpointError::from_response)
5589 .await?;
5590 let mut response = response;
5591 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5592 proto::json::ResponsePayload::new(&response).deserialize::<CreateEndpointResponse, _>()
5593 }
5594
5595 async fn create_event_subscription(
5597 &self,
5598 input: CreateEventSubscriptionMessage,
5599 ) -> Result<CreateEventSubscriptionResponse, RusotoError<CreateEventSubscriptionError>> {
5600 let mut request = self.new_signed_request("POST", "/");
5601 request.add_header("x-amz-target", "AmazonDMSv20160101.CreateEventSubscription");
5602 let encoded = serde_json::to_string(&input).unwrap();
5603 request.set_payload(Some(encoded));
5604
5605 let response = self
5606 .sign_and_dispatch(request, CreateEventSubscriptionError::from_response)
5607 .await?;
5608 let mut response = response;
5609 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5610 proto::json::ResponsePayload::new(&response)
5611 .deserialize::<CreateEventSubscriptionResponse, _>()
5612 }
5613
5614 async fn create_replication_instance(
5616 &self,
5617 input: CreateReplicationInstanceMessage,
5618 ) -> Result<CreateReplicationInstanceResponse, RusotoError<CreateReplicationInstanceError>>
5619 {
5620 let mut request = self.new_signed_request("POST", "/");
5621 request.add_header(
5622 "x-amz-target",
5623 "AmazonDMSv20160101.CreateReplicationInstance",
5624 );
5625 let encoded = serde_json::to_string(&input).unwrap();
5626 request.set_payload(Some(encoded));
5627
5628 let response = self
5629 .sign_and_dispatch(request, CreateReplicationInstanceError::from_response)
5630 .await?;
5631 let mut response = response;
5632 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5633 proto::json::ResponsePayload::new(&response)
5634 .deserialize::<CreateReplicationInstanceResponse, _>()
5635 }
5636
5637 async fn create_replication_subnet_group(
5639 &self,
5640 input: CreateReplicationSubnetGroupMessage,
5641 ) -> Result<CreateReplicationSubnetGroupResponse, RusotoError<CreateReplicationSubnetGroupError>>
5642 {
5643 let mut request = self.new_signed_request("POST", "/");
5644 request.add_header(
5645 "x-amz-target",
5646 "AmazonDMSv20160101.CreateReplicationSubnetGroup",
5647 );
5648 let encoded = serde_json::to_string(&input).unwrap();
5649 request.set_payload(Some(encoded));
5650
5651 let response = self
5652 .sign_and_dispatch(request, CreateReplicationSubnetGroupError::from_response)
5653 .await?;
5654 let mut response = response;
5655 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5656 proto::json::ResponsePayload::new(&response)
5657 .deserialize::<CreateReplicationSubnetGroupResponse, _>()
5658 }
5659
5660 async fn create_replication_task(
5662 &self,
5663 input: CreateReplicationTaskMessage,
5664 ) -> Result<CreateReplicationTaskResponse, RusotoError<CreateReplicationTaskError>> {
5665 let mut request = self.new_signed_request("POST", "/");
5666 request.add_header("x-amz-target", "AmazonDMSv20160101.CreateReplicationTask");
5667 let encoded = serde_json::to_string(&input).unwrap();
5668 request.set_payload(Some(encoded));
5669
5670 let response = self
5671 .sign_and_dispatch(request, CreateReplicationTaskError::from_response)
5672 .await?;
5673 let mut response = response;
5674 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5675 proto::json::ResponsePayload::new(&response)
5676 .deserialize::<CreateReplicationTaskResponse, _>()
5677 }
5678
5679 async fn delete_certificate(
5681 &self,
5682 input: DeleteCertificateMessage,
5683 ) -> Result<DeleteCertificateResponse, RusotoError<DeleteCertificateError>> {
5684 let mut request = self.new_signed_request("POST", "/");
5685 request.add_header("x-amz-target", "AmazonDMSv20160101.DeleteCertificate");
5686 let encoded = serde_json::to_string(&input).unwrap();
5687 request.set_payload(Some(encoded));
5688
5689 let response = self
5690 .sign_and_dispatch(request, DeleteCertificateError::from_response)
5691 .await?;
5692 let mut response = response;
5693 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5694 proto::json::ResponsePayload::new(&response).deserialize::<DeleteCertificateResponse, _>()
5695 }
5696
5697 async fn delete_connection(
5699 &self,
5700 input: DeleteConnectionMessage,
5701 ) -> Result<DeleteConnectionResponse, RusotoError<DeleteConnectionError>> {
5702 let mut request = self.new_signed_request("POST", "/");
5703 request.add_header("x-amz-target", "AmazonDMSv20160101.DeleteConnection");
5704 let encoded = serde_json::to_string(&input).unwrap();
5705 request.set_payload(Some(encoded));
5706
5707 let response = self
5708 .sign_and_dispatch(request, DeleteConnectionError::from_response)
5709 .await?;
5710 let mut response = response;
5711 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5712 proto::json::ResponsePayload::new(&response).deserialize::<DeleteConnectionResponse, _>()
5713 }
5714
5715 async fn delete_endpoint(
5717 &self,
5718 input: DeleteEndpointMessage,
5719 ) -> Result<DeleteEndpointResponse, RusotoError<DeleteEndpointError>> {
5720 let mut request = self.new_signed_request("POST", "/");
5721 request.add_header("x-amz-target", "AmazonDMSv20160101.DeleteEndpoint");
5722 let encoded = serde_json::to_string(&input).unwrap();
5723 request.set_payload(Some(encoded));
5724
5725 let response = self
5726 .sign_and_dispatch(request, DeleteEndpointError::from_response)
5727 .await?;
5728 let mut response = response;
5729 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5730 proto::json::ResponsePayload::new(&response).deserialize::<DeleteEndpointResponse, _>()
5731 }
5732
5733 async fn delete_event_subscription(
5735 &self,
5736 input: DeleteEventSubscriptionMessage,
5737 ) -> Result<DeleteEventSubscriptionResponse, RusotoError<DeleteEventSubscriptionError>> {
5738 let mut request = self.new_signed_request("POST", "/");
5739 request.add_header("x-amz-target", "AmazonDMSv20160101.DeleteEventSubscription");
5740 let encoded = serde_json::to_string(&input).unwrap();
5741 request.set_payload(Some(encoded));
5742
5743 let response = self
5744 .sign_and_dispatch(request, DeleteEventSubscriptionError::from_response)
5745 .await?;
5746 let mut response = response;
5747 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5748 proto::json::ResponsePayload::new(&response)
5749 .deserialize::<DeleteEventSubscriptionResponse, _>()
5750 }
5751
5752 async fn delete_replication_instance(
5754 &self,
5755 input: DeleteReplicationInstanceMessage,
5756 ) -> Result<DeleteReplicationInstanceResponse, RusotoError<DeleteReplicationInstanceError>>
5757 {
5758 let mut request = self.new_signed_request("POST", "/");
5759 request.add_header(
5760 "x-amz-target",
5761 "AmazonDMSv20160101.DeleteReplicationInstance",
5762 );
5763 let encoded = serde_json::to_string(&input).unwrap();
5764 request.set_payload(Some(encoded));
5765
5766 let response = self
5767 .sign_and_dispatch(request, DeleteReplicationInstanceError::from_response)
5768 .await?;
5769 let mut response = response;
5770 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5771 proto::json::ResponsePayload::new(&response)
5772 .deserialize::<DeleteReplicationInstanceResponse, _>()
5773 }
5774
5775 async fn delete_replication_subnet_group(
5777 &self,
5778 input: DeleteReplicationSubnetGroupMessage,
5779 ) -> Result<DeleteReplicationSubnetGroupResponse, RusotoError<DeleteReplicationSubnetGroupError>>
5780 {
5781 let mut request = self.new_signed_request("POST", "/");
5782 request.add_header(
5783 "x-amz-target",
5784 "AmazonDMSv20160101.DeleteReplicationSubnetGroup",
5785 );
5786 let encoded = serde_json::to_string(&input).unwrap();
5787 request.set_payload(Some(encoded));
5788
5789 let response = self
5790 .sign_and_dispatch(request, DeleteReplicationSubnetGroupError::from_response)
5791 .await?;
5792 let mut response = response;
5793 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5794 proto::json::ResponsePayload::new(&response)
5795 .deserialize::<DeleteReplicationSubnetGroupResponse, _>()
5796 }
5797
5798 async fn delete_replication_task(
5800 &self,
5801 input: DeleteReplicationTaskMessage,
5802 ) -> Result<DeleteReplicationTaskResponse, RusotoError<DeleteReplicationTaskError>> {
5803 let mut request = self.new_signed_request("POST", "/");
5804 request.add_header("x-amz-target", "AmazonDMSv20160101.DeleteReplicationTask");
5805 let encoded = serde_json::to_string(&input).unwrap();
5806 request.set_payload(Some(encoded));
5807
5808 let response = self
5809 .sign_and_dispatch(request, DeleteReplicationTaskError::from_response)
5810 .await?;
5811 let mut response = response;
5812 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5813 proto::json::ResponsePayload::new(&response)
5814 .deserialize::<DeleteReplicationTaskResponse, _>()
5815 }
5816
5817 async fn describe_account_attributes(
5819 &self,
5820 ) -> Result<DescribeAccountAttributesResponse, RusotoError<DescribeAccountAttributesError>>
5821 {
5822 let mut request = self.new_signed_request("POST", "/");
5823 request.add_header(
5824 "x-amz-target",
5825 "AmazonDMSv20160101.DescribeAccountAttributes",
5826 );
5827 request.set_payload(Some(bytes::Bytes::from_static(b"{}")));
5828
5829 let response = self
5830 .sign_and_dispatch(request, DescribeAccountAttributesError::from_response)
5831 .await?;
5832 let mut response = response;
5833 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5834 proto::json::ResponsePayload::new(&response)
5835 .deserialize::<DescribeAccountAttributesResponse, _>()
5836 }
5837
5838 async fn describe_certificates(
5840 &self,
5841 input: DescribeCertificatesMessage,
5842 ) -> Result<DescribeCertificatesResponse, RusotoError<DescribeCertificatesError>> {
5843 let mut request = self.new_signed_request("POST", "/");
5844 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeCertificates");
5845 let encoded = serde_json::to_string(&input).unwrap();
5846 request.set_payload(Some(encoded));
5847
5848 let response = self
5849 .sign_and_dispatch(request, DescribeCertificatesError::from_response)
5850 .await?;
5851 let mut response = response;
5852 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5853 proto::json::ResponsePayload::new(&response)
5854 .deserialize::<DescribeCertificatesResponse, _>()
5855 }
5856
5857 async fn describe_connections(
5859 &self,
5860 input: DescribeConnectionsMessage,
5861 ) -> Result<DescribeConnectionsResponse, RusotoError<DescribeConnectionsError>> {
5862 let mut request = self.new_signed_request("POST", "/");
5863 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeConnections");
5864 let encoded = serde_json::to_string(&input).unwrap();
5865 request.set_payload(Some(encoded));
5866
5867 let response = self
5868 .sign_and_dispatch(request, DescribeConnectionsError::from_response)
5869 .await?;
5870 let mut response = response;
5871 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5872 proto::json::ResponsePayload::new(&response).deserialize::<DescribeConnectionsResponse, _>()
5873 }
5874
5875 async fn describe_endpoint_types(
5877 &self,
5878 input: DescribeEndpointTypesMessage,
5879 ) -> Result<DescribeEndpointTypesResponse, RusotoError<DescribeEndpointTypesError>> {
5880 let mut request = self.new_signed_request("POST", "/");
5881 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeEndpointTypes");
5882 let encoded = serde_json::to_string(&input).unwrap();
5883 request.set_payload(Some(encoded));
5884
5885 let response = self
5886 .sign_and_dispatch(request, DescribeEndpointTypesError::from_response)
5887 .await?;
5888 let mut response = response;
5889 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5890 proto::json::ResponsePayload::new(&response)
5891 .deserialize::<DescribeEndpointTypesResponse, _>()
5892 }
5893
5894 async fn describe_endpoints(
5896 &self,
5897 input: DescribeEndpointsMessage,
5898 ) -> Result<DescribeEndpointsResponse, RusotoError<DescribeEndpointsError>> {
5899 let mut request = self.new_signed_request("POST", "/");
5900 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeEndpoints");
5901 let encoded = serde_json::to_string(&input).unwrap();
5902 request.set_payload(Some(encoded));
5903
5904 let response = self
5905 .sign_and_dispatch(request, DescribeEndpointsError::from_response)
5906 .await?;
5907 let mut response = response;
5908 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5909 proto::json::ResponsePayload::new(&response).deserialize::<DescribeEndpointsResponse, _>()
5910 }
5911
5912 async fn describe_event_categories(
5914 &self,
5915 input: DescribeEventCategoriesMessage,
5916 ) -> Result<DescribeEventCategoriesResponse, RusotoError<DescribeEventCategoriesError>> {
5917 let mut request = self.new_signed_request("POST", "/");
5918 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeEventCategories");
5919 let encoded = serde_json::to_string(&input).unwrap();
5920 request.set_payload(Some(encoded));
5921
5922 let response = self
5923 .sign_and_dispatch(request, DescribeEventCategoriesError::from_response)
5924 .await?;
5925 let mut response = response;
5926 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5927 proto::json::ResponsePayload::new(&response)
5928 .deserialize::<DescribeEventCategoriesResponse, _>()
5929 }
5930
5931 async fn describe_event_subscriptions(
5933 &self,
5934 input: DescribeEventSubscriptionsMessage,
5935 ) -> Result<DescribeEventSubscriptionsResponse, RusotoError<DescribeEventSubscriptionsError>>
5936 {
5937 let mut request = self.new_signed_request("POST", "/");
5938 request.add_header(
5939 "x-amz-target",
5940 "AmazonDMSv20160101.DescribeEventSubscriptions",
5941 );
5942 let encoded = serde_json::to_string(&input).unwrap();
5943 request.set_payload(Some(encoded));
5944
5945 let response = self
5946 .sign_and_dispatch(request, DescribeEventSubscriptionsError::from_response)
5947 .await?;
5948 let mut response = response;
5949 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5950 proto::json::ResponsePayload::new(&response)
5951 .deserialize::<DescribeEventSubscriptionsResponse, _>()
5952 }
5953
5954 async fn describe_events(
5956 &self,
5957 input: DescribeEventsMessage,
5958 ) -> Result<DescribeEventsResponse, RusotoError<DescribeEventsError>> {
5959 let mut request = self.new_signed_request("POST", "/");
5960 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeEvents");
5961 let encoded = serde_json::to_string(&input).unwrap();
5962 request.set_payload(Some(encoded));
5963
5964 let response = self
5965 .sign_and_dispatch(request, DescribeEventsError::from_response)
5966 .await?;
5967 let mut response = response;
5968 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5969 proto::json::ResponsePayload::new(&response).deserialize::<DescribeEventsResponse, _>()
5970 }
5971
5972 async fn describe_orderable_replication_instances(
5974 &self,
5975 input: DescribeOrderableReplicationInstancesMessage,
5976 ) -> Result<
5977 DescribeOrderableReplicationInstancesResponse,
5978 RusotoError<DescribeOrderableReplicationInstancesError>,
5979 > {
5980 let mut request = self.new_signed_request("POST", "/");
5981 request.add_header(
5982 "x-amz-target",
5983 "AmazonDMSv20160101.DescribeOrderableReplicationInstances",
5984 );
5985 let encoded = serde_json::to_string(&input).unwrap();
5986 request.set_payload(Some(encoded));
5987
5988 let response = self
5989 .sign_and_dispatch(
5990 request,
5991 DescribeOrderableReplicationInstancesError::from_response,
5992 )
5993 .await?;
5994 let mut response = response;
5995 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5996 proto::json::ResponsePayload::new(&response)
5997 .deserialize::<DescribeOrderableReplicationInstancesResponse, _>()
5998 }
5999
6000 async fn describe_pending_maintenance_actions(
6002 &self,
6003 input: DescribePendingMaintenanceActionsMessage,
6004 ) -> Result<
6005 DescribePendingMaintenanceActionsResponse,
6006 RusotoError<DescribePendingMaintenanceActionsError>,
6007 > {
6008 let mut request = self.new_signed_request("POST", "/");
6009 request.add_header(
6010 "x-amz-target",
6011 "AmazonDMSv20160101.DescribePendingMaintenanceActions",
6012 );
6013 let encoded = serde_json::to_string(&input).unwrap();
6014 request.set_payload(Some(encoded));
6015
6016 let response = self
6017 .sign_and_dispatch(
6018 request,
6019 DescribePendingMaintenanceActionsError::from_response,
6020 )
6021 .await?;
6022 let mut response = response;
6023 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6024 proto::json::ResponsePayload::new(&response)
6025 .deserialize::<DescribePendingMaintenanceActionsResponse, _>()
6026 }
6027
6028 async fn describe_refresh_schemas_status(
6030 &self,
6031 input: DescribeRefreshSchemasStatusMessage,
6032 ) -> Result<DescribeRefreshSchemasStatusResponse, RusotoError<DescribeRefreshSchemasStatusError>>
6033 {
6034 let mut request = self.new_signed_request("POST", "/");
6035 request.add_header(
6036 "x-amz-target",
6037 "AmazonDMSv20160101.DescribeRefreshSchemasStatus",
6038 );
6039 let encoded = serde_json::to_string(&input).unwrap();
6040 request.set_payload(Some(encoded));
6041
6042 let response = self
6043 .sign_and_dispatch(request, DescribeRefreshSchemasStatusError::from_response)
6044 .await?;
6045 let mut response = response;
6046 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6047 proto::json::ResponsePayload::new(&response)
6048 .deserialize::<DescribeRefreshSchemasStatusResponse, _>()
6049 }
6050
6051 async fn describe_replication_instance_task_logs(
6053 &self,
6054 input: DescribeReplicationInstanceTaskLogsMessage,
6055 ) -> Result<
6056 DescribeReplicationInstanceTaskLogsResponse,
6057 RusotoError<DescribeReplicationInstanceTaskLogsError>,
6058 > {
6059 let mut request = self.new_signed_request("POST", "/");
6060 request.add_header(
6061 "x-amz-target",
6062 "AmazonDMSv20160101.DescribeReplicationInstanceTaskLogs",
6063 );
6064 let encoded = serde_json::to_string(&input).unwrap();
6065 request.set_payload(Some(encoded));
6066
6067 let response = self
6068 .sign_and_dispatch(
6069 request,
6070 DescribeReplicationInstanceTaskLogsError::from_response,
6071 )
6072 .await?;
6073 let mut response = response;
6074 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6075 proto::json::ResponsePayload::new(&response)
6076 .deserialize::<DescribeReplicationInstanceTaskLogsResponse, _>()
6077 }
6078
6079 async fn describe_replication_instances(
6081 &self,
6082 input: DescribeReplicationInstancesMessage,
6083 ) -> Result<DescribeReplicationInstancesResponse, RusotoError<DescribeReplicationInstancesError>>
6084 {
6085 let mut request = self.new_signed_request("POST", "/");
6086 request.add_header(
6087 "x-amz-target",
6088 "AmazonDMSv20160101.DescribeReplicationInstances",
6089 );
6090 let encoded = serde_json::to_string(&input).unwrap();
6091 request.set_payload(Some(encoded));
6092
6093 let response = self
6094 .sign_and_dispatch(request, DescribeReplicationInstancesError::from_response)
6095 .await?;
6096 let mut response = response;
6097 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6098 proto::json::ResponsePayload::new(&response)
6099 .deserialize::<DescribeReplicationInstancesResponse, _>()
6100 }
6101
6102 async fn describe_replication_subnet_groups(
6104 &self,
6105 input: DescribeReplicationSubnetGroupsMessage,
6106 ) -> Result<
6107 DescribeReplicationSubnetGroupsResponse,
6108 RusotoError<DescribeReplicationSubnetGroupsError>,
6109 > {
6110 let mut request = self.new_signed_request("POST", "/");
6111 request.add_header(
6112 "x-amz-target",
6113 "AmazonDMSv20160101.DescribeReplicationSubnetGroups",
6114 );
6115 let encoded = serde_json::to_string(&input).unwrap();
6116 request.set_payload(Some(encoded));
6117
6118 let response = self
6119 .sign_and_dispatch(request, DescribeReplicationSubnetGroupsError::from_response)
6120 .await?;
6121 let mut response = response;
6122 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6123 proto::json::ResponsePayload::new(&response)
6124 .deserialize::<DescribeReplicationSubnetGroupsResponse, _>()
6125 }
6126
6127 async fn describe_replication_task_assessment_results(
6129 &self,
6130 input: DescribeReplicationTaskAssessmentResultsMessage,
6131 ) -> Result<
6132 DescribeReplicationTaskAssessmentResultsResponse,
6133 RusotoError<DescribeReplicationTaskAssessmentResultsError>,
6134 > {
6135 let mut request = self.new_signed_request("POST", "/");
6136 request.add_header(
6137 "x-amz-target",
6138 "AmazonDMSv20160101.DescribeReplicationTaskAssessmentResults",
6139 );
6140 let encoded = serde_json::to_string(&input).unwrap();
6141 request.set_payload(Some(encoded));
6142
6143 let response = self
6144 .sign_and_dispatch(
6145 request,
6146 DescribeReplicationTaskAssessmentResultsError::from_response,
6147 )
6148 .await?;
6149 let mut response = response;
6150 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6151 proto::json::ResponsePayload::new(&response)
6152 .deserialize::<DescribeReplicationTaskAssessmentResultsResponse, _>()
6153 }
6154
6155 async fn describe_replication_tasks(
6157 &self,
6158 input: DescribeReplicationTasksMessage,
6159 ) -> Result<DescribeReplicationTasksResponse, RusotoError<DescribeReplicationTasksError>> {
6160 let mut request = self.new_signed_request("POST", "/");
6161 request.add_header(
6162 "x-amz-target",
6163 "AmazonDMSv20160101.DescribeReplicationTasks",
6164 );
6165 let encoded = serde_json::to_string(&input).unwrap();
6166 request.set_payload(Some(encoded));
6167
6168 let response = self
6169 .sign_and_dispatch(request, DescribeReplicationTasksError::from_response)
6170 .await?;
6171 let mut response = response;
6172 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6173 proto::json::ResponsePayload::new(&response)
6174 .deserialize::<DescribeReplicationTasksResponse, _>()
6175 }
6176
6177 async fn describe_schemas(
6179 &self,
6180 input: DescribeSchemasMessage,
6181 ) -> Result<DescribeSchemasResponse, RusotoError<DescribeSchemasError>> {
6182 let mut request = self.new_signed_request("POST", "/");
6183 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeSchemas");
6184 let encoded = serde_json::to_string(&input).unwrap();
6185 request.set_payload(Some(encoded));
6186
6187 let response = self
6188 .sign_and_dispatch(request, DescribeSchemasError::from_response)
6189 .await?;
6190 let mut response = response;
6191 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6192 proto::json::ResponsePayload::new(&response).deserialize::<DescribeSchemasResponse, _>()
6193 }
6194
6195 async fn describe_table_statistics(
6197 &self,
6198 input: DescribeTableStatisticsMessage,
6199 ) -> Result<DescribeTableStatisticsResponse, RusotoError<DescribeTableStatisticsError>> {
6200 let mut request = self.new_signed_request("POST", "/");
6201 request.add_header("x-amz-target", "AmazonDMSv20160101.DescribeTableStatistics");
6202 let encoded = serde_json::to_string(&input).unwrap();
6203 request.set_payload(Some(encoded));
6204
6205 let response = self
6206 .sign_and_dispatch(request, DescribeTableStatisticsError::from_response)
6207 .await?;
6208 let mut response = response;
6209 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6210 proto::json::ResponsePayload::new(&response)
6211 .deserialize::<DescribeTableStatisticsResponse, _>()
6212 }
6213
6214 async fn import_certificate(
6216 &self,
6217 input: ImportCertificateMessage,
6218 ) -> Result<ImportCertificateResponse, RusotoError<ImportCertificateError>> {
6219 let mut request = self.new_signed_request("POST", "/");
6220 request.add_header("x-amz-target", "AmazonDMSv20160101.ImportCertificate");
6221 let encoded = serde_json::to_string(&input).unwrap();
6222 request.set_payload(Some(encoded));
6223
6224 let response = self
6225 .sign_and_dispatch(request, ImportCertificateError::from_response)
6226 .await?;
6227 let mut response = response;
6228 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6229 proto::json::ResponsePayload::new(&response).deserialize::<ImportCertificateResponse, _>()
6230 }
6231
6232 async fn list_tags_for_resource(
6234 &self,
6235 input: ListTagsForResourceMessage,
6236 ) -> Result<ListTagsForResourceResponse, RusotoError<ListTagsForResourceError>> {
6237 let mut request = self.new_signed_request("POST", "/");
6238 request.add_header("x-amz-target", "AmazonDMSv20160101.ListTagsForResource");
6239 let encoded = serde_json::to_string(&input).unwrap();
6240 request.set_payload(Some(encoded));
6241
6242 let response = self
6243 .sign_and_dispatch(request, ListTagsForResourceError::from_response)
6244 .await?;
6245 let mut response = response;
6246 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6247 proto::json::ResponsePayload::new(&response).deserialize::<ListTagsForResourceResponse, _>()
6248 }
6249
6250 async fn modify_endpoint(
6252 &self,
6253 input: ModifyEndpointMessage,
6254 ) -> Result<ModifyEndpointResponse, RusotoError<ModifyEndpointError>> {
6255 let mut request = self.new_signed_request("POST", "/");
6256 request.add_header("x-amz-target", "AmazonDMSv20160101.ModifyEndpoint");
6257 let encoded = serde_json::to_string(&input).unwrap();
6258 request.set_payload(Some(encoded));
6259
6260 let response = self
6261 .sign_and_dispatch(request, ModifyEndpointError::from_response)
6262 .await?;
6263 let mut response = response;
6264 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6265 proto::json::ResponsePayload::new(&response).deserialize::<ModifyEndpointResponse, _>()
6266 }
6267
6268 async fn modify_event_subscription(
6270 &self,
6271 input: ModifyEventSubscriptionMessage,
6272 ) -> Result<ModifyEventSubscriptionResponse, RusotoError<ModifyEventSubscriptionError>> {
6273 let mut request = self.new_signed_request("POST", "/");
6274 request.add_header("x-amz-target", "AmazonDMSv20160101.ModifyEventSubscription");
6275 let encoded = serde_json::to_string(&input).unwrap();
6276 request.set_payload(Some(encoded));
6277
6278 let response = self
6279 .sign_and_dispatch(request, ModifyEventSubscriptionError::from_response)
6280 .await?;
6281 let mut response = response;
6282 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6283 proto::json::ResponsePayload::new(&response)
6284 .deserialize::<ModifyEventSubscriptionResponse, _>()
6285 }
6286
6287 async fn modify_replication_instance(
6289 &self,
6290 input: ModifyReplicationInstanceMessage,
6291 ) -> Result<ModifyReplicationInstanceResponse, RusotoError<ModifyReplicationInstanceError>>
6292 {
6293 let mut request = self.new_signed_request("POST", "/");
6294 request.add_header(
6295 "x-amz-target",
6296 "AmazonDMSv20160101.ModifyReplicationInstance",
6297 );
6298 let encoded = serde_json::to_string(&input).unwrap();
6299 request.set_payload(Some(encoded));
6300
6301 let response = self
6302 .sign_and_dispatch(request, ModifyReplicationInstanceError::from_response)
6303 .await?;
6304 let mut response = response;
6305 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6306 proto::json::ResponsePayload::new(&response)
6307 .deserialize::<ModifyReplicationInstanceResponse, _>()
6308 }
6309
6310 async fn modify_replication_subnet_group(
6312 &self,
6313 input: ModifyReplicationSubnetGroupMessage,
6314 ) -> Result<ModifyReplicationSubnetGroupResponse, RusotoError<ModifyReplicationSubnetGroupError>>
6315 {
6316 let mut request = self.new_signed_request("POST", "/");
6317 request.add_header(
6318 "x-amz-target",
6319 "AmazonDMSv20160101.ModifyReplicationSubnetGroup",
6320 );
6321 let encoded = serde_json::to_string(&input).unwrap();
6322 request.set_payload(Some(encoded));
6323
6324 let response = self
6325 .sign_and_dispatch(request, ModifyReplicationSubnetGroupError::from_response)
6326 .await?;
6327 let mut response = response;
6328 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6329 proto::json::ResponsePayload::new(&response)
6330 .deserialize::<ModifyReplicationSubnetGroupResponse, _>()
6331 }
6332
6333 async fn modify_replication_task(
6335 &self,
6336 input: ModifyReplicationTaskMessage,
6337 ) -> Result<ModifyReplicationTaskResponse, RusotoError<ModifyReplicationTaskError>> {
6338 let mut request = self.new_signed_request("POST", "/");
6339 request.add_header("x-amz-target", "AmazonDMSv20160101.ModifyReplicationTask");
6340 let encoded = serde_json::to_string(&input).unwrap();
6341 request.set_payload(Some(encoded));
6342
6343 let response = self
6344 .sign_and_dispatch(request, ModifyReplicationTaskError::from_response)
6345 .await?;
6346 let mut response = response;
6347 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6348 proto::json::ResponsePayload::new(&response)
6349 .deserialize::<ModifyReplicationTaskResponse, _>()
6350 }
6351
6352 async fn reboot_replication_instance(
6354 &self,
6355 input: RebootReplicationInstanceMessage,
6356 ) -> Result<RebootReplicationInstanceResponse, RusotoError<RebootReplicationInstanceError>>
6357 {
6358 let mut request = self.new_signed_request("POST", "/");
6359 request.add_header(
6360 "x-amz-target",
6361 "AmazonDMSv20160101.RebootReplicationInstance",
6362 );
6363 let encoded = serde_json::to_string(&input).unwrap();
6364 request.set_payload(Some(encoded));
6365
6366 let response = self
6367 .sign_and_dispatch(request, RebootReplicationInstanceError::from_response)
6368 .await?;
6369 let mut response = response;
6370 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6371 proto::json::ResponsePayload::new(&response)
6372 .deserialize::<RebootReplicationInstanceResponse, _>()
6373 }
6374
6375 async fn refresh_schemas(
6377 &self,
6378 input: RefreshSchemasMessage,
6379 ) -> Result<RefreshSchemasResponse, RusotoError<RefreshSchemasError>> {
6380 let mut request = self.new_signed_request("POST", "/");
6381 request.add_header("x-amz-target", "AmazonDMSv20160101.RefreshSchemas");
6382 let encoded = serde_json::to_string(&input).unwrap();
6383 request.set_payload(Some(encoded));
6384
6385 let response = self
6386 .sign_and_dispatch(request, RefreshSchemasError::from_response)
6387 .await?;
6388 let mut response = response;
6389 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6390 proto::json::ResponsePayload::new(&response).deserialize::<RefreshSchemasResponse, _>()
6391 }
6392
6393 async fn reload_tables(
6395 &self,
6396 input: ReloadTablesMessage,
6397 ) -> Result<ReloadTablesResponse, RusotoError<ReloadTablesError>> {
6398 let mut request = self.new_signed_request("POST", "/");
6399 request.add_header("x-amz-target", "AmazonDMSv20160101.ReloadTables");
6400 let encoded = serde_json::to_string(&input).unwrap();
6401 request.set_payload(Some(encoded));
6402
6403 let response = self
6404 .sign_and_dispatch(request, ReloadTablesError::from_response)
6405 .await?;
6406 let mut response = response;
6407 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6408 proto::json::ResponsePayload::new(&response).deserialize::<ReloadTablesResponse, _>()
6409 }
6410
6411 async fn remove_tags_from_resource(
6413 &self,
6414 input: RemoveTagsFromResourceMessage,
6415 ) -> Result<RemoveTagsFromResourceResponse, RusotoError<RemoveTagsFromResourceError>> {
6416 let mut request = self.new_signed_request("POST", "/");
6417 request.add_header("x-amz-target", "AmazonDMSv20160101.RemoveTagsFromResource");
6418 let encoded = serde_json::to_string(&input).unwrap();
6419 request.set_payload(Some(encoded));
6420
6421 let response = self
6422 .sign_and_dispatch(request, RemoveTagsFromResourceError::from_response)
6423 .await?;
6424 let mut response = response;
6425 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6426 proto::json::ResponsePayload::new(&response)
6427 .deserialize::<RemoveTagsFromResourceResponse, _>()
6428 }
6429
6430 async fn start_replication_task(
6432 &self,
6433 input: StartReplicationTaskMessage,
6434 ) -> Result<StartReplicationTaskResponse, RusotoError<StartReplicationTaskError>> {
6435 let mut request = self.new_signed_request("POST", "/");
6436 request.add_header("x-amz-target", "AmazonDMSv20160101.StartReplicationTask");
6437 let encoded = serde_json::to_string(&input).unwrap();
6438 request.set_payload(Some(encoded));
6439
6440 let response = self
6441 .sign_and_dispatch(request, StartReplicationTaskError::from_response)
6442 .await?;
6443 let mut response = response;
6444 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6445 proto::json::ResponsePayload::new(&response)
6446 .deserialize::<StartReplicationTaskResponse, _>()
6447 }
6448
6449 async fn start_replication_task_assessment(
6451 &self,
6452 input: StartReplicationTaskAssessmentMessage,
6453 ) -> Result<
6454 StartReplicationTaskAssessmentResponse,
6455 RusotoError<StartReplicationTaskAssessmentError>,
6456 > {
6457 let mut request = self.new_signed_request("POST", "/");
6458 request.add_header(
6459 "x-amz-target",
6460 "AmazonDMSv20160101.StartReplicationTaskAssessment",
6461 );
6462 let encoded = serde_json::to_string(&input).unwrap();
6463 request.set_payload(Some(encoded));
6464
6465 let response = self
6466 .sign_and_dispatch(request, StartReplicationTaskAssessmentError::from_response)
6467 .await?;
6468 let mut response = response;
6469 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6470 proto::json::ResponsePayload::new(&response)
6471 .deserialize::<StartReplicationTaskAssessmentResponse, _>()
6472 }
6473
6474 async fn stop_replication_task(
6476 &self,
6477 input: StopReplicationTaskMessage,
6478 ) -> Result<StopReplicationTaskResponse, RusotoError<StopReplicationTaskError>> {
6479 let mut request = self.new_signed_request("POST", "/");
6480 request.add_header("x-amz-target", "AmazonDMSv20160101.StopReplicationTask");
6481 let encoded = serde_json::to_string(&input).unwrap();
6482 request.set_payload(Some(encoded));
6483
6484 let response = self
6485 .sign_and_dispatch(request, StopReplicationTaskError::from_response)
6486 .await?;
6487 let mut response = response;
6488 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6489 proto::json::ResponsePayload::new(&response).deserialize::<StopReplicationTaskResponse, _>()
6490 }
6491
6492 async fn test_connection(
6494 &self,
6495 input: TestConnectionMessage,
6496 ) -> Result<TestConnectionResponse, RusotoError<TestConnectionError>> {
6497 let mut request = self.new_signed_request("POST", "/");
6498 request.add_header("x-amz-target", "AmazonDMSv20160101.TestConnection");
6499 let encoded = serde_json::to_string(&input).unwrap();
6500 request.set_payload(Some(encoded));
6501
6502 let response = self
6503 .sign_and_dispatch(request, TestConnectionError::from_response)
6504 .await?;
6505 let mut response = response;
6506 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6507 proto::json::ResponsePayload::new(&response).deserialize::<TestConnectionResponse, _>()
6508 }
6509}