AWS SDK

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/describe_batch_load_task.rs

@@ -227,227 +288,290 @@

-227
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DescribeBatchLoadTaskEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "DescribeBatchLoadTaskEndpointParamsInterceptor"
-231
+    }
-232
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeBatchLoadTaskInput>()
             .ok_or("failed to downcast to DescribeBatchLoadTaskInput")?;

-247
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-262
+    }
-263
+}
-264
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-267
 /// Error type for the `DescribeBatchLoadTaskError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeBatchLoadTaskError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-285
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-287
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeBatchLoadTaskError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-290
+}

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/describe_database.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DescribeDatabaseEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "DescribeDatabaseEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeDatabaseInput>()
             .ok_or("failed to downcast to DescribeDatabaseInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `DescribeDatabaseError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeDatabaseError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-279
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-281
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeDatabaseError) for what information is available for the error.")]

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/describe_endpoints.rs

@@ -222,222 +283,285 @@

↥ Expand context

-222
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DescribeEndpointsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "DescribeEndpointsEndpointParamsInterceptor"
-226
+    }
-227
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeEndpointsInput>()
             .ok_or("failed to downcast to DescribeEndpointsInput")?;

-242
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-257
+    }
-258
+}
-259
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-262
 /// Error type for the `DescribeEndpointsError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeEndpointsError {
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-276
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-278
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeEndpointsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-281
+}
 impl DescribeEndpointsError {
     /// Creates the `DescribeEndpointsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/describe_table.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DescribeTableEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "DescribeTableEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DescribeTableInput>()
             .ok_or("failed to downcast to DescribeTableInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `DescribeTableError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum DescribeTableError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-279
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-281
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DescribeTableError) for what information is available for the error.")]

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/list_batch_load_tasks.rs

@@ -227,227 +288,290 @@

↥ Expand context

-227
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListBatchLoadTasksEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListBatchLoadTasksEndpointParamsInterceptor"
-231
+    }
-232
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ListBatchLoadTasksInput>()
             .ok_or("failed to downcast to ListBatchLoadTasksInput")?;

-247
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-262
+    }
-263
+}
-264
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-267
 /// Error type for the `ListBatchLoadTasksError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ListBatchLoadTasksError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-285
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-287
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ListBatchLoadTasksError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-290
+}

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/list_databases.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListDatabasesEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListDatabasesEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ListDatabasesInput>()
             .ok_or("failed to downcast to ListDatabasesInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `ListDatabasesError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ListDatabasesError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-277
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-279
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ListDatabasesError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-282
+}

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/list_tables.rs

@@ -217,217 +278,280 @@

↥ Expand context

-217
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListTablesEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListTablesEndpointParamsInterceptor"
-221
+    }
-222
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ListTablesInput>()
             .ok_or("failed to downcast to ListTablesInput")?;

-237
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-252
+    }
-253
+}
-254
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-257
 /// Error type for the `ListTablesError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ListTablesError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-277
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-279
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ListTablesError) for what information is available for the error.")]

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/list_tags_for_resource.rs

@@ -227,227 +288,290 @@

↥ Expand context

-227
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ListTagsForResourceEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ListTagsForResourceEndpointParamsInterceptor"
-231
+    }
-232
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ListTagsForResourceInput>()
             .ok_or("failed to downcast to ListTagsForResourceInput")?;

-247
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-262
+    }
-263
+}
-264
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-267
 /// Error type for the `ListTagsForResourceError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ListTagsForResourceError {
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-283
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-285
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ListTagsForResourceError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-288
+}
 impl ListTagsForResourceError {
     /// Creates the `ListTagsForResourceError::Unhandled` variant from any error type.

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/resume_batch_load_task.rs

@@ -227,227 +288,290 @@

↥ Expand context

-227
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for ResumeBatchLoadTaskEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "ResumeBatchLoadTaskEndpointParamsInterceptor"
-231
+    }
-232
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<ResumeBatchLoadTaskInput>()
             .ok_or("failed to downcast to ResumeBatchLoadTaskInput")?;

-247
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-262
+    }
-263
+}
-264
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-267
 /// Error type for the `ResumeBatchLoadTaskError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum ResumeBatchLoadTaskError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-287
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-289
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-ResumeBatchLoadTaskError) for what information is available for the error.")]

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/tag_resource.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for TagResourceEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "TagResourceEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<TagResourceInput>()
             .ok_or("failed to downcast to TagResourceInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `TagResourceError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum TagResourceError {
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>The instance quota of resource exceeded for this account.</p>
     ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-277
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-279
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-TagResourceError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-282
+}

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/untag_resource.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UntagResourceEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "UntagResourceEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<UntagResourceInput>()
             .ok_or("failed to downcast to UntagResourceInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `UntagResourceError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum UntagResourceError {
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>The instance quota of resource exceeded for this account.</p>
     ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-277
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-279
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-UntagResourceError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-282
+}

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/update_database.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateDatabaseEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "UpdateDatabaseEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<UpdateDatabaseInput>()
             .ok_or("failed to downcast to UpdateDatabaseInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `UpdateDatabaseError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum UpdateDatabaseError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>The instance quota of resource exceeded for this account.</p>
     ServiceQuotaExceededException(crate::types::error::ServiceQuotaExceededException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-281
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/update_table.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for UpdateTableEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "UpdateTableEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<UpdateTableInput>()
             .ok_or("failed to downcast to UpdateTableInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `UpdateTableError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum UpdateTableError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFoundException(crate::types::error::ResourceNotFoundException),
     /// <p>Too many requests were made by a user and they exceeded the service quotas. The request was throttled.</p>
     ThrottlingException(crate::types::error::ThrottlingException),
     /// <p>An invalid or malformed request.</p>
     ValidationException(crate::types::error::ValidationException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-279
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-281
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-UpdateTableError) for what information is available for the error.")]

tmp-codegen-diff/aws-sdk/sdk/timestreamwrite/src/operation/write_records.rs

@@ -219,219 +280,282 @@

↥ Expand context

-219
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for WriteRecordsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "WriteRecordsEndpointParamsInterceptor"
-223
+    }
-224
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<WriteRecordsInput>()
             .ok_or("failed to downcast to WriteRecordsInput")?;

-239
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-254
+    }
-255
+}
-256
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-259
 /// Error type for the `WriteRecordsError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum WriteRecordsError {
     /// <p>You are not authorized to perform this action.</p>
     AccessDeniedException(crate::types::error::AccessDeniedException),
     /// <p>Timestream was unable to fully process this request because of an internal server error.</p>
     InternalServerException(crate::types::error::InternalServerException),
     /// <p>The requested endpoint was not valid.</p>
     InvalidEndpointException(crate::types::error::InvalidEndpointException),
     /// <p>WriteRecords would throw this exception in the following cases:</p>
     /// <ul>
     /// <li>
     /// <p>Records with duplicate data where there are multiple records with the same dimensions, timestamps, and measure names but:</p>
     /// <ul>
     /// <li>
     /// <p>Measure values are different</p></li>
     /// <li>
     /// <p>Version is not present in the request <i>or</i> the value of version in the new record is equal to or lower than the existing value</p></li>
     /// </ul>
     /// <p>In this case, if Timestream rejects data, the <code>ExistingVersion</code> field in the <code>RejectedRecords</code> response will indicate the current record’s version. To force an update, you can resend the request with a version for the record set to a value greater than the <code>ExistingVersion</code>.</p></li>
     /// <li>
     /// <p>Records with timestamps that lie outside the retention duration of the memory store.</p></li>

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/Cargo.toml

@@ -1,1 +54,54 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-transcribestreaming"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon Transcribe Streaming Service"
 edition = "2021"
 license = "Apache-2.0"

 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.86.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]
 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.6"
 version = "1.2.7"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["event-stream"]
 version = "1.5.10"
 version = "1.5.11"
-25
 [dependencies.aws-sigv4]
 path = "../aws-sigv4"
 version = "1.3.4"
-29
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.5"
-33
 [dependencies.aws-smithy-eventstream]

↧ Expand context

 path = "../aws-smithy-eventstream"
 version = "0.60.11"
-37
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 features = ["event-stream"]
 version = "0.62.3"
-42
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.5"
-46
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.9.2"
-51
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]

@@ -64,64 +129,129 @@

↥ Expand context

 version = "1.3.8"
-65
 [dependencies.bytes]
 version = "1.4.0"
-68
 [dependencies.fastrand]
 version = "2.0.0"
-71
 [dependencies.http]
 version = "0.2.9"
-74
 [dependencies.hyper]
 version = "0.14.26"
 features = ["stream"]
-78
 [dependencies.regex-lite]
 version = "0.1.5"
-81
 [dependencies.tracing]
 version = "0.1"

 [dev-dependencies.async-stream]
 version = "0.3.0"
-86
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.8.7"
-90
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.6"
 version = "1.2.7"
-95
 [dev-dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["test-util"]
 version = "1.5.10"
 version = "1.5.11"
-100
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.5"
-105
 [dev-dependencies.aws-smithy-eventstream]
 path = "../aws-smithy-eventstream"
 features = ["test-util"]
 version = "0.60.11"

↧ Expand context

-110
 [dev-dependencies.aws-smithy-http-client]
 path = "../aws-smithy-http-client"
 features = ["test-util", "wire-mock"]
 version = "1.1.1"
-115
 [dev-dependencies.aws-smithy-protocol-test]
 path = "../aws-smithy-protocol-test"
 version = "0.63.4"
-119
 [dev-dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["test-util"]
 version = "1.9.2"
-124
 [dev-dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["test-util"]
 version = "1.9.0"
-129

tmp-codegen-diff/aws-sdk/sdk/transcribestreaming/src/operation/start_call_analytics_stream_transcription.rs

@@ -249,249 +310,312 @@

↥ Expand context

-249
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for StartCallAnalyticsStreamTranscriptionEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "StartCallAnalyticsStreamTranscriptionEndpointParamsInterceptor"
-253
+    }
-254
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<StartCallAnalyticsStreamTranscriptionInput>()
             .ok_or("failed to downcast to StartCallAnalyticsStreamTranscriptionInput")?;

-269
         let params = crate::config::endpoint::Params::builder()
             .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
             .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
             .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
             .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
             .build()
             .map_err(|err| {
                 ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
             })?;
-+
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
-+
         ::std::result::Result::Ok(())
-284
+    }
-285
+}
-286
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-289
 /// Error type for the `StartCallAnalyticsStreamTranscriptionError` operation.
 #[non_exhaustive]
 #[derive(::std::fmt::Debug)]

↧ Expand context

 pub enum StartCallAnalyticsStreamTranscriptionError {
     /// <p>The service is currently unavailable. Try your request later.</p>
     ServiceUnavailableException(crate::types::error::ServiceUnavailableException),
     /// <p>One or more arguments to the <code>StartStreamTranscription</code>, <code>StartMedicalStreamTranscription</code>, or <code>StartCallAnalyticsStreamTranscription</code> operation was not valid. For example, <code>MediaEncoding</code> or <code>LanguageCode</code> used not valid values. Check the specified parameters and try your request again.</p>
     BadRequestException(crate::types::error::BadRequestException),
     /// <p>A problem occurred while processing the audio. Amazon Transcribe terminated processing.</p>
     InternalFailureException(crate::types::error::InternalFailureException),
     /// <p>A new stream started with the same session ID. The current stream has been terminated.</p>
     ConflictException(crate::types::error::ConflictException),
     /// <p>Your client has exceeded one of the Amazon Transcribe limits. This is typically the audio length limit. Break your audio stream into smaller chunks and try your request again.</p>
     LimitExceededException(crate::types::error::LimitExceededException),
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-307
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-309
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-StartCallAnalyticsStreamTranscriptionError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
-312
+}

AWS SDK

Files changed: