aws_sdk_redshift/protocol_serde/
shape_delete_endpoint_access.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2#[allow(clippy::unnecessary_wraps)]
3pub fn de_delete_endpoint_access_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::delete_endpoint_access::DeleteEndpointAccessOutput,
9    crate::operation::delete_endpoint_access::DeleteEndpointAccessError,
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::delete_endpoint_access::DeleteEndpointAccessError::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::delete_endpoint_access::DeleteEndpointAccessError::unhandled(generic)),
19    };
20
21    let _error_message = generic.message().map(|msg| msg.to_owned());
22    Err(match error_code {
23        "ClusterNotFound" => crate::operation::delete_endpoint_access::DeleteEndpointAccessError::ClusterNotFoundFault({
24            #[allow(unused_mut)]
25            let mut tmp = {
26                #[allow(unused_mut)]
27                let mut output = crate::types::error::builders::ClusterNotFoundFaultBuilder::default();
28                output = crate::protocol_serde::shape_cluster_not_found_fault::de_cluster_not_found_fault_xml_err(_response_body, output)
29                    .map_err(crate::operation::delete_endpoint_access::DeleteEndpointAccessError::unhandled)?;
30                let output = output.meta(generic);
31                output.build()
32            };
33            if tmp.message.is_none() {
34                tmp.message = _error_message;
35            }
36            tmp
37        }),
38        "EndpointNotFound" => crate::operation::delete_endpoint_access::DeleteEndpointAccessError::EndpointNotFoundFault({
39            #[allow(unused_mut)]
40            let mut tmp = {
41                #[allow(unused_mut)]
42                let mut output = crate::types::error::builders::EndpointNotFoundFaultBuilder::default();
43                output = crate::protocol_serde::shape_endpoint_not_found_fault::de_endpoint_not_found_fault_xml_err(_response_body, output)
44                    .map_err(crate::operation::delete_endpoint_access::DeleteEndpointAccessError::unhandled)?;
45                let output = output.meta(generic);
46                output.build()
47            };
48            if tmp.message.is_none() {
49                tmp.message = _error_message;
50            }
51            tmp
52        }),
53        "InvalidClusterSecurityGroupState" => {
54            crate::operation::delete_endpoint_access::DeleteEndpointAccessError::InvalidClusterSecurityGroupStateFault({
55                #[allow(unused_mut)]
56                let mut tmp = {
57                    #[allow(unused_mut)]
58                    let mut output = crate::types::error::builders::InvalidClusterSecurityGroupStateFaultBuilder::default();
59                    output = crate::protocol_serde::shape_invalid_cluster_security_group_state_fault::de_invalid_cluster_security_group_state_fault_xml_err(_response_body, output).map_err(crate::operation::delete_endpoint_access::DeleteEndpointAccessError::unhandled)?;
60                    let output = output.meta(generic);
61                    output.build()
62                };
63                if tmp.message.is_none() {
64                    tmp.message = _error_message;
65                }
66                tmp
67            })
68        }
69        "InvalidClusterState" => crate::operation::delete_endpoint_access::DeleteEndpointAccessError::InvalidClusterStateFault({
70            #[allow(unused_mut)]
71            let mut tmp = {
72                #[allow(unused_mut)]
73                let mut output = crate::types::error::builders::InvalidClusterStateFaultBuilder::default();
74                output = crate::protocol_serde::shape_invalid_cluster_state_fault::de_invalid_cluster_state_fault_xml_err(_response_body, output)
75                    .map_err(crate::operation::delete_endpoint_access::DeleteEndpointAccessError::unhandled)?;
76                let output = output.meta(generic);
77                output.build()
78            };
79            if tmp.message.is_none() {
80                tmp.message = _error_message;
81            }
82            tmp
83        }),
84        "InvalidEndpointState" => crate::operation::delete_endpoint_access::DeleteEndpointAccessError::InvalidEndpointStateFault({
85            #[allow(unused_mut)]
86            let mut tmp = {
87                #[allow(unused_mut)]
88                let mut output = crate::types::error::builders::InvalidEndpointStateFaultBuilder::default();
89                output = crate::protocol_serde::shape_invalid_endpoint_state_fault::de_invalid_endpoint_state_fault_xml_err(_response_body, output)
90                    .map_err(crate::operation::delete_endpoint_access::DeleteEndpointAccessError::unhandled)?;
91                let output = output.meta(generic);
92                output.build()
93            };
94            if tmp.message.is_none() {
95                tmp.message = _error_message;
96            }
97            tmp
98        }),
99        _ => crate::operation::delete_endpoint_access::DeleteEndpointAccessError::generic(generic),
100    })
101}
102
103#[allow(clippy::unnecessary_wraps)]
104pub fn de_delete_endpoint_access_http_response(
105    _response_status: u16,
106    _response_headers: &::aws_smithy_runtime_api::http::Headers,
107    _response_body: &[u8],
108) -> std::result::Result<
109    crate::operation::delete_endpoint_access::DeleteEndpointAccessOutput,
110    crate::operation::delete_endpoint_access::DeleteEndpointAccessError,
111> {
112    Ok({
113        #[allow(unused_mut)]
114        let mut output = crate::operation::delete_endpoint_access::builders::DeleteEndpointAccessOutputBuilder::default();
115        output = crate::protocol_serde::shape_delete_endpoint_access::de_delete_endpoint_access(_response_body, output)
116            .map_err(crate::operation::delete_endpoint_access::DeleteEndpointAccessError::unhandled)?;
117        output._set_request_id(::aws_types::request_id::RequestId::request_id(_response_headers).map(str::to_string));
118        output.build()
119    })
120}
121
122#[allow(unused_mut)]
123pub fn de_delete_endpoint_access(
124    inp: &[u8],
125    mut builder: crate::operation::delete_endpoint_access::builders::DeleteEndpointAccessOutputBuilder,
126) -> std::result::Result<
127    crate::operation::delete_endpoint_access::builders::DeleteEndpointAccessOutputBuilder,
128    ::aws_smithy_xml::decode::XmlDecodeError,
129> {
130    let mut doc = ::aws_smithy_xml::decode::Document::try_from(inp)?;
131
132    #[allow(unused_mut)]
133    let mut decoder = doc.root_element()?;
134    #[allow(unused_variables)]
135    let start_el = decoder.start_el();
136    if !(start_el.matches("DeleteEndpointAccessResponse")) {
137        return Err(::aws_smithy_xml::decode::XmlDecodeError::custom(format!(
138            "invalid root, expected DeleteEndpointAccessResponse got {:?}",
139            start_el
140        )));
141    }
142    if let Some(mut result_tag) = decoder.next_tag() {
143        let start_el = result_tag.start_el();
144        if !(start_el.matches("DeleteEndpointAccessResult")) {
145            return Err(::aws_smithy_xml::decode::XmlDecodeError::custom(format!(
146                "invalid result, expected DeleteEndpointAccessResult got {:?}",
147                start_el
148            )));
149        }
150        while let Some(mut tag) = result_tag.next_tag() {
151            match tag.start_el() {
152            s if s.matches("ClusterIdentifier") /* ClusterIdentifier com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$ClusterIdentifier */ =>  {
153                let var_1 =
154                    Some(
155                        Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
156                            ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
157                            .into()
158                        )
159                        ?
160                    )
161                ;
162                builder = builder.set_cluster_identifier(var_1);
163            }
164            ,
165            s if s.matches("ResourceOwner") /* ResourceOwner com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$ResourceOwner */ =>  {
166                let var_2 =
167                    Some(
168                        Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
169                            ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
170                            .into()
171                        )
172                        ?
173                    )
174                ;
175                builder = builder.set_resource_owner(var_2);
176            }
177            ,
178            s if s.matches("SubnetGroupName") /* SubnetGroupName com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$SubnetGroupName */ =>  {
179                let var_3 =
180                    Some(
181                        Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
182                            ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
183                            .into()
184                        )
185                        ?
186                    )
187                ;
188                builder = builder.set_subnet_group_name(var_3);
189            }
190            ,
191            s if s.matches("EndpointStatus") /* EndpointStatus com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$EndpointStatus */ =>  {
192                let var_4 =
193                    Some(
194                        Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
195                            ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
196                            .into()
197                        )
198                        ?
199                    )
200                ;
201                builder = builder.set_endpoint_status(var_4);
202            }
203            ,
204            s if s.matches("EndpointName") /* EndpointName com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$EndpointName */ =>  {
205                let var_5 =
206                    Some(
207                        Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
208                            ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
209                            .into()
210                        )
211                        ?
212                    )
213                ;
214                builder = builder.set_endpoint_name(var_5);
215            }
216            ,
217            s if s.matches("EndpointCreateTime") /* EndpointCreateTime com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$EndpointCreateTime */ =>  {
218                let var_6 =
219                    Some(
220                        ::aws_smithy_types::DateTime::from_str(
221                            ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
222                            , ::aws_smithy_types::date_time::Format::DateTimeWithOffset
223                        )
224                        .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (timestamp: `com.amazonaws.redshift#TStamp`)"))
225                        ?
226                    )
227                ;
228                builder = builder.set_endpoint_create_time(var_6);
229            }
230            ,
231            s if s.matches("Port") /* Port com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$Port */ =>  {
232                let var_7 =
233                    Some(
234                         {
235                            <i32 as ::aws_smithy_types::primitive::Parse>::parse_smithy_primitive(
236                                ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
237                            )
238                            .map_err(|_|::aws_smithy_xml::decode::XmlDecodeError::custom("expected (integer: `com.amazonaws.redshift#Integer`)"))
239                        }
240                        ?
241                    )
242                ;
243                builder = builder.set_port(var_7);
244            }
245            ,
246            s if s.matches("Address") /* Address com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$Address */ =>  {
247                let var_8 =
248                    Some(
249                        Result::<::std::string::String, ::aws_smithy_xml::decode::XmlDecodeError>::Ok(
250                            ::aws_smithy_xml::decode::try_data(&mut tag)?.as_ref()
251                            .into()
252                        )
253                        ?
254                    )
255                ;
256                builder = builder.set_address(var_8);
257            }
258            ,
259            s if s.matches("VpcSecurityGroups") /* VpcSecurityGroups com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$VpcSecurityGroups */ =>  {
260                let var_9 =
261                    Some(
262                        crate::protocol_serde::shape_vpc_security_group_membership_list::de_vpc_security_group_membership_list(&mut tag)
263                        ?
264                    )
265                ;
266                builder = builder.set_vpc_security_groups(var_9);
267            }
268            ,
269            s if s.matches("VpcEndpoint") /* VpcEndpoint com.amazonaws.redshift.synthetic#DeleteEndpointAccessOutput$VpcEndpoint */ =>  {
270                let var_10 =
271                    Some(
272                        crate::protocol_serde::shape_vpc_endpoint::de_vpc_endpoint(&mut tag)
273                        ?
274                    )
275                ;
276                builder = builder.set_vpc_endpoint(var_10);
277            }
278            ,
279            _ => {}
280        }
281        }
282    } else {
283        return Err(::aws_smithy_xml::decode::XmlDecodeError::custom(
284            "expected DeleteEndpointAccessResult tag",
285        ));
286    };
287    Ok(builder)
288}
aws_sdk_redshift/protocol_serde/shape_delete_endpoint_access.rs

aws_sdk_redshift/protocol_serde/
shape_delete_endpoint_access.rs
