aws_sdk_observabilityadmin/operation/
list_s3_table_integrations.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `ListS3TableIntegrations`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct ListS3TableIntegrations;
6impl ListS3TableIntegrations {
7    /// Creates a new `ListS3TableIntegrations`
8    pub fn new() -> Self {
9        Self
10    }
11    pub(crate) async fn orchestrate(
12        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
13        input: crate::operation::list_s3_table_integrations::ListS3TableIntegrationsInput,
14    ) -> ::std::result::Result<
15        crate::operation::list_s3_table_integrations::ListS3TableIntegrationsOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::list_s3_table_integrations::ListS3TableIntegrationsError,
18            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
19        >,
20    > {
21        let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
22            ::aws_smithy_runtime_api::client::interceptors::context::Error,
23            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
24        >| {
25            err.map_service_error(|err| {
26                err.downcast::<crate::operation::list_s3_table_integrations::ListS3TableIntegrationsError>()
27                    .expect("correct error type")
28            })
29        };
30        let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
31            .await
32            .map_err(map_err)?;
33        let output = context.finalize().map_err(map_err)?;
34        ::std::result::Result::Ok(
35            output
36                .downcast::<crate::operation::list_s3_table_integrations::ListS3TableIntegrationsOutput>()
37                .expect("correct output type"),
38        )
39    }
40
41    pub(crate) async fn orchestrate_with_stop_point(
42        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
43        input: crate::operation::list_s3_table_integrations::ListS3TableIntegrationsInput,
44        stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,
45    ) -> ::std::result::Result<
46        ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext,
47        ::aws_smithy_runtime_api::client::result::SdkError<
48            ::aws_smithy_runtime_api::client::interceptors::context::Error,
49            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
50        >,
51    > {
52        let input = ::aws_smithy_runtime_api::client::interceptors::context::Input::erase(input);
53        use ::tracing::Instrument;
54        ::aws_smithy_runtime::client::orchestrator::invoke_with_stop_point(
55            "ObservabilityAdmin",
56            "ListS3TableIntegrations",
57            input,
58            runtime_plugins,
59            stop_point,
60        )
61        // Create a parent span for the entire operation. Includes a random, internal-only,
62        // seven-digit ID for the operation orchestration so that it can be correlated in the logs.
63        .instrument(::tracing::debug_span!(
64            "ObservabilityAdmin.ListS3TableIntegrations",
65            "rpc.service" = "ObservabilityAdmin",
66            "rpc.method" = "ListS3TableIntegrations",
67            "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
68            "rpc.system" = "aws-api",
69        ))
70        .await
71    }
72
73    pub(crate) fn operation_runtime_plugins(
74        client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
75        client_config: &crate::config::Config,
76        config_override: ::std::option::Option<crate::config::Builder>,
77    ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
78        let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
79
80        if let ::std::option::Option::Some(config_override) = config_override {
81            for plugin in config_override.runtime_plugins.iter().cloned() {
82                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
83            }
84            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
85                config_override,
86                client_config.config.clone(),
87                &client_config.runtime_components,
88            ));
89        }
90        runtime_plugins
91    }
92}
93impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ListS3TableIntegrations {
94    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
95        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("ListS3TableIntegrations");
96
97        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
98            ListS3TableIntegrationsRequestSerializer,
99        ));
100        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
101            ListS3TableIntegrationsResponseDeserializer,
102        ));
103
104        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
105            crate::config::auth::Params::builder()
106                .operation_name("ListS3TableIntegrations")
107                .build()
108                .expect("required fields set"),
109        ));
110
111        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
112            "ListS3TableIntegrations",
113            "ObservabilityAdmin",
114        ));
115        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
116        signing_options.double_uri_encode = true;
117        signing_options.content_sha256_header = false;
118        signing_options.normalize_uri_path = true;
119        signing_options.payload_override = None;
120
121        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
122            signing_options,
123            ..::std::default::Default::default()
124        });
125
126        ::std::option::Option::Some(cfg.freeze())
127    }
128
129    fn runtime_components(
130        &self,
131        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
132    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
133        #[allow(unused_mut)]
134        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ListS3TableIntegrations")
135            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
136                ListS3TableIntegrationsTelemetryInputCaptureInterceptor,
137            ))
138            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
139                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
140            ))
141            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
142                ListS3TableIntegrationsEndpointParamsInterceptor,
143            ))
144            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
145                crate::operation::list_s3_table_integrations::ListS3TableIntegrationsError,
146            >::new())
147            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
148                crate::operation::list_s3_table_integrations::ListS3TableIntegrationsError,
149            >::new())
150            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
151                crate::operation::list_s3_table_integrations::ListS3TableIntegrationsError,
152            >::new());
153
154        ::std::borrow::Cow::Owned(rcb)
155    }
156}
157
158#[derive(Debug)]
159struct ListS3TableIntegrationsTelemetryInputCaptureInterceptor;
160
161#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
162impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListS3TableIntegrationsTelemetryInputCaptureInterceptor {
163    fn name(&self) -> &'static str {
164        "ListS3TableIntegrationsTelemetryInputCaptureInterceptor"
165    }
166
167    fn read_before_execution(
168        &self,
169        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
170            '_,
171            ::aws_smithy_runtime_api::client::interceptors::context::Input,
172            ::aws_smithy_runtime_api::client::interceptors::context::Output,
173            ::aws_smithy_runtime_api::client::interceptors::context::Error,
174        >,
175        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
176    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
177        // Nothing to do unless the customer opted in by naming members to record.
178        let ::std::option::Option::Some(requested) = cfg
179            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
180            .filter(|r| !r.is_empty())
181        else {
182            return ::std::result::Result::Ok(());
183        };
184
185        let ::std::option::Option::Some(input) = context.input().downcast_ref::<ListS3TableIntegrationsInput>() else {
186            // A mismatched input is not this interceptor's concern; skip quietly.
187            return ::std::result::Result::Ok(());
188        };
189
190        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
191        if requested.should_capture("NextToken") {
192            if let ::std::option::Option::Some(value) = input.next_token.as_deref() {
193                captured.insert("NextToken", value);
194            }
195        }
196
197        cfg.interceptor_state().store_put(captured);
198        ::std::result::Result::Ok(())
199    }
200}
201#[derive(Debug)]
202struct ListS3TableIntegrationsResponseDeserializer;
203impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for ListS3TableIntegrationsResponseDeserializer {
204    fn deserialize_nonstreaming_with_config(
205        &self,
206        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
207        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
208    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
209        let (success, status) = (response.status().is_success(), response.status().as_u16());
210        let headers = response.headers();
211        let body = response.body().bytes().expect("body loaded");
212        #[allow(unused_mut)]
213        let mut force_error = false;
214        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
215        let parse_result = if !success && status != 200 || force_error {
216            crate::protocol_serde::shape_list_s3_table_integrations::de_list_s3_table_integrations_http_error(status, headers, body)
217        } else {
218            crate::protocol_serde::shape_list_s3_table_integrations::de_list_s3_table_integrations_http_response(status, headers, body)
219        };
220        crate::protocol_serde::type_erase_result(parse_result)
221    }
222}
223#[derive(Debug)]
224struct ListS3TableIntegrationsRequestSerializer;
225impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for ListS3TableIntegrationsRequestSerializer {
226    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
227    fn serialize_input(
228        &self,
229        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
230        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
231    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
232        let input = input
233            .downcast::<crate::operation::list_s3_table_integrations::ListS3TableIntegrationsInput>()
234            .expect("correct type");
235        let _header_serialization_settings = _cfg
236            .load::<crate::serialization_settings::HeaderSerializationSettings>()
237            .cloned()
238            .unwrap_or_default();
239        let mut request_builder = {
240            #[allow(clippy::uninlined_format_args)]
241            fn uri_base(
242                _input: &crate::operation::list_s3_table_integrations::ListS3TableIntegrationsInput,
243                output: &mut ::std::string::String,
244            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
245                use ::std::fmt::Write as _;
246                ::std::write!(output, "/ListS3TableIntegrations").expect("formatting should succeed");
247                ::std::result::Result::Ok(())
248            }
249            #[allow(clippy::unnecessary_wraps)]
250            fn update_http_builder(
251                input: &crate::operation::list_s3_table_integrations::ListS3TableIntegrationsInput,
252                builder: ::http_1x::request::Builder,
253            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
254                let mut uri = ::std::string::String::new();
255                uri_base(input, &mut uri)?;
256                ::std::result::Result::Ok(builder.method("POST").uri(uri))
257            }
258            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
259            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/json");
260            builder
261        };
262        let body = ::aws_smithy_types::body::SdkBody::from(
263            crate::protocol_serde::shape_list_s3_table_integrations::ser_list_s3_table_integrations_input(&input)?,
264        );
265        if let Some(content_length) = body.content_length() {
266            let content_length = content_length.to_string();
267            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
268        }
269        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
270    }
271}
272#[derive(Debug)]
273struct ListS3TableIntegrationsEndpointParamsInterceptor;
274
275#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
276impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListS3TableIntegrationsEndpointParamsInterceptor {
277    fn name(&self) -> &'static str {
278        "ListS3TableIntegrationsEndpointParamsInterceptor"
279    }
280
281    fn read_before_execution(
282        &self,
283        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
284            '_,
285            ::aws_smithy_runtime_api::client::interceptors::context::Input,
286            ::aws_smithy_runtime_api::client::interceptors::context::Output,
287            ::aws_smithy_runtime_api::client::interceptors::context::Error,
288        >,
289        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
290    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
291        let _input = context
292            .input()
293            .downcast_ref::<ListS3TableIntegrationsInput>()
294            .ok_or("failed to downcast to ListS3TableIntegrationsInput")?;
295
296        let params = crate::config::endpoint::Params::builder()
297            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
298            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
299            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
300            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
301            .build()
302            .map_err(|err| {
303                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
304            })?;
305        cfg.interceptor_state()
306            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
307        ::std::result::Result::Ok(())
308    }
309}
310
311// The get_* functions below are generated from JMESPath expressions in the
312// operationContextParams trait. They target the operation's input shape.
313
314/// Error type for the `ListS3TableIntegrationsError` operation.
315#[non_exhaustive]
316#[derive(::std::fmt::Debug)]
317pub enum ListS3TableIntegrationsError {
318    /// <p>Indicates you don't have permissions to perform the requested operation. The user or role that is making the request must have at least one IAM permissions policy attached that grants the required permissions. For more information, see <a href="https://docs.aws.amazon.com/IAM/latest/UserGuide/access.html">Access management for Amazon Web Services resources</a> in the IAM user guide.</p>
319    AccessDeniedException(crate::types::error::AccessDeniedException),
320    /// <p>Indicates the request has failed to process because of an unknown server error, exception, or failure.</p>
321    InternalServerException(crate::types::error::InternalServerException),
322    /// <p>The request throughput limit was exceeded.</p>
323    TooManyRequestsException(crate::types::error::TooManyRequestsException),
324    /// <p>Indicates input validation failed. Check your request parameters and retry the request.</p>
325    ValidationException(crate::types::error::ValidationException),
326    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
327    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
328    variable wildcard pattern and check `.code()`:
329     \
330    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
331     \
332    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ListS3TableIntegrationsError) for what information is available for the error.")]
333    Unhandled(crate::error::sealed_unhandled::Unhandled),
334}
335impl ListS3TableIntegrationsError {
336    /// Creates the `ListS3TableIntegrationsError::Unhandled` variant from any error type.
337    pub fn unhandled(
338        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
339    ) -> Self {
340        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
341            source: err.into(),
342            meta: ::std::default::Default::default(),
343        })
344    }
345
346    /// Creates the `ListS3TableIntegrationsError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
347    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
348        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
349            source: err.clone().into(),
350            meta: err,
351        })
352    }
353    ///
354    /// Returns error metadata, which includes the error code, message,
355    /// request ID, and potentially additional information.
356    ///
357    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
358        match self {
359            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
360            Self::InternalServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
361            Self::TooManyRequestsException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
362            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
363            Self::Unhandled(e) => &e.meta,
364        }
365    }
366    /// Returns `true` if the error kind is `ListS3TableIntegrationsError::AccessDeniedException`.
367    pub fn is_access_denied_exception(&self) -> bool {
368        matches!(self, Self::AccessDeniedException(_))
369    }
370    /// Returns `true` if the error kind is `ListS3TableIntegrationsError::InternalServerException`.
371    pub fn is_internal_server_exception(&self) -> bool {
372        matches!(self, Self::InternalServerException(_))
373    }
374    /// Returns `true` if the error kind is `ListS3TableIntegrationsError::TooManyRequestsException`.
375    pub fn is_too_many_requests_exception(&self) -> bool {
376        matches!(self, Self::TooManyRequestsException(_))
377    }
378    /// Returns `true` if the error kind is `ListS3TableIntegrationsError::ValidationException`.
379    pub fn is_validation_exception(&self) -> bool {
380        matches!(self, Self::ValidationException(_))
381    }
382}
383impl ::std::error::Error for ListS3TableIntegrationsError {
384    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
385        match self {
386            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
387            Self::InternalServerException(_inner) => ::std::option::Option::Some(_inner),
388            Self::TooManyRequestsException(_inner) => ::std::option::Option::Some(_inner),
389            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
390            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
391        }
392    }
393}
394impl ::std::fmt::Display for ListS3TableIntegrationsError {
395    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
396        match self {
397            Self::AccessDeniedException(_inner) => _inner.fmt(f),
398            Self::InternalServerException(_inner) => _inner.fmt(f),
399            Self::TooManyRequestsException(_inner) => _inner.fmt(f),
400            Self::ValidationException(_inner) => _inner.fmt(f),
401            Self::Unhandled(_inner) => {
402                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
403                    write!(f, "unhandled error ({code})")
404                } else {
405                    f.write_str("unhandled error")
406                }
407            }
408        }
409    }
410}
411impl ::aws_smithy_types::retry::ProvideErrorKind for ListS3TableIntegrationsError {
412    fn code(&self) -> ::std::option::Option<&str> {
413        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
414    }
415    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
416        ::std::option::Option::None
417    }
418}
419impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for ListS3TableIntegrationsError {
420    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
421        match self {
422            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
423            Self::InternalServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
424            Self::TooManyRequestsException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
425            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
426            Self::Unhandled(_inner) => &_inner.meta,
427        }
428    }
429}
430impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for ListS3TableIntegrationsError {
431    fn create_unhandled_error(
432        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
433        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
434    ) -> Self {
435        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
436            source,
437            meta: meta.unwrap_or_default(),
438        })
439    }
440}
441impl ::aws_types::request_id::RequestId for crate::operation::list_s3_table_integrations::ListS3TableIntegrationsError {
442    fn request_id(&self) -> Option<&str> {
443        self.meta().request_id()
444    }
445}
446
447pub use crate::operation::list_s3_table_integrations::_list_s3_table_integrations_input::ListS3TableIntegrationsInput;
448
449pub use crate::operation::list_s3_table_integrations::_list_s3_table_integrations_output::ListS3TableIntegrationsOutput;
450
451mod _list_s3_table_integrations_input;
452
453mod _list_s3_table_integrations_output;
454
455/// Builders
456pub mod builders;
457
458/// Paginator for this operation
459pub mod paginator;
aws_sdk_observabilityadmin/operation/list_s3_table_integrations.rs

aws_sdk_observabilityadmin/operation/
list_s3_table_integrations.rs
