aws_sdk_keyspacesstreams/operation/
get_shard_iterator.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `GetShardIterator`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct GetShardIterator;
6impl GetShardIterator {
7    /// Creates a new `GetShardIterator`
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_shard_iterator::GetShardIteratorInput,
14    ) -> ::std::result::Result<
15        crate::operation::get_shard_iterator::GetShardIteratorOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::get_shard_iterator::GetShardIteratorError,
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_shard_iterator::GetShardIteratorError>()
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_shard_iterator::GetShardIteratorOutput>()
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_shard_iterator::GetShardIteratorInput,
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("KeyspacesStreams", "GetShardIterator", input, runtime_plugins, stop_point)
55            // Create a parent span for the entire operation. Includes a random, internal-only,
56            // seven-digit ID for the operation orchestration so that it can be correlated in the logs.
57            .instrument(::tracing::debug_span!(
58                "KeyspacesStreams.GetShardIterator",
59                "rpc.service" = "KeyspacesStreams",
60                "rpc.method" = "GetShardIterator",
61                "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
62                "rpc.system" = "aws-api",
63            ))
64            .await
65    }
66
67    pub(crate) fn operation_runtime_plugins(
68        client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
69        client_config: &crate::config::Config,
70        config_override: ::std::option::Option<crate::config::Builder>,
71    ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
72        let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
73
74        if let ::std::option::Option::Some(config_override) = config_override {
75            for plugin in config_override.runtime_plugins.iter().cloned() {
76                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
77            }
78            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
79                config_override,
80                client_config.config.clone(),
81                &client_config.runtime_components,
82            ));
83        }
84        runtime_plugins
85    }
86}
87impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for GetShardIterator {
88    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("GetShardIterator");
90
91        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92            GetShardIteratorRequestSerializer,
93        ));
94        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95            GetShardIteratorResponseDeserializer,
96        ));
97
98        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99            crate::config::auth::Params::builder()
100                .operation_name("GetShardIterator")
101                .build()
102                .expect("required fields set"),
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
106            "GetShardIterator",
107            "KeyspacesStreams",
108        ));
109        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
110        signing_options.double_uri_encode = true;
111        signing_options.content_sha256_header = false;
112        signing_options.normalize_uri_path = true;
113        signing_options.payload_override = None;
114
115        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
116            signing_options,
117            ..::std::default::Default::default()
118        });
119
120        ::std::option::Option::Some(cfg.freeze())
121    }
122
123    fn runtime_components(
124        &self,
125        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
126    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
127        #[allow(unused_mut)]
128        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("GetShardIterator")
129            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
130                GetShardIteratorTelemetryInputCaptureInterceptor,
131            ))
132            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
133                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
134            ))
135            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
136                GetShardIteratorEndpointParamsInterceptor,
137            ))
138            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
139                crate::operation::get_shard_iterator::GetShardIteratorError,
140            >::new())
141            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
142                crate::operation::get_shard_iterator::GetShardIteratorError,
143            >::new())
144            .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
145                crate::operation::get_shard_iterator::GetShardIteratorError,
146            >::new());
147
148        ::std::borrow::Cow::Owned(rcb)
149    }
150}
151
152#[derive(Debug)]
153struct GetShardIteratorTelemetryInputCaptureInterceptor;
154
155#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
156impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetShardIteratorTelemetryInputCaptureInterceptor {
157    fn name(&self) -> &'static str {
158        "GetShardIteratorTelemetryInputCaptureInterceptor"
159    }
160
161    fn read_before_execution(
162        &self,
163        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
164            '_,
165            ::aws_smithy_runtime_api::client::interceptors::context::Input,
166            ::aws_smithy_runtime_api::client::interceptors::context::Output,
167            ::aws_smithy_runtime_api::client::interceptors::context::Error,
168        >,
169        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
170    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
171        // Nothing to do unless the customer opted in by naming members to record.
172        let ::std::option::Option::Some(requested) = cfg
173            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
174            .filter(|r| !r.is_empty())
175        else {
176            return ::std::result::Result::Ok(());
177        };
178
179        let ::std::option::Option::Some(input) = context.input().downcast_ref::<GetShardIteratorInput>() else {
180            // A mismatched input is not this interceptor's concern; skip quietly.
181            return ::std::result::Result::Ok(());
182        };
183
184        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
185        if requested.should_capture("streamArn") {
186            if let ::std::option::Option::Some(value) = input.stream_arn.as_deref() {
187                captured.insert("streamArn", value);
188            }
189        }
190        if requested.should_capture("shardId") {
191            if let ::std::option::Option::Some(value) = input.shard_id.as_deref() {
192                captured.insert("shardId", value);
193            }
194        }
195        if requested.should_capture("sequenceNumber") {
196            if let ::std::option::Option::Some(value) = input.sequence_number.as_deref() {
197                captured.insert("sequenceNumber", value);
198            }
199        }
200
201        cfg.interceptor_state().store_put(captured);
202        ::std::result::Result::Ok(())
203    }
204}
205#[derive(Debug)]
206struct GetShardIteratorResponseDeserializer;
207impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for GetShardIteratorResponseDeserializer {
208    fn deserialize_nonstreaming_with_config(
209        &self,
210        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
211        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
212    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
213        let (success, status) = (response.status().is_success(), response.status().as_u16());
214        let headers = response.headers();
215        let body = response.body().bytes().expect("body loaded");
216        #[allow(unused_mut)]
217        let mut force_error = false;
218        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
219        let parse_result = if !success && status != 200 || force_error {
220            crate::protocol_serde::shape_get_shard_iterator::de_get_shard_iterator_http_error(status, headers, body)
221        } else {
222            crate::protocol_serde::shape_get_shard_iterator::de_get_shard_iterator_http_response(status, headers, body)
223        };
224        crate::protocol_serde::type_erase_result(parse_result)
225    }
226}
227#[derive(Debug)]
228struct GetShardIteratorRequestSerializer;
229impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for GetShardIteratorRequestSerializer {
230    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
231    fn serialize_input(
232        &self,
233        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
234        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
235    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
236        let input = input
237            .downcast::<crate::operation::get_shard_iterator::GetShardIteratorInput>()
238            .expect("correct type");
239        let _header_serialization_settings = _cfg
240            .load::<crate::serialization_settings::HeaderSerializationSettings>()
241            .cloned()
242            .unwrap_or_default();
243        let mut request_builder = {
244            #[allow(clippy::uninlined_format_args)]
245            fn uri_base(
246                _input: &crate::operation::get_shard_iterator::GetShardIteratorInput,
247                output: &mut ::std::string::String,
248            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
249                use ::std::fmt::Write as _;
250                ::std::write!(output, "/").expect("formatting should succeed");
251                ::std::result::Result::Ok(())
252            }
253            #[allow(clippy::unnecessary_wraps)]
254            fn update_http_builder(
255                input: &crate::operation::get_shard_iterator::GetShardIteratorInput,
256                builder: ::http_1x::request::Builder,
257            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
258                let mut uri = ::std::string::String::new();
259                uri_base(input, &mut uri)?;
260                ::std::result::Result::Ok(builder.method("POST").uri(uri))
261            }
262            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
263            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/x-amz-json-1.0");
264            builder = _header_serialization_settings.set_default_header(
265                builder,
266                ::http_1x::header::HeaderName::from_static("x-amz-target"),
267                "KeyspacesStreams.GetShardIterator",
268            );
269            builder
270        };
271        let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_get_shard_iterator::ser_get_shard_iterator_input(&input)?);
272        if let Some(content_length) = body.content_length() {
273            let content_length = content_length.to_string();
274            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
275        }
276        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
277    }
278}
279#[derive(Debug)]
280struct GetShardIteratorEndpointParamsInterceptor;
281
282#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
283impl ::aws_smithy_runtime_api::client::interceptors::Intercept for GetShardIteratorEndpointParamsInterceptor {
284    fn name(&self) -> &'static str {
285        "GetShardIteratorEndpointParamsInterceptor"
286    }
287
288    fn read_before_execution(
289        &self,
290        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
291            '_,
292            ::aws_smithy_runtime_api::client::interceptors::context::Input,
293            ::aws_smithy_runtime_api::client::interceptors::context::Output,
294            ::aws_smithy_runtime_api::client::interceptors::context::Error,
295        >,
296        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
297    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
298        let _input = context
299            .input()
300            .downcast_ref::<GetShardIteratorInput>()
301            .ok_or("failed to downcast to GetShardIteratorInput")?;
302
303        let params = crate::config::endpoint::Params::builder()
304            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
305            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
306            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
307            .build()
308            .map_err(|err| {
309                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
310            })?;
311        cfg.interceptor_state()
312            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
313        ::std::result::Result::Ok(())
314    }
315}
316
317// The get_* functions below are generated from JMESPath expressions in the
318// operationContextParams trait. They target the operation's input shape.
319
320/// Error type for the `GetShardIteratorError` operation.
321#[non_exhaustive]
322#[derive(::std::fmt::Debug)]
323pub enum GetShardIteratorError {
324    /// <p>You don't have sufficient access permissions to perform this operation.</p>
325    /// <p>This exception occurs when your IAM user or role lacks the required permissions to access the Amazon Keyspaces resource or perform the requested action. Check your IAM policies and ensure they grant the necessary permissions.</p>
326    AccessDeniedException(crate::types::error::AccessDeniedException),
327    /// <p>The Amazon Keyspaces service encountered an unexpected error while processing the request.</p>
328    /// <p>This internal server error is not related to your request parameters. Retry your request after a brief delay. If the issue persists, contact Amazon Web Services Support with details of your request to help identify and resolve the problem.</p>
329    InternalServerException(crate::types::error::InternalServerException),
330    /// <p>The requested resource doesn't exist or could not be found.</p>
331    /// <p>This exception occurs when you attempt to access a keyspace, table, stream, or other Amazon Keyspaces resource that doesn't exist or that has been deleted. Verify that the resource identifier is correct and that the resource exists in your account.</p>
332    ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
333    /// <p>The request rate is too high and exceeds the service's throughput limits.</p>
334    /// <p>This exception occurs when you send too many requests in a short period of time. Implement exponential backoff in your retry strategy to handle this exception. Reducing your request frequency or distributing requests more evenly can help avoid throughput exceptions.</p>
335    /// <p>This exception can also occur when more than two processes are reading from the same stream shard at the same time. Ensure that only one process reads from a stream shard at the same time.</p>
336    ThrottlingException(crate::types::error::ThrottlingException),
337    /// <p>The request validation failed because one or more input parameters failed validation.</p>
338    /// <p>This exception occurs when there are syntax errors in the request, field constraints are violated, or required parameters are missing. To help you fix the issue, the exception message provides details about which parameter failed and why.</p>
339    ValidationException(crate::types::error::ValidationException),
340    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
341    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
342    variable wildcard pattern and check `.code()`:
343     \
344    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
345     \
346    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-GetShardIteratorError) for what information is available for the error.")]
347    Unhandled(crate::error::sealed_unhandled::Unhandled),
348}
349impl GetShardIteratorError {
350    /// Creates the `GetShardIteratorError::Unhandled` variant from any error type.
351    pub fn unhandled(
352        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
353    ) -> Self {
354        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
355            source: err.into(),
356            meta: ::std::default::Default::default(),
357        })
358    }
359
360    /// Creates the `GetShardIteratorError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
361    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
362        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
363            source: err.clone().into(),
364            meta: err,
365        })
366    }
367    ///
368    /// Returns error metadata, which includes the error code, message,
369    /// request ID, and potentially additional information.
370    ///
371    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
372        match self {
373            Self::AccessDeniedException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
374            Self::InternalServerException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
375            Self::ResourceNotFoundException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
376            Self::ThrottlingException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
377            Self::ValidationException(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
378            Self::Unhandled(e) => &e.meta,
379        }
380    }
381    /// Returns `true` if the error kind is `GetShardIteratorError::AccessDeniedException`.
382    pub fn is_access_denied_exception(&self) -> bool {
383        matches!(self, Self::AccessDeniedException(_))
384    }
385    /// Returns `true` if the error kind is `GetShardIteratorError::InternalServerException`.
386    pub fn is_internal_server_exception(&self) -> bool {
387        matches!(self, Self::InternalServerException(_))
388    }
389    /// Returns `true` if the error kind is `GetShardIteratorError::ResourceNotFoundException`.
390    pub fn is_resource_not_found_exception(&self) -> bool {
391        matches!(self, Self::ResourceNotFoundException(_))
392    }
393    /// Returns `true` if the error kind is `GetShardIteratorError::ThrottlingException`.
394    pub fn is_throttling_exception(&self) -> bool {
395        matches!(self, Self::ThrottlingException(_))
396    }
397    /// Returns `true` if the error kind is `GetShardIteratorError::ValidationException`.
398    pub fn is_validation_exception(&self) -> bool {
399        matches!(self, Self::ValidationException(_))
400    }
401}
402impl ::std::error::Error for GetShardIteratorError {
403    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
404        match self {
405            Self::AccessDeniedException(_inner) => ::std::option::Option::Some(_inner),
406            Self::InternalServerException(_inner) => ::std::option::Option::Some(_inner),
407            Self::ResourceNotFoundException(_inner) => ::std::option::Option::Some(_inner),
408            Self::ThrottlingException(_inner) => ::std::option::Option::Some(_inner),
409            Self::ValidationException(_inner) => ::std::option::Option::Some(_inner),
410            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
411        }
412    }
413}
414impl ::std::fmt::Display for GetShardIteratorError {
415    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
416        match self {
417            Self::AccessDeniedException(_inner) => _inner.fmt(f),
418            Self::InternalServerException(_inner) => _inner.fmt(f),
419            Self::ResourceNotFoundException(_inner) => _inner.fmt(f),
420            Self::ThrottlingException(_inner) => _inner.fmt(f),
421            Self::ValidationException(_inner) => _inner.fmt(f),
422            Self::Unhandled(_inner) => {
423                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
424                    write!(f, "unhandled error ({code})")
425                } else {
426                    f.write_str("unhandled error")
427                }
428            }
429        }
430    }
431}
432impl ::aws_smithy_types::retry::ProvideErrorKind for GetShardIteratorError {
433    fn code(&self) -> ::std::option::Option<&str> {
434        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
435    }
436    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
437        ::std::option::Option::None
438    }
439}
440impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for GetShardIteratorError {
441    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
442        match self {
443            Self::AccessDeniedException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
444            Self::InternalServerException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
445            Self::ResourceNotFoundException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
446            Self::ThrottlingException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
447            Self::ValidationException(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
448            Self::Unhandled(_inner) => &_inner.meta,
449        }
450    }
451}
452impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for GetShardIteratorError {
453    fn create_unhandled_error(
454        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
455        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
456    ) -> Self {
457        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
458            source,
459            meta: meta.unwrap_or_default(),
460        })
461    }
462}
463impl ::aws_types::request_id::RequestId for crate::operation::get_shard_iterator::GetShardIteratorError {
464    fn request_id(&self) -> Option<&str> {
465        self.meta().request_id()
466    }
467}
468
469pub use crate::operation::get_shard_iterator::_get_shard_iterator_input::GetShardIteratorInput;
470
471pub use crate::operation::get_shard_iterator::_get_shard_iterator_output::GetShardIteratorOutput;
472
473mod _get_shard_iterator_input;
474
475mod _get_shard_iterator_output;
476
477/// Builders
478pub mod builders;
aws_sdk_keyspacesstreams/operation/get_shard_iterator.rs

aws_sdk_keyspacesstreams/operation/
get_shard_iterator.rs
