Skip to main content

aws_sdk_observabilityadmin/operation/
get_telemetry_rule.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `GetTelemetryRule`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct GetTelemetryRule;
6impl GetTelemetryRule {
7    /// Creates a new `GetTelemetryRule`
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::get_telemetry_rule::GetTelemetryRuleInput,
14    ) -> ::std::result::Result<
15        crate::operation::get_telemetry_rule::GetTelemetryRuleOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::get_telemetry_rule::GetTelemetryRuleError,
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::get_telemetry_rule::GetTelemetryRuleError>()
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::get_telemetry_rule::GetTelemetryRuleOutput>()
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::get_telemetry_rule::GetTelemetryRuleInput,
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            "GetTelemetryRule",
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.GetTelemetryRule",
65            "rpc.service" = "ObservabilityAdmin",
66            "rpc.method" = "GetTelemetryRule",
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 GetTelemetryRule {
94    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
95        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("GetTelemetryRule");
96
97        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
98            GetTelemetryRuleRequestSerializer,
99        ));
100        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
101            GetTelemetryRuleResponseDeserializer,
102        ));
103
104        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
105            crate::config::auth::Params::builder()
106                .operation_name("GetTelemetryRule")
107                .build()
108                .expect("required fields set"),
109        ));
110
111        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
112            "GetTelemetryRule",
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("GetTelemetryRule")
135            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
136                GetTelemetryRuleTelemetryInputCaptureInterceptor,
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                GetTelemetryRuleEndpointParamsInterceptor,
143            ))
144            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
145                crate::operation::get_telemetry_rule::GetTelemetryRuleError,
146            >::new())
147            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
148                crate::operation::get_telemetry_rule::GetTelemetryRuleError,
149            >::new())
150            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
151                crate::operation::get_telemetry_rule::GetTelemetryRuleError,
152            >::new())
153            .with_retry_classifier(::aws_runtime::service_clock_skew::ServiceClockSkewClassifier::<
154                crate::operation::get_telemetry_rule::GetTelemetryRuleError,
155            >::new());
156
157        ::std::borrow::Cow::Owned(rcb)
158    }
159}
160
161#[derive(Debug)]
162struct GetTelemetryRuleTelemetryInputCaptureInterceptor;
163
164#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
165impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetTelemetryRuleTelemetryInputCaptureInterceptor {
166    fn name(&self) -> &'static str {
167        "GetTelemetryRuleTelemetryInputCaptureInterceptor"
168    }
169
170    fn read_before_execution(
171        &self,
172        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
173            '_,
174            ::aws_smithy_runtime_api::client::interceptors::context::Input,
175            ::aws_smithy_runtime_api::client::interceptors::context::Output,
176            ::aws_smithy_runtime_api::client::interceptors::context::Error,
177        >,
178        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
179    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
180        // Nothing to do unless the customer opted in by naming members to record.
181        let ::std::option::Option::Some(requested) = cfg
182            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
183            .filter(|r| !r.is_empty())
184        else {
185            return ::std::result::Result::Ok(());
186        };
187
188        let ::std::option::Option::Some(input) = context.input().downcast_ref::<GetTelemetryRuleInput>() else {
189            // A mismatched input is not this interceptor's concern; skip quietly.
190            return ::std::result::Result::Ok(());
191        };
192
193        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
194        if requested.should_capture("RuleIdentifier") {
195            if let ::std::option::Option::Some(value) = input.rule_identifier.as_deref() {
196                captured.insert("RuleIdentifier", value);
197            }
198        }
199
200        cfg.interceptor_state().store_put(captured);
201        ::std::result::Result::Ok(())
202    }
203}
204#[derive(Debug)]
205struct GetTelemetryRuleResponseDeserializer;
206impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for GetTelemetryRuleResponseDeserializer {
207    fn deserialize_nonstreaming_with_config(
208        &self,
209        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
210        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
211    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
212        let (success, status) = (response.status().is_success(), response.status().as_u16());
213        let headers = response.headers();
214        let body = response.body().bytes().expect("body loaded");
215        #[allow(unused_mut)]
216        let mut force_error = false;
217        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
218        let parse_result = if !success && status != 200 || force_error {
219            crate::protocol_serde::shape_get_telemetry_rule::de_get_telemetry_rule_http_error(status, headers, body)
220        } else {
221            crate::protocol_serde::shape_get_telemetry_rule::de_get_telemetry_rule_http_response(status, headers, body)
222        };
223        crate::protocol_serde::type_erase_result(parse_result)
224    }
225}
226#[derive(Debug)]
227struct GetTelemetryRuleRequestSerializer;
228impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for GetTelemetryRuleRequestSerializer {
229    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
230    fn serialize_input(
231        &self,
232        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
233        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
234    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
235        let input = input
236            .downcast::<crate::operation::get_telemetry_rule::GetTelemetryRuleInput>()
237            .expect("correct type");
238        let _header_serialization_settings = _cfg
239            .load::<crate::serialization_settings::HeaderSerializationSettings>()
240            .cloned()
241            .unwrap_or_default();
242        let mut request_builder = {
243            #[allow(clippy::uninlined_format_args)]
244            fn uri_base(
245                _input: &crate::operation::get_telemetry_rule::GetTelemetryRuleInput,
246                output: &mut ::std::string::String,
247            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
248                use ::std::fmt::Write as _;
249                ::std::write!(output, "/GetTelemetryRule").expect("formatting should succeed");
250                ::std::result::Result::Ok(())
251            }
252            #[allow(clippy::unnecessary_wraps)]
253            fn update_http_builder(
254                input: &crate::operation::get_telemetry_rule::GetTelemetryRuleInput,
255                builder: ::http_1x::request::Builder,
256            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
257                let mut uri = ::std::string::String::new();
258                uri_base(input, &mut uri)?;
259                ::std::result::Result::Ok(builder.method("POST").uri(uri))
260            }
261            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
262            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/json");
263            builder
264        };
265        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_get_telemetry_rule::ser_get_telemetry_rule_input(&input)?);
266        if let Some(content_length) = body.content_length() {
267            let content_length = content_length.to_string();
268            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
269        }
270        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
271    }
272}
273#[derive(Debug)]
274struct GetTelemetryRuleEndpointParamsInterceptor;
275
276#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
277impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetTelemetryRuleEndpointParamsInterceptor {
278    fn name(&self) -> &'static str {
279        "GetTelemetryRuleEndpointParamsInterceptor"
280    }
281
282    fn read_before_execution(
283        &self,
284        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
285            '_,
286            ::aws_smithy_runtime_api::client::interceptors::context::Input,
287            ::aws_smithy_runtime_api::client::interceptors::context::Output,
288            ::aws_smithy_runtime_api::client::interceptors::context::Error,
289        >,
290        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
291    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
292        let _input = context
293            .input()
294            .downcast_ref::<GetTelemetryRuleInput>()
295            .ok_or("failed to downcast to GetTelemetryRuleInput")?;
296
297        let params = crate::config::endpoint::Params::builder()
298            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
299            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
300            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
301            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
302            .build()
303            .map_err(|err| {
304                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
305            })?;
306        cfg.interceptor_state()
307            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
308        ::std::result::Result::Ok(())
309    }
310}
311
312// The get_* functions below are generated from JMESPath expressions in the
313// operationContextParams trait. They target the operation's input shape.
314
315/// Error type for the `GetTelemetryRuleError` operation.
316#[non_exhaustive]
317#[derive(::std::fmt::Debug)]
318pub enum GetTelemetryRuleError {
319    /// <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>
320    AccessDeniedException(crate::types::error::AccessDeniedException),
321    /// <p>Indicates the request has failed to process because of an unknown server error, exception, or failure.</p>
322    InternalServerException(crate::types::error::InternalServerException),
323    /// <p>The specified resource (such as a telemetry rule) could not be found.</p>
324    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
325    /// <p>The request throughput limit was exceeded.</p>
326    TooManyRequestsException(crate::types::error::TooManyRequestsException),
327    /// <p>Indicates input validation failed. Check your request parameters and retry the request.</p>
328    ValidationException(crate::types::error::ValidationException),
329    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
330    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
331    variable wildcard pattern and check `.code()`:
332     \
333    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
334     \
335    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-GetTelemetryRuleError) for what information is available for the error.")]
336    Unhandled(crate::error::sealed_unhandled::Unhandled),
337}
338impl GetTelemetryRuleError {
339    /// Creates the `GetTelemetryRuleError::Unhandled` variant from any error type.
340    pub fn unhandled(
341        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
342    ) -> Self {
343        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
344            source: err.into(),
345            meta: ::std::default::Default::default(),
346        })
347    }
348
349    /// Creates the `GetTelemetryRuleError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
350    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
351        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
352            source: err.clone().into(),
353            meta: err,
354        })
355    }
356    ///
357    /// Returns error metadata, which includes the error code, message,
358    /// request ID, and potentially additional information.
359    ///
360    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
361        match self {
362            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
363            Self::InternalServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
364            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
365            Self::TooManyRequestsException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
366            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
367            Self::Unhandled(e) => &e.meta,
368        }
369    }
370    /// Returns `true` if the error kind is `GetTelemetryRuleError::AccessDeniedException`.
371    pub fn is_access_denied_exception(&self) -> bool {
372        matches!(self, Self::AccessDeniedException(_))
373    }
374    /// Returns `true` if the error kind is `GetTelemetryRuleError::InternalServerException`.
375    pub fn is_internal_server_exception(&self) -> bool {
376        matches!(self, Self::InternalServerException(_))
377    }
378    /// Returns `true` if the error kind is `GetTelemetryRuleError::ResourceNotFoundException`.
379    pub fn is_resource_not_found_exception(&self) -> bool {
380        matches!(self, Self::ResourceNotFoundException(_))
381    }
382    /// Returns `true` if the error kind is `GetTelemetryRuleError::TooManyRequestsException`.
383    pub fn is_too_many_requests_exception(&self) -> bool {
384        matches!(self, Self::TooManyRequestsException(_))
385    }
386    /// Returns `true` if the error kind is `GetTelemetryRuleError::ValidationException`.
387    pub fn is_validation_exception(&self) -> bool {
388        matches!(self, Self::ValidationException(_))
389    }
390}
391impl ::std::error::Error for GetTelemetryRuleError {
392    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
393        match self {
394            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
395            Self::InternalServerException(_inner) => ::std::option::Option::Some(_inner),
396            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
397            Self::TooManyRequestsException(_inner) => ::std::option::Option::Some(_inner),
398            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
399            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
400        }
401    }
402}
403impl ::std::fmt::Display for GetTelemetryRuleError {
404    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
405        match self {
406            Self::AccessDeniedException(_inner) => _inner.fmt(f),
407            Self::InternalServerException(_inner) => _inner.fmt(f),
408            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
409            Self::TooManyRequestsException(_inner) => _inner.fmt(f),
410            Self::ValidationException(_inner) => _inner.fmt(f),
411            Self::Unhandled(_inner) => {
412                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
413                    write!(f, "unhandled error ({code})")
414                } else {
415                    f.write_str("unhandled error")
416                }
417            }
418        }
419    }
420}
421impl ::aws_smithy_types::retry::ProvideErrorKind for GetTelemetryRuleError {
422    fn code(&self) -> ::std::option::Option<&str> {
423        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
424    }
425    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
426        ::std::option::Option::None
427    }
428}
429impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for GetTelemetryRuleError {
430    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
431        match self {
432            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
433            Self::InternalServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
434            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
435            Self::TooManyRequestsException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
436            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
437            Self::Unhandled(_inner) => &_inner.meta,
438        }
439    }
440}
441impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for GetTelemetryRuleError {
442    fn create_unhandled_error(
443        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
444        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
445    ) -> Self {
446        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
447            source,
448            meta: meta.unwrap_or_default(),
449        })
450    }
451}
452impl ::aws_types::request_id::RequestId for crate::operation::get_telemetry_rule::GetTelemetryRuleError {
453    fn request_id(&self) -> Option<&str> {
454        self.meta().request_id()
455    }
456}
457
458pub use crate::operation::get_telemetry_rule::_get_telemetry_rule_input::GetTelemetryRuleInput;
459
460pub use crate::operation::get_telemetry_rule::_get_telemetry_rule_output::GetTelemetryRuleOutput;
461
462mod _get_telemetry_rule_input;
463
464mod _get_telemetry_rule_output;
465
466/// Builders
467pub mod builders;