pub(crate) fn de_endpoint<'a, I>(
tokens: &mut ::std::iter::Peekable<I>,
_value: &'a [u8],
) -> ::std::result::Result<Option<crate::types::Endpoint>, ::aws_smithy_json::deserialize::error::DeserializeError>
where
I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
{
match tokens.next().transpose()? {
Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::types::builders::EndpointBuilder::default();
loop {
match tokens.next().transpose()? {
Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
"EndpointIdentifier" => {
builder = builder.set_endpoint_identifier(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"EndpointType" => {
builder = builder.set_endpoint_type(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| crate::types::ReplicationEndpointTypeValue::from(u.as_ref())))
.transpose()?,
);
}
"EngineName" => {
builder = builder.set_engine_name(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"EngineDisplayName" => {
builder = builder.set_engine_display_name(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"Username" => {
builder = builder.set_username(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"ServerName" => {
builder = builder.set_server_name(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"Port" => {
builder = builder.set_port(
::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
.map(i32::try_from)
.transpose()?,
);
}
"DatabaseName" => {
builder = builder.set_database_name(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"ExtraConnectionAttributes" => {
builder = builder.set_extra_connection_attributes(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"Status" => {
builder = builder.set_status(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"KmsKeyId" => {
builder = builder.set_kms_key_id(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"EndpointArn" => {
builder = builder.set_endpoint_arn(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"CertificateArn" => {
builder = builder.set_certificate_arn(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"SslMode" => {
builder = builder.set_ssl_mode(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| crate::types::DmsSslModeValue::from(u.as_ref())))
.transpose()?,
);
}
"ServiceAccessRoleArn" => {
builder = builder.set_service_access_role_arn(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"ExternalTableDefinition" => {
builder = builder.set_external_table_definition(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"ExternalId" => {
builder = builder.set_external_id(
::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"IsReadOnly" => {
builder = builder.set_is_read_only(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
}
"DynamoDbSettings" => {
builder = builder
.set_dynamo_db_settings(crate::protocol_serde::shape_dynamo_db_settings::de_dynamo_db_settings(tokens, _value)?);
}
"S3Settings" => {
builder = builder.set_s3_settings(crate::protocol_serde::shape_s3_settings::de_s3_settings(tokens, _value)?);
}
"DmsTransferSettings" => {
builder = builder.set_dms_transfer_settings(
crate::protocol_serde::shape_dms_transfer_settings::de_dms_transfer_settings(tokens, _value)?,
);
}
"MongoDbSettings" => {
builder =
builder.set_mongo_db_settings(crate::protocol_serde::shape_mongo_db_settings::de_mongo_db_settings(tokens, _value)?);
}
"KinesisSettings" => {
builder =
builder.set_kinesis_settings(crate::protocol_serde::shape_kinesis_settings::de_kinesis_settings(tokens, _value)?);
}
"KafkaSettings" => {
builder = builder.set_kafka_settings(crate::protocol_serde::shape_kafka_settings::de_kafka_settings(tokens, _value)?);
}
"ElasticsearchSettings" => {
builder = builder.set_elasticsearch_settings(
crate::protocol_serde::shape_elasticsearch_settings::de_elasticsearch_settings(tokens, _value)?,
);
}
"NeptuneSettings" => {
builder =
builder.set_neptune_settings(crate::protocol_serde::shape_neptune_settings::de_neptune_settings(tokens, _value)?);
}
"RedshiftSettings" => {
builder =
builder.set_redshift_settings(crate::protocol_serde::shape_redshift_settings::de_redshift_settings(tokens, _value)?);
}
"PostgreSQLSettings" => {
builder = builder.set_postgre_sql_settings(crate::protocol_serde::shape_postgre_sql_settings::de_postgre_sql_settings(
tokens, _value,
)?);
}
"MySQLSettings" => {
builder = builder.set_my_sql_settings(crate::protocol_serde::shape_my_sql_settings::de_my_sql_settings(tokens, _value)?);
}
"OracleSettings" => {
builder = builder.set_oracle_settings(crate::protocol_serde::shape_oracle_settings::de_oracle_settings(tokens, _value)?);
}
"SybaseSettings" => {
builder = builder.set_sybase_settings(crate::protocol_serde::shape_sybase_settings::de_sybase_settings(tokens, _value)?);
}
"MicrosoftSQLServerSettings" => {
builder = builder.set_microsoft_sql_server_settings(
crate::protocol_serde::shape_microsoft_sql_server_settings::de_microsoft_sql_server_settings(tokens, _value)?,
);
}
"IBMDb2Settings" => {
builder =
builder.set_ibm_db2_settings(crate::protocol_serde::shape_ibm_db2_settings::de_ibm_db2_settings(tokens, _value)?);
}
"DocDbSettings" => {
builder = builder.set_doc_db_settings(crate::protocol_serde::shape_doc_db_settings::de_doc_db_settings(tokens, _value)?);
}
"RedisSettings" => {
builder = builder.set_redis_settings(crate::protocol_serde::shape_redis_settings::de_redis_settings(tokens, _value)?);
}
"GcpMySQLSettings" => {
builder = builder
.set_gcp_my_sql_settings(crate::protocol_serde::shape_gcp_my_sql_settings::de_gcp_my_sql_settings(tokens, _value)?);
}
"TimestreamSettings" => {
builder = builder
.set_timestream_settings(crate::protocol_serde::shape_timestream_settings::de_timestream_settings(tokens, _value)?);
}
"LakehouseSettings" => {
builder = builder
.set_lakehouse_settings(crate::protocol_serde::shape_lakehouse_settings::de_lakehouse_settings(tokens, _value)?);
}
_ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
},
other => {
return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {other:?}"
)))
}
}
}
Ok(Some(builder.build()))
}
_ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
)),
}
}