aws_sdk_databasemigration/protocol_serde/
shape_create_endpoint_input.rs1pub fn ser_create_endpoint_input_input(
3 object: &mut ::aws_smithy_json::serialize::JsonObjectWriter,
4 input: &crate::operation::create_endpoint::CreateEndpointInput,
5) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::SerializationError> {
6 if let Some(var_1) = &input.endpoint_identifier {
7 object.key("EndpointIdentifier").string(var_1.as_str());
8 }
9 if let Some(var_2) = &input.endpoint_type {
10 object.key("EndpointType").string(var_2.as_str());
11 }
12 if let Some(var_3) = &input.engine_name {
13 object.key("EngineName").string(var_3.as_str());
14 }
15 if let Some(var_4) = &input.username {
16 object.key("Username").string(var_4.as_str());
17 }
18 if let Some(var_5) = &input.password {
19 object.key("Password").string(var_5.as_str());
20 }
21 if let Some(var_6) = &input.server_name {
22 object.key("ServerName").string(var_6.as_str());
23 }
24 if let Some(var_7) = &input.port {
25 object.key("Port").number(
26 #[allow(clippy::useless_conversion)]
27 ::aws_smithy_types::Number::NegInt((*var_7).into()),
28 );
29 }
30 if let Some(var_8) = &input.database_name {
31 object.key("DatabaseName").string(var_8.as_str());
32 }
33 if let Some(var_9) = &input.extra_connection_attributes {
34 object.key("ExtraConnectionAttributes").string(var_9.as_str());
35 }
36 if let Some(var_10) = &input.kms_key_id {
37 object.key("KmsKeyId").string(var_10.as_str());
38 }
39 if let Some(var_11) = &input.tags {
40 let mut array_12 = object.key("Tags").start_array();
41 for item_13 in var_11 {
42 {
43 #[allow(unused_mut)]
44 let mut object_14 = array_12.value().start_object();
45 crate::protocol_serde::shape_tag::ser_tag(&mut object_14, item_13)?;
46 object_14.finish();
47 }
48 }
49 array_12.finish();
50 }
51 if let Some(var_15) = &input.certificate_arn {
52 object.key("CertificateArn").string(var_15.as_str());
53 }
54 if let Some(var_16) = &input.ssl_mode {
55 object.key("SslMode").string(var_16.as_str());
56 }
57 if let Some(var_17) = &input.service_access_role_arn {
58 object.key("ServiceAccessRoleArn").string(var_17.as_str());
59 }
60 if let Some(var_18) = &input.external_table_definition {
61 object.key("ExternalTableDefinition").string(var_18.as_str());
62 }
63 if let Some(var_19) = &input.dynamo_db_settings {
64 #[allow(unused_mut)]
65 let mut object_20 = object.key("DynamoDbSettings").start_object();
66 crate::protocol_serde::shape_dynamo_db_settings::ser_dynamo_db_settings(&mut object_20, var_19)?;
67 object_20.finish();
68 }
69 if let Some(var_21) = &input.s3_settings {
70 #[allow(unused_mut)]
71 let mut object_22 = object.key("S3Settings").start_object();
72 crate::protocol_serde::shape_s3_settings::ser_s3_settings(&mut object_22, var_21)?;
73 object_22.finish();
74 }
75 if let Some(var_23) = &input.dms_transfer_settings {
76 #[allow(unused_mut)]
77 let mut object_24 = object.key("DmsTransferSettings").start_object();
78 crate::protocol_serde::shape_dms_transfer_settings::ser_dms_transfer_settings(&mut object_24, var_23)?;
79 object_24.finish();
80 }
81 if let Some(var_25) = &input.mongo_db_settings {
82 #[allow(unused_mut)]
83 let mut object_26 = object.key("MongoDbSettings").start_object();
84 crate::protocol_serde::shape_mongo_db_settings::ser_mongo_db_settings(&mut object_26, var_25)?;
85 object_26.finish();
86 }
87 if let Some(var_27) = &input.kinesis_settings {
88 #[allow(unused_mut)]
89 let mut object_28 = object.key("KinesisSettings").start_object();
90 crate::protocol_serde::shape_kinesis_settings::ser_kinesis_settings(&mut object_28, var_27)?;
91 object_28.finish();
92 }
93 if let Some(var_29) = &input.kafka_settings {
94 #[allow(unused_mut)]
95 let mut object_30 = object.key("KafkaSettings").start_object();
96 crate::protocol_serde::shape_kafka_settings::ser_kafka_settings(&mut object_30, var_29)?;
97 object_30.finish();
98 }
99 if let Some(var_31) = &input.elasticsearch_settings {
100 #[allow(unused_mut)]
101 let mut object_32 = object.key("ElasticsearchSettings").start_object();
102 crate::protocol_serde::shape_elasticsearch_settings::ser_elasticsearch_settings(&mut object_32, var_31)?;
103 object_32.finish();
104 }
105 if let Some(var_33) = &input.neptune_settings {
106 #[allow(unused_mut)]
107 let mut object_34 = object.key("NeptuneSettings").start_object();
108 crate::protocol_serde::shape_neptune_settings::ser_neptune_settings(&mut object_34, var_33)?;
109 object_34.finish();
110 }
111 if let Some(var_35) = &input.redshift_settings {
112 #[allow(unused_mut)]
113 let mut object_36 = object.key("RedshiftSettings").start_object();
114 crate::protocol_serde::shape_redshift_settings::ser_redshift_settings(&mut object_36, var_35)?;
115 object_36.finish();
116 }
117 if let Some(var_37) = &input.postgre_sql_settings {
118 #[allow(unused_mut)]
119 let mut object_38 = object.key("PostgreSQLSettings").start_object();
120 crate::protocol_serde::shape_postgre_sql_settings::ser_postgre_sql_settings(&mut object_38, var_37)?;
121 object_38.finish();
122 }
123 if let Some(var_39) = &input.my_sql_settings {
124 #[allow(unused_mut)]
125 let mut object_40 = object.key("MySQLSettings").start_object();
126 crate::protocol_serde::shape_my_sql_settings::ser_my_sql_settings(&mut object_40, var_39)?;
127 object_40.finish();
128 }
129 if let Some(var_41) = &input.oracle_settings {
130 #[allow(unused_mut)]
131 let mut object_42 = object.key("OracleSettings").start_object();
132 crate::protocol_serde::shape_oracle_settings::ser_oracle_settings(&mut object_42, var_41)?;
133 object_42.finish();
134 }
135 if let Some(var_43) = &input.sybase_settings {
136 #[allow(unused_mut)]
137 let mut object_44 = object.key("SybaseSettings").start_object();
138 crate::protocol_serde::shape_sybase_settings::ser_sybase_settings(&mut object_44, var_43)?;
139 object_44.finish();
140 }
141 if let Some(var_45) = &input.microsoft_sql_server_settings {
142 #[allow(unused_mut)]
143 let mut object_46 = object.key("MicrosoftSQLServerSettings").start_object();
144 crate::protocol_serde::shape_microsoft_sql_server_settings::ser_microsoft_sql_server_settings(&mut object_46, var_45)?;
145 object_46.finish();
146 }
147 if let Some(var_47) = &input.ibm_db2_settings {
148 #[allow(unused_mut)]
149 let mut object_48 = object.key("IBMDb2Settings").start_object();
150 crate::protocol_serde::shape_ibm_db2_settings::ser_ibm_db2_settings(&mut object_48, var_47)?;
151 object_48.finish();
152 }
153 if let Some(var_49) = &input.resource_identifier {
154 object.key("ResourceIdentifier").string(var_49.as_str());
155 }
156 if let Some(var_50) = &input.doc_db_settings {
157 #[allow(unused_mut)]
158 let mut object_51 = object.key("DocDbSettings").start_object();
159 crate::protocol_serde::shape_doc_db_settings::ser_doc_db_settings(&mut object_51, var_50)?;
160 object_51.finish();
161 }
162 if let Some(var_52) = &input.redis_settings {
163 #[allow(unused_mut)]
164 let mut object_53 = object.key("RedisSettings").start_object();
165 crate::protocol_serde::shape_redis_settings::ser_redis_settings(&mut object_53, var_52)?;
166 object_53.finish();
167 }
168 if let Some(var_54) = &input.gcp_my_sql_settings {
169 #[allow(unused_mut)]
170 let mut object_55 = object.key("GcpMySQLSettings").start_object();
171 crate::protocol_serde::shape_gcp_my_sql_settings::ser_gcp_my_sql_settings(&mut object_55, var_54)?;
172 object_55.finish();
173 }
174 if let Some(var_56) = &input.timestream_settings {
175 #[allow(unused_mut)]
176 let mut object_57 = object.key("TimestreamSettings").start_object();
177 crate::protocol_serde::shape_timestream_settings::ser_timestream_settings(&mut object_57, var_56)?;
178 object_57.finish();
179 }
180 Ok(())
181}