aws_sdk_mediaconvert/protocol_serde/
shape_queue.rs1pub(crate) fn de_queue<'a, I>(
3 tokens: &mut ::std::iter::Peekable<I>,
4) -> ::std::result::Result<Option<crate::types::Queue>, ::aws_smithy_json::deserialize::error::DeserializeError>
5where
6 I: Iterator<Item = Result<::aws_smithy_json::deserialize::Token<'a>, ::aws_smithy_json::deserialize::error::DeserializeError>>,
7{
8 match tokens.next().transpose()? {
9 Some(::aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
10 Some(::aws_smithy_json::deserialize::Token::StartObject { .. }) => {
11 #[allow(unused_mut)]
12 let mut builder = crate::types::builders::QueueBuilder::default();
13 loop {
14 match tokens.next().transpose()? {
15 Some(::aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
16 Some(::aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => match key.to_unescaped()?.as_ref() {
17 "arn" => {
18 builder = builder.set_arn(
19 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
20 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
21 .transpose()?,
22 );
23 }
24 "concurrentJobs" => {
25 builder = builder.set_concurrent_jobs(
26 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
27 .map(i32::try_from)
28 .transpose()?,
29 );
30 }
31 "createdAt" => {
32 builder = builder.set_created_at(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
33 tokens.next(),
34 ::aws_smithy_types::date_time::Format::EpochSeconds,
35 )?);
36 }
37 "description" => {
38 builder = builder.set_description(
39 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
40 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
41 .transpose()?,
42 );
43 }
44 "lastUpdated" => {
45 builder = builder.set_last_updated(::aws_smithy_json::deserialize::token::expect_timestamp_or_null(
46 tokens.next(),
47 ::aws_smithy_types::date_time::Format::EpochSeconds,
48 )?);
49 }
50 "name" => {
51 builder = builder.set_name(
52 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
53 .map(|s| s.to_unescaped().map(|u| u.into_owned()))
54 .transpose()?,
55 );
56 }
57 "pricingPlan" => {
58 builder = builder.set_pricing_plan(
59 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
60 .map(|s| s.to_unescaped().map(|u| crate::types::PricingPlan::from(u.as_ref())))
61 .transpose()?,
62 );
63 }
64 "progressingJobsCount" => {
65 builder = builder.set_progressing_jobs_count(
66 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
67 .map(i32::try_from)
68 .transpose()?,
69 );
70 }
71 "reservationPlan" => {
72 builder = builder.set_reservation_plan(crate::protocol_serde::shape_reservation_plan::de_reservation_plan(tokens)?);
73 }
74 "serviceOverrides" => {
75 builder = builder.set_service_overrides(
76 crate::protocol_serde::shape_list_of_service_override::de_list_of_service_override(tokens)?,
77 );
78 }
79 "status" => {
80 builder = builder.set_status(
81 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
82 .map(|s| s.to_unescaped().map(|u| crate::types::QueueStatus::from(u.as_ref())))
83 .transpose()?,
84 );
85 }
86 "submittedJobsCount" => {
87 builder = builder.set_submitted_jobs_count(
88 ::aws_smithy_json::deserialize::token::expect_number_or_null(tokens.next())?
89 .map(i32::try_from)
90 .transpose()?,
91 );
92 }
93 "type" => {
94 builder = builder.set_type(
95 ::aws_smithy_json::deserialize::token::expect_string_or_null(tokens.next())?
96 .map(|s| s.to_unescaped().map(|u| crate::types::Type::from(u.as_ref())))
97 .transpose()?,
98 );
99 }
100 _ => ::aws_smithy_json::deserialize::token::skip_value(tokens)?,
101 },
102 other => {
103 return Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
104 "expected object key or end object, found: {other:?}"
105 )))
106 }
107 }
108 }
109 Ok(Some(crate::serde_util::queue_correct_errors(builder).build()))
110 }
111 _ => Err(::aws_smithy_json::deserialize::error::DeserializeError::custom(
112 "expected start object or null",
113 )),
114 }
115}