aws_sdk_kinesisanalytics/protocol_serde/
shape_add_application_output.rs1#[allow(clippy::unnecessary_wraps)]
3pub fn de_add_application_output_http_error(
4 _response_status: u16,
5 _response_headers: &::aws_smithy_runtime_api::http::Headers,
6 _response_body: &[u8],
7) -> std::result::Result<
8 crate::operation::add_application_output::AddApplicationOutputOutput,
9 crate::operation::add_application_output::AddApplicationOutputError,
10> {
11 #[allow(unused_mut)]
12 let mut generic_builder = crate::protocol_serde::parse_http_error_metadata(_response_status, _response_headers, _response_body)
13 .map_err(crate::operation::add_application_output::AddApplicationOutputError::unhandled)?;
14 generic_builder = ::aws_types::request_id::apply_request_id(generic_builder, _response_headers);
15 let generic = generic_builder.build();
16 let error_code = match generic.code() {
17 Some(code) => code,
18 None => return Err(crate::operation::add_application_output::AddApplicationOutputError::unhandled(generic)),
19 };
20
21 let _error_message = generic.message().map(|msg| msg.to_owned());
22 Err(match error_code {
23 "ConcurrentModificationException" => crate::operation::add_application_output::AddApplicationOutputError::ConcurrentModificationException({
24 #[allow(unused_mut)]
25 let mut tmp = {
26 #[allow(unused_mut)]
27 let mut output = crate::types::error::builders::ConcurrentModificationExceptionBuilder::default();
28 output = crate::protocol_serde::shape_concurrent_modification_exception::de_concurrent_modification_exception_json_err(
29 _response_body,
30 output,
31 )
32 .map_err(crate::operation::add_application_output::AddApplicationOutputError::unhandled)?;
33 let output = output.meta(generic);
34 output.build()
35 };
36 if tmp.message.is_none() {
37 tmp.message = _error_message;
38 }
39 tmp
40 }),
41 "InvalidArgumentException" => crate::operation::add_application_output::AddApplicationOutputError::InvalidArgumentException({
42 #[allow(unused_mut)]
43 let mut tmp = {
44 #[allow(unused_mut)]
45 let mut output = crate::types::error::builders::InvalidArgumentExceptionBuilder::default();
46 output = crate::protocol_serde::shape_invalid_argument_exception::de_invalid_argument_exception_json_err(_response_body, output)
47 .map_err(crate::operation::add_application_output::AddApplicationOutputError::unhandled)?;
48 let output = output.meta(generic);
49 output.build()
50 };
51 if tmp.message.is_none() {
52 tmp.message = _error_message;
53 }
54 tmp
55 }),
56 "ResourceInUseException" => crate::operation::add_application_output::AddApplicationOutputError::ResourceInUseException({
57 #[allow(unused_mut)]
58 let mut tmp = {
59 #[allow(unused_mut)]
60 let mut output = crate::types::error::builders::ResourceInUseExceptionBuilder::default();
61 output = crate::protocol_serde::shape_resource_in_use_exception::de_resource_in_use_exception_json_err(_response_body, output)
62 .map_err(crate::operation::add_application_output::AddApplicationOutputError::unhandled)?;
63 let output = output.meta(generic);
64 output.build()
65 };
66 if tmp.message.is_none() {
67 tmp.message = _error_message;
68 }
69 tmp
70 }),
71 "ResourceNotFoundException" => crate::operation::add_application_output::AddApplicationOutputError::ResourceNotFoundException({
72 #[allow(unused_mut)]
73 let mut tmp = {
74 #[allow(unused_mut)]
75 let mut output = crate::types::error::builders::ResourceNotFoundExceptionBuilder::default();
76 output = crate::protocol_serde::shape_resource_not_found_exception::de_resource_not_found_exception_json_err(_response_body, output)
77 .map_err(crate::operation::add_application_output::AddApplicationOutputError::unhandled)?;
78 let output = output.meta(generic);
79 output.build()
80 };
81 if tmp.message.is_none() {
82 tmp.message = _error_message;
83 }
84 tmp
85 }),
86 "UnsupportedOperationException" => crate::operation::add_application_output::AddApplicationOutputError::UnsupportedOperationException({
87 #[allow(unused_mut)]
88 let mut tmp = {
89 #[allow(unused_mut)]
90 let mut output = crate::types::error::builders::UnsupportedOperationExceptionBuilder::default();
91 output =
92 crate::protocol_serde::shape_unsupported_operation_exception::de_unsupported_operation_exception_json_err(_response_body, output)
93 .map_err(crate::operation::add_application_output::AddApplicationOutputError::unhandled)?;
94 let output = output.meta(generic);
95 output.build()
96 };
97 if tmp.message.is_none() {
98 tmp.message = _error_message;
99 }
100 tmp
101 }),
102 _ => crate::operation::add_application_output::AddApplicationOutputError::generic(generic),
103 })
104}
105
106#[allow(clippy::unnecessary_wraps)]
107pub fn de_add_application_output_http_response(
108 _response_status: u16,
109 _response_headers: &::aws_smithy_runtime_api::http::Headers,
110 _response_body: &[u8],
111) -> std::result::Result<
112 crate::operation::add_application_output::AddApplicationOutputOutput,
113 crate::operation::add_application_output::AddApplicationOutputError,
114> {
115 Ok({
116 #[allow(unused_mut)]
117 let mut output = crate::operation::add_application_output::builders::AddApplicationOutputOutputBuilder::default();
118 output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
119 output.build()
120 })
121}
122
123pub fn ser_add_application_output_input(
124 input: &crate::operation::add_application_output::AddApplicationOutputInput,
125) -> ::std::result::Result<::aws_smithy_types::body::SdkBody, ::aws_smithy_types::error::operation::SerializationError> {
126 let mut out = String::new();
127 let mut object = ::aws_smithy_json::serialize::JsonObjectWriter::new(&mut out);
128 crate::protocol_serde::shape_add_application_output_input::ser_add_application_output_input_input(&mut object, input)?;
129 object.finish();
130 Ok(::aws_smithy_types::body::SdkBody::from(out))
131}