1 - | // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
|
2 - | pub(crate) fn de_event_source_mapping_configuration<'a, I>(
|
3 - | tokens: &mut ::std::iter::Peekable<I>,
|
4 - | _value: &'a [u8],
|
5 - | ) -> ::std::result::Result<Option<crate::types::EventSourceMappingConfiguration>, ::aws_smithy_json::deserialize::error::DeserializeError>
|
6 - | where
|
7 - | I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
|
8 - | {
|
9 - | match tokens.next().transpose()? {
|
10 - | Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
|
11 - | Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
|
12 - | #[allow(unused_mut)]
|
13 - | let mut builder = crate::types::builders::EventSourceMappingConfigurationBuilder::default();
|
14 - | loop {
|
15 - | match tokens.next().transpose()? {
|
16 - | Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
|
17 - | Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
|
18 - | "UUID" => {
|
19 - | builder = builder.set_uuid(
|
20 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
21 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
22 - | .transpose()?,
|
23 - | );
|
24 - | }
|
25 - | "StartingPosition" => {
|
26 - | builder = builder.set_starting_position(
|
27 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
28 - | .map(|s| s.to_unescaped().map(|u| crate::types::EventSourcePosition::from(u.as_ref())))
|
29 - | .transpose()?,
|
30 - | );
|
31 - | }
|
32 - | "StartingPositionTimestamp" => {
|
33 - | builder = builder.set_starting_position_timestamp(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
|
34 - | tokens.next(),
|
35 - | ::aws_smithy_types::date_time::Format::EpochSeconds,
|
36 - | )?);
|
37 - | }
|
38 - | "BatchSize" => {
|
39 - | builder = builder.set_batch_size(
|
40 - | ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
|
41 - | .map(i32::try_from)
|
42 - | .transpose()?,
|
43 - | );
|
44 - | }
|
45 - | "MaximumBatchingWindowInSeconds" => {
|
46 - | builder = builder.set_maximum_batching_window_in_seconds(
|
47 - | ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
|
48 - | .map(i32::try_from)
|
49 - | .transpose()?,
|
50 - | );
|
51 - | }
|
52 - | "ParallelizationFactor" => {
|
53 - | builder = builder.set_parallelization_factor(
|
54 - | ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
|
55 - | .map(i32::try_from)
|
56 - | .transpose()?,
|
57 - | );
|
58 - | }
|
59 - | "EventSourceArn" => {
|
60 - | builder = builder.set_event_source_arn(
|
61 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
62 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
63 - | .transpose()?,
|
64 - | );
|
65 - | }
|
66 - | "FilterCriteria" => {
|
67 - | builder = builder.set_filter_criteria(crate::protocol_serde::shape_filter_criteria::de_filter_criteria(tokens, _value)?);
|
68 - | }
|
69 - | "FunctionArn" => {
|
70 - | builder = builder.set_function_arn(
|
71 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
72 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
73 - | .transpose()?,
|
74 - | );
|
75 - | }
|
76 - | "LastModified" => {
|
77 - | builder = builder.set_last_modified(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
|
78 - | tokens.next(),
|
79 - | ::aws_smithy_types::date_time::Format::EpochSeconds,
|
80 - | )?);
|
81 - | }
|
82 - | "LastProcessingResult" => {
|
83 - | builder = builder.set_last_processing_result(
|
84 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
85 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
86 - | .transpose()?,
|
87 - | );
|
88 - | }
|
89 - | "State" => {
|
90 - | builder = builder.set_state(
|
91 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
92 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
93 - | .transpose()?,
|
94 - | );
|
95 - | }
|
96 - | "StateTransitionReason" => {
|
97 - | builder = builder.set_state_transition_reason(
|
98 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
99 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
100 - | .transpose()?,
|
101 - | );
|
102 - | }
|
103 - | "DestinationConfig" => {
|
104 - | builder = builder
|
105 - | .set_destination_config(crate::protocol_serde::shape_destination_config::de_destination_config(tokens, _value)?);
|
106 - | }
|
107 - | "Topics" => {
|
108 - | builder = builder.set_topics(crate::protocol_serde::shape_topics::de_topics(tokens, _value)?);
|
109 - | }
|
110 - | "Queues" => {
|
111 - | builder = builder.set_queues(crate::protocol_serde::shape_queues::de_queues(tokens, _value)?);
|
112 - | }
|
113 - | "SourceAccessConfigurations" => {
|
114 - | builder = builder.set_source_access_configurations(
|
115 - | crate::protocol_serde::shape_source_access_configurations::de_source_access_configurations(tokens, _value)?,
|
116 - | );
|
117 - | }
|
118 - | "SelfManagedEventSource" => {
|
119 - | builder = builder.set_self_managed_event_source(
|
120 - | crate::protocol_serde::shape_self_managed_event_source::de_self_managed_event_source(tokens, _value)?,
|
121 - | );
|
122 - | }
|
123 - | "MaximumRecordAgeInSeconds" => {
|
124 - | builder = builder.set_maximum_record_age_in_seconds(
|
125 - | ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
|
126 - | .map(i32::try_from)
|
127 - | .transpose()?,
|
128 - | );
|
129 - | }
|
130 - | "BisectBatchOnFunctionError" => {
|
131 - | builder = builder
|
132 - | .set_bisect_batch_on_function_error(::aws_smithy_json::deserialize::token::expect_bool_or_null(tokens.next())?);
|
133 - | }
|
134 - | "MaximumRetryAttempts" => {
|
135 - | builder = builder.set_maximum_retry_attempts(
|
136 - | ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
|
137 - | .map(i32::try_from)
|
138 - | .transpose()?,
|
139 - | );
|
140 - | }
|
141 - | "TumblingWindowInSeconds" => {
|
142 - | builder = builder.set_tumbling_window_in_seconds(
|
143 - | ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
|
144 - | .map(i32::try_from)
|
145 - | .transpose()?,
|
146 - | );
|
147 - | }
|
148 - | "FunctionResponseTypes" => {
|
149 - | builder = builder.set_function_response_types(
|
150 - | crate::protocol_serde::shape_function_response_type_list::de_function_response_type_list(tokens, _value)?,
|
151 - | );
|
152 - | }
|
153 - | "AmazonManagedKafkaEventSourceConfig" => {
|
154 - | builder = builder.set_amazon_managed_kafka_event_source_config(
|
155 - | crate::protocol_serde::shape_amazon_managed_kafka_event_source_config::de_amazon_managed_kafka_event_source_config(
|
156 - | tokens, _value,
|
157 - | )?,
|
158 - | );
|
159 - | }
|
160 - | "SelfManagedKafkaEventSourceConfig" => {
|
161 - | builder = builder.set_self_managed_kafka_event_source_config(
|
162 - | crate::protocol_serde::shape_self_managed_kafka_event_source_config::de_self_managed_kafka_event_source_config(
|
163 - | tokens, _value,
|
164 - | )?,
|
165 - | );
|
166 - | }
|
167 - | "ScalingConfig" => {
|
168 - | builder = builder.set_scaling_config(crate::protocol_serde::shape_scaling_config::de_scaling_config(tokens, _value)?);
|
169 - | }
|
170 - | "DocumentDBEventSourceConfig" => {
|
171 - | builder = builder.set_document_db_event_source_config(
|
172 - | crate::protocol_serde::shape_document_db_event_source_config::de_document_db_event_source_config(tokens, _value)?,
|
173 - | );
|
174 - | }
|
175 - | "KMSKeyArn" => {
|
176 - | builder = builder.set_kms_key_arn(
|
177 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
178 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
179 - | .transpose()?,
|
180 - | );
|
181 - | }
|
182 - | "FilterCriteriaError" => {
|
183 - | builder = builder.set_filter_criteria_error(
|
184 - | crate::protocol_serde::shape_filter_criteria_error::de_filter_criteria_error(tokens, _value)?,
|
185 - | );
|
186 - | }
|
187 - | "EventSourceMappingArn" => {
|
188 - | builder = builder.set_event_source_mapping_arn(
|
189 - | ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
|
190 - | .map(|s| s.to_unescaped().map(|u| u.into_owned()))
|
191 - | .transpose()?,
|
192 - | );
|
193 - | }
|
194 - | "MetricsConfig" => {
|
195 - | builder = builder.set_metrics_config(
|
196 - | crate::protocol_serde::shape_event_source_mapping_metrics_config::de_event_source_mapping_metrics_config(
|
197 - | tokens, _value,
|
198 - | )?,
|
199 - | );
|
200 - | }
|
201 - | "ProvisionedPollerConfig" => {
|
202 - | builder = builder.set_provisioned_poller_config(
|
203 - | crate::protocol_serde::shape_provisioned_poller_config::de_provisioned_poller_config(tokens, _value)?,
|
204 - | );
|
205 - | }
|
206 - | _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
|
207 - | },
|
208 - | other => {
|
209 - | return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
|
210 - | "expected object key or end object, found: {other:?}"
|
211 - | )))
|
212 - | }
|
213 - | }
|
214 - | }
|
215 - | Ok(Some(builder.build()))
|
216 - | }
|
217 - | _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
|
218 - | "expected start object or null",
|
219 - | )),
|
220 - | }
|
221 - | }
|