AWS SDK

rev. daaaaae30b6928be97b33eccac35ffadde7c457d (ignoring whitespace)

Files changed:

tmp-codegen-diff/aws-sdk/sdk/aws-smithy-runtime/src/client/defaults.rs

@@ -1,1 +48,48 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 //! Runtime plugins that provide defaults for clients.
 //!

 //! Note: these are the absolute base-level defaults. They may not be the defaults
 //! for _your_ client, since many things can change these defaults on the way to
 //! code generating and constructing a full client.
-11
 use crate::client::http::body::content_length_enforcement::EnforceContentLengthRuntimePlugin;
 use crate::client::identity::IdentityCache;
 use crate::client::retries::strategy::standard::TokenBucketProvider;
 use crate::client::retries::strategy::StandardRetryStrategy;
 use crate::client::retries::RetryPartition;
 use aws_smithy_async::rt::sleep::default_async_sleep;
 use aws_smithy_async::time::SystemTimeSource;
 use aws_smithy_async::time::{SharedTimeSource, SystemTimeSource, TimeSource};
 use aws_smithy_runtime_api::box_error::BoxError;
 use aws_smithy_runtime_api::client::behavior_version::BehaviorVersion;
 use aws_smithy_runtime_api::client::http::SharedHttpClient;
 use aws_smithy_runtime_api::client::runtime_components::{
     RuntimeComponentsBuilder, SharedConfigValidator,
 };
 use aws_smithy_runtime_api::client::runtime_plugin::{
     Order, SharedRuntimePlugin, StaticRuntimePlugin,
 };
 use aws_smithy_runtime_api::client::stalled_stream_protection::StalledStreamProtectionConfig;

↧ Expand context

 use aws_smithy_runtime_api::shared::IntoShared;
 use aws_smithy_types::config_bag::{ConfigBag, FrozenLayer, Layer};
 use aws_smithy_types::retry::RetryConfig;
 use aws_smithy_types::timeout::TimeoutConfig;
 use std::borrow::Cow;
 use std::time::Duration;
-35
 fn default_plugin<CompFn>(name: &'static str, components_fn: CompFn) -> StaticRuntimePlugin
 where
     CompFn: FnOnce(RuntimeComponentsBuilder) -> RuntimeComponentsBuilder,
-39
+{
     StaticRuntimePlugin::new()
         .with_order(Order::Defaults)
         .with_runtime_components((components_fn)(RuntimeComponentsBuilder::new(name)))
-43
+}
-44
 fn layer<LayerFn>(name: &'static str, layer_fn: LayerFn) -> FrozenLayer
 where
     LayerFn: FnOnce(&mut Layer),
-48
+{

@@ -99,99 +170,207 @@

↥ Expand context

-99
     _default.map(|default| {
         default_plugin("default_http_client_plugin", |components| {
             components.with_http_client(Some(default))
         })
         .into_shared()
     })
-106
+}
-107
 /// Runtime plugin that provides a default async sleep implementation.
 pub fn default_sleep_impl_plugin() -> Option<SharedRuntimePlugin> {
     default_async_sleep().map(|default| {
         default_plugin("default_sleep_impl_plugin", |components| {
             components.with_sleep_impl(Some(default))
         })
         .into_shared()
     })
-116
+}
-117
 /// Runtime plugin that provides a default time source.

 pub fn default_time_source_plugin() -> Option<SharedRuntimePlugin> {
     Some(
         default_plugin("default_time_source_plugin", |components| {
             components.with_time_source(Some(SystemTimeSource::new()))
         })
         .into_shared(),
-125
+    )
-126
+}
-127
 /// Runtime plugin that sets the default retry strategy, config (disabled), and partition.
 #[deprecated = "Use default_retry_config_plugin_v2 to get a TokenBucket that respects the user provided TimeSource."]
 pub fn default_retry_config_plugin(
     default_partition_name: impl Into<Cow<'static, str>>,
 ) -> Option<SharedRuntimePlugin> {
     let retry_partition = RetryPartition::new(default_partition_name);
     Some(
         default_plugin("default_retry_config_plugin", |components| {
             components
                 .with_retry_strategy(Some(StandardRetryStrategy::new()))
                 .with_config_validator(SharedConfigValidator::base_client_config_fn(
                     validate_retry_config,
                 ))
                 .with_interceptor(TokenBucketProvider::new(retry_partition.clone()))
                 .with_interceptor(TokenBucketProvider::new(
                     retry_partition.clone(),
                     SharedTimeSource::default(), // Replicates previous behavior
                 ))
         })
         .with_config(layer("default_retry_config", |layer| {
             layer.store_put(RetryConfig::disabled());
             layer.store_put(retry_partition);
         }))
         .into_shared(),
-+
+    )
-+
+}
-+
 /// Runtime plugin that sets the default retry strategy, config (disabled), and partition.
 pub fn default_retry_config_plugin_v2(
     default_plugin_params: &DefaultPluginParams,
 ) -> Option<SharedRuntimePlugin> {
     let retry_partition = RetryPartition::new(
         default_plugin_params
             .retry_partition_name()
             .clone()
             .expect("retry_partition_name is required"),
     );
     Some(
         default_plugin("default_retry_config_plugin", |components| {
             components
                 .with_retry_strategy(Some(StandardRetryStrategy::new()))
                 .with_config_validator(SharedConfigValidator::base_client_config_fn(
                     validate_retry_config,
                 ))
                 .with_interceptor(TokenBucketProvider::new(
                     retry_partition.clone(),
                     default_plugin_params
                         .time_source
                         .clone()
                         .unwrap_or_default(),
                 ))
         })
         .with_config(layer("default_retry_config", |layer| {
             layer.store_put(RetryConfig::disabled());
             layer.store_put(retry_partition);
         }))
         .into_shared(),
-184
+    )
-185
+}
-186
 fn validate_retry_config(

↧ Expand context

     components: &RuntimeComponentsBuilder,
     cfg: &ConfigBag,
 ) -> Result<(), BoxError> {
     if let Some(retry_config) = cfg.load::<RetryConfig>() {
         if retry_config.has_retry() && components.sleep_impl().is_none() {
             Err("An async sleep implementation is required for retry to work. Please provide a `sleep_impl` on \
                  the config, or disable timeouts.".into())
         } else {
             Ok(())
-197
+        }
     } else {
         Err(
             "The default retry config was removed, and no other config was put in its place."
                 .into(),
-202
+        )
-203
+    }
-204
+}
-205
 /// Runtime plugin that sets the default timeout config (no timeouts).
 pub fn default_timeout_config_plugin() -> Option<SharedRuntimePlugin> {

@@ -261,298 +357,412 @@

↥ Expand context

             if components.sleep_impl().is_none() {
                 return Err(
                     "An async sleep implementation is required for stalled stream protection to work. \
                      Please provide a `sleep_impl` on the config, or disable stalled stream protection.".into());
-302
+            }
-303
             if components.time_source().is_none() {
                 return Err(
                     "A time source is required for stalled stream protection to work.\
                      Please provide a `time_source` on the config, or disable stalled stream protection.".into());
-308
+            }
-309
+        }
-310
         Ok(())
     } else {
         Err(
             "The default stalled stream protection config was removed, and no other config was put in its place."
                 .into(),
-316
+        )
-317
+    }

-318
+}
-319
 /// Arguments for the [`default_plugins`] method.
 ///
 /// This is a struct to enable adding new parameters in the future without breaking the API.
 #[non_exhaustive]
 #[derive(Debug, Default)]
 pub struct DefaultPluginParams {
     retry_partition_name: Option<Cow<'static, str>>,
     behavior_version: Option<BehaviorVersion>,
     time_source: Option<SharedTimeSource>,
-329
+}
-330
 impl DefaultPluginParams {
     /// Creates a new [`DefaultPluginParams`].
     pub fn new() -> Self {
         Default::default()
-335
+    }
-336
     /// Sets the retry partition name.
     pub fn with_retry_partition_name(mut self, name: impl Into<Cow<'static, str>>) -> Self {
         self.retry_partition_name = Some(name.into());
         self
-341
+    }
-342
     /// Gets the retry partition name.
     pub fn retry_partition_name(&self) -> &Option<Cow<'static, str>> {
         &self.retry_partition_name
-+
+    }
-+
     /// Sets the behavior major version.
     pub fn with_behavior_version(mut self, version: BehaviorVersion) -> Self {
         self.behavior_version = Some(version);
         self
-352
+    }
-+
     /// Gets the behavior major version.
     pub fn behavior_version(&self) -> &Option<BehaviorVersion> {
         &self.behavior_version
-+
+    }
-+
     /// Sets the time_source.
     pub fn with_time_source(mut self, time_source: impl TimeSource + 'static) -> Self {
         self.time_source = Some(SharedTimeSource::new(time_source));
         self
-+
+    }
-+
     /// Gets the time_source.
     pub fn time_source(&self) -> &Option<SharedTimeSource> {
         &self.time_source
-+
+    }
-369
+}
-370
 /// All default plugins.
 pub fn default_plugins(
     params: DefaultPluginParams,
 ) -> impl IntoIterator<Item = SharedRuntimePlugin> {
     let behavior_version = params
         .behavior_version
         .unwrap_or_else(BehaviorVersion::latest);
-378
-379
+    [
         default_http_client_plugin_v2(behavior_version),
         default_identity_cache_plugin(),
         default_retry_config_plugin(
             params
                 .retry_partition_name
                 .expect("retry_partition_name is required"),
         ),
         default_retry_config_plugin_v2(&params),
         default_sleep_impl_plugin(),
         default_time_source_plugin(),
         default_timeout_config_plugin(),
         enforce_content_length_runtime_plugin(),
         default_stalled_stream_protection_config_plugin_v2(behavior_version),
-388
+    ]
     .into_iter()
     .flatten()
     .collect::<Vec<SharedRuntimePlugin>>()
-392
+}

↧ Expand context

-393
 #[cfg(test)]
 mod tests {
     use super::*;
     use aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins;
-398
     fn test_plugin_params(version: BehaviorVersion) -> DefaultPluginParams {
         DefaultPluginParams::new()
             .with_behavior_version(version)
             .with_retry_partition_name("dontcare")
-403
+    }
     fn config_for(plugins: impl IntoIterator<Item = SharedRuntimePlugin>) -> ConfigBag {
         let mut config = ConfigBag::base();
         let plugins = RuntimePlugins::new().with_client_plugins(plugins);
         plugins.apply_client_configuration(&mut config).unwrap();
         config
-409
+    }
-410
     #[test]
     #[allow(deprecated)]

tmp-codegen-diff/aws-sdk/sdk/aws-smithy-runtime/src/client/retries/strategy/standard.rs

@@ -1,1 +38,39 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 use std::sync::Mutex;
 use std::time::{Duration, SystemTime};
-8
 use aws_smithy_async::time::SharedTimeSource;
 use tokio::sync::OwnedSemaphorePermit;
 use tracing::{debug, trace};
-12
 use aws_smithy_runtime_api::box_error::BoxError;
 use aws_smithy_runtime_api::client::interceptors::context::{
     BeforeTransmitInterceptorContextMut, InterceptorContext,
 };
 use aws_smithy_runtime_api::client::interceptors::Intercept;
 use aws_smithy_runtime_api::client::retries::classifiers::{RetryAction, RetryReason};
 use aws_smithy_runtime_api::client::retries::{RequestAttempts, RetryStrategy, ShouldAttempt};

↧ Expand context

 use aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 use aws_smithy_types::config_bag::{ConfigBag, Layer, Storable, StoreReplace};
 use aws_smithy_types::retry::{ErrorKind, RetryConfig, RetryMode};
-23
 use crate::client::retries::classifiers::run_classifiers_on_ctx;
 use crate::client::retries::client_rate_limiter::{ClientRateLimiter, RequestReason};
 use crate::client::retries::strategy::standard::ReleaseResult::{
     APermitWasReleased, NoPermitWasReleased,
 };
 use crate::client::retries::token_bucket::TokenBucket;
 use crate::client::retries::{ClientRateLimiterPartition, RetryPartition, RetryPartitionInner};
 use crate::static_partition_map::StaticPartitionMap;
-32
 static CLIENT_RATE_LIMITER: StaticPartitionMap<ClientRateLimiterPartition, ClientRateLimiter> =
     StaticPartitionMap::new();
-35
 /// Used by token bucket interceptor to ensure a TokenBucket always exists in config bag
 static TOKEN_BUCKET: StaticPartitionMap<RetryPartition, TokenBucket> = StaticPartitionMap::new();
-38
 /// Retry strategy with exponential backoff, max attempts, and a token bucket.

@@ -344,345 +435,444 @@

↥ Expand context

     // Apply jitter to `result`, and note that it can be applied to `max_backoff`.
     // Won't panic because `base` is either in range 0..1 or a constant 1 in testing (if configured).
     result.mul_f64(base)
-348
+}
-349
 pub(super) fn get_seconds_since_unix_epoch(runtime_components: &RuntimeComponents) -> f64 {
     let request_time = runtime_components
         .time_source()
         .expect("time source required for retries");
     request_time
         .now()
         .duration_since(SystemTime::UNIX_EPOCH)
         .unwrap()
         .as_secs_f64()
-359
+}
-360
 /// Interceptor registered in default retry plugin that ensures a token bucket exists in config
 /// bag for every operation. Token bucket provided is partitioned by the retry partition **in the
 /// config bag** at the time an operation is executed.
 #[derive(Debug)]

 pub(crate) struct TokenBucketProvider {
     default_partition: RetryPartition,
     token_bucket: TokenBucket,
-368
+}
-369
 impl TokenBucketProvider {
     /// Create a new token bucket provider with the given default retry partition.
     ///
     /// NOTE: This partition should be the one used for every operation on a client
     /// unless config is overridden.
     pub(crate) fn new(default_partition: RetryPartition) -> Self {
         let token_bucket = TOKEN_BUCKET.get_or_init_default(default_partition.clone());
     pub(crate) fn new(default_partition: RetryPartition, time_source: SharedTimeSource) -> Self {
         let token_bucket = TOKEN_BUCKET.get_or_init(default_partition.clone(), || {
             let mut tb = TokenBucket::default();
             tb.update_time_source(time_source);
             tb
         });
         Self {
             default_partition,
             token_bucket,
-384
+        }
-385
+    }
-386
+}
-387
 impl Intercept for TokenBucketProvider {
     fn name(&self) -> &'static str {
         "TokenBucketProvider"
-391
+    }
-392
     fn modify_before_retry_loop(
         &self,
         _context: &mut BeforeTransmitInterceptorContextMut<'_>,
         _runtime_components: &RuntimeComponents,
         runtime_components: &RuntimeComponents,
         cfg: &mut ConfigBag,
     ) -> Result<(), BoxError> {
         let retry_partition = cfg.load::<RetryPartition>().expect("set in default config");
-400
         let tb = match &retry_partition.inner {
             RetryPartitionInner::Default(name) => {
                 // we store the original retry partition configured and associated token bucket
                 // for the client when created so that we can avoid locking on _every_ request
                 // from _every_ client
                 if name == self.default_partition.name() {
                     // avoid contention on the global lock
                     self.token_bucket.clone()
                 } else {
                     TOKEN_BUCKET.get_or_init_default(retry_partition.clone())
                     TOKEN_BUCKET.get_or_init(retry_partition.clone(), || {
                         let mut tb = TokenBucket::default();
                         tb.update_time_source(runtime_components.time_source().unwrap_or_default());
                         tb
                     })
-415
+                }
-416
+            }
             RetryPartitionInner::Custom { token_bucket, .. } => token_bucket.clone(),
         };
-419
         trace!("token bucket for {retry_partition:?} added to config bag");
         let mut layer = Layer::new("token_bucket_partition");
         layer.store_put(tb);
         cfg.push_layer(layer);
         Ok(())

↧ Expand context

-425
+    }
-426
+}
-427
 #[cfg(test)]
 mod tests {
     #[allow(unused_imports)] // will be unused with `--no-default-features --features client`
     use std::fmt;
     use std::sync::Mutex;
     use std::time::Duration;
-434
     use aws_smithy_async::time::SystemTimeSource;
     use aws_smithy_runtime_api::client::interceptors::context::{
         Input, InterceptorContext, Output,
     };
     use aws_smithy_runtime_api::client::orchestrator::OrchestratorError;
     use aws_smithy_runtime_api::client::retries::classifiers::{
         ClassifyRetry, RetryAction, SharedRetryClassifier,
     };
     use aws_smithy_runtime_api::client::retries::{
         AlwaysRetry, RequestAttempts, RetryStrategy, ShouldAttempt,

tmp-codegen-diff/aws-sdk/sdk/aws-smithy-runtime/src/client/retries/token_bucket.rs

@@ -254,254 +313,326 @@

↥ Expand context

             // Cap fractional tokens at max_permits to prevent unbounded growth
             let new_fractional = (current + self.success_reward).min(max_fractional);
             self.fractional_tokens.store(new_fractional);
-257
+        }
-258
+    }
-259
     pub(crate) fn add_permits(&self, amount: usize) {
         let available = self.semaphore.available_permits();
         if available >= self.max_permits {
             return;
-264
+        }
         self.semaphore
             .add_permits(amount.min(self.max_permits - available));
-267
+    }
-268
     /// Returns true if the token bucket is full, false otherwise
     pub fn is_full(&self) -> bool {
         self.semaphore.available_permits() >= self.max_permits
-272
+    }
-273

     /// Returns true if the token bucket is empty, false otherwise
     pub fn is_empty(&self) -> bool {
         self.semaphore.available_permits() == 0
-277
+    }
-278
     #[allow(dead_code)] // only used in tests
     #[cfg(any(test, feature = "test-util", feature = "legacy-test-util"))]
     pub(crate) fn available_permits(&self) -> usize {
         self.semaphore.available_permits()
-283
+    }
-+
     // Allows us to create a default client but still update the time_source
     pub(crate) fn update_time_source(&mut self, new_time_source: SharedTimeSource) {
         self.time_source = new_time_source;
-+
+    }
-+
     #[allow(dead_code)]
     #[doc(hidden)]
     #[cfg(any(test, feature = "test-util", feature = "legacy-test-util"))]
     /// This method should only be used for internal testing
     pub fn time_source(&self) -> &SharedTimeSource {
         &self.time_source
-+
+    }
-297
+}
-298
 /// Builder for constructing a `TokenBucket`.
 #[derive(Clone, Debug, Default)]
 pub struct TokenBucketBuilder {
     capacity: Option<usize>,
     retry_cost: Option<u32>,
     timeout_retry_cost: Option<u32>,
     success_reward: Option<f32>,
     refill_rate: Option<f32>,

↧ Expand context

     time_source: Option<SharedTimeSource>,
-308
+}
-309
 impl TokenBucketBuilder {
     /// Creates a new `TokenBucketBuilder` with default values.
     pub fn new() -> Self {
         Self::default()
-314
+    }
-315
     /// Sets the maximum bucket capacity for the builder.
     pub fn capacity(mut self, mut capacity: usize) -> Self {
         if capacity > MAXIMUM_CAPACITY {
             capacity = MAXIMUM_CAPACITY;
-320
+        }
         self.capacity = Some(capacity);
         self
-323
+    }
-324
     /// Sets the specified retry cost for the builder.
     pub fn retry_cost(mut self, retry_cost: u32) -> Self {

tmp-codegen-diff/aws-sdk/sdk/bedrockruntime/src/config.rs

@@ -1539,1539 +1598,1599 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1541
+}
-1542
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1544
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1549
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1552
+        }
-1553
+    }
-1554
     let default_retry_partition = "bedrockruntime";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1560
     let scope = "aws-sdk-bedrockruntime";
-1562
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1576
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1587
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1590
+    }
     plugins
-1592
+}
-1593
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1595
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1597
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1599

tmp-codegen-diff/aws-sdk/sdk/cloudwatchlogs/src/config.rs

@@ -1465,1465 +1524,1525 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1467
+}
-1468
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1470
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1475
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1478
+        }
-1479
+    }
-1480
     let default_retry_partition = "cloudwatchlogs";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1486
     let scope = "aws-sdk-cloudwatchlogs";
-1488
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1502
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1513
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1516
+    }
     plugins
-1518
+}
-1519
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1521
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1523
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1525

tmp-codegen-diff/aws-sdk/sdk/codecatalyst/src/config.rs

@@ -1454,1454 +1513,1514 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1456
+}
-1457
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1459
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1464
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1467
+        }
-1468
+    }
-1469
     let default_retry_partition = "codecatalyst";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1475
     let scope = "aws-sdk-codecatalyst";
-1477
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1491
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1502
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1505
+    }
     plugins
-1507
+}
-1508
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1510
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1512
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1514

tmp-codegen-diff/aws-sdk/sdk/config/src/config.rs

@@ -1447,1447 +1506,1507 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1449
+}
-1450
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1452
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1457
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1460
+        }
-1461
+    }
-1462
     let default_retry_partition = "configservice";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1468
     let scope = "aws-sdk-config";
-1470
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1484
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1495
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1498
+    }
     plugins
-1500
+}
-1501
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1503
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1505
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1507

tmp-codegen-diff/aws-sdk/sdk/dynamodb/src/config.rs

@@ -1481,1481 +1540,1541 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1483
+}
-1484
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1486
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1491
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1494
+        }
-1495
+    }
-1496
     let default_retry_partition = "dynamodb";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1502
     let scope = "aws-sdk-dynamodb";
-1504
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1518
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1529
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1532
+    }
     plugins
-1534
+}
-1535
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1537
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1539
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1541

tmp-codegen-diff/aws-sdk/sdk/ec2/src/config.rs

@@ -1465,1465 +1524,1525 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1467
+}
-1468
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1470
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1475
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1478
+        }
-1479
+    }
-1480
     let default_retry_partition = "ec2";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1486
     let scope = "aws-sdk-ec2";
-1488
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1502
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1513
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1516
+    }
     plugins
-1518
+}
-1519
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1521
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1523
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1525

tmp-codegen-diff/aws-sdk/sdk/ecs/src/config.rs

@@ -1465,1465 +1524,1525 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1467
+}
-1468
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1470
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1475
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1478
+        }
-1479
+    }
-1480
     let default_retry_partition = "ecs";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1486
     let scope = "aws-sdk-ecs";
-1488
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1502
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1513
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1516
+    }
     plugins
-1518
+}
-1519
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1521
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1523
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1525

tmp-codegen-diff/aws-sdk/sdk/glacier/src/config.rs

@@ -1448,1448 +1507,1508 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1450
+}
-1451
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1453
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1458
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1461
+        }
-1462
+    }
-1463
     let default_retry_partition = "glacier";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1469
     let scope = "aws-sdk-glacier";
-1471
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1485
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1496
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1499
+    }
     plugins
-1501
+}
-1502
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1504
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1506
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1508

tmp-codegen-diff/aws-sdk/sdk/iam/src/config.rs

@@ -1447,1447 +1506,1507 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1449
+}
-1450
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1452
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1457
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1460
+        }
-1461
+    }
-1462
     let default_retry_partition = "iam";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1468
     let scope = "aws-sdk-iam";
-1470
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1484
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1495
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1498
+    }
     plugins
-1500
+}
-1501
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1503
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1505
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1507

tmp-codegen-diff/aws-sdk/sdk/kms/src/config.rs

@@ -1447,1447 +1506,1507 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1449
+}
-1450
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1452
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1457
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1460
+        }
-1461
+    }
-1462
     let default_retry_partition = "kms";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1468
     let scope = "aws-sdk-kms";
-1470
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1484
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1495
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1498
+    }
     plugins
-1500
+}
-1501
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1503
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1505
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1507

tmp-codegen-diff/aws-sdk/sdk/lambda/src/config.rs

@@ -1447,1447 +1506,1507 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1449
+}
-1450
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1452
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1457
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1460
+        }
-1461
+    }
-1462
     let default_retry_partition = "lambda";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1468
     let scope = "aws-sdk-lambda";
-1470
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1484
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1495
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1498
+    }
     plugins
-1500
+}
-1501
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1503
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1505
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1507

tmp-codegen-diff/aws-sdk/sdk/polly/src/config.rs

@@ -1447,1447 +1506,1507 @@

↥ Expand context

         .build()
         .expect("all field sets explicitly, can't fail")
-1449
+}
-1450
 pub use ::aws_smithy_async::rt::sleep::Sleep;
-1452
 pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
     let mut configured_plugins = ::std::vec::Vec::new();
     ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
     #[cfg(feature = "behavior-version-latest")]
-1457
+    {
         if config.behavior_version.is_none() {
             config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
-1460
+        }
-1461
+    }
-1462
     let default_retry_partition = "polly";
     let default_retry_partition = match config.region() {
         Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{region}")),
         None => ::std::borrow::Cow::from(default_retry_partition),

     };
-1468
     let scope = "aws-sdk-polly";
-1470
     let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
                         // defaults
                         .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
                             ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
                                 .with_retry_partition_name(default_retry_partition)
                                 .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                         ))
                         // user config
                         .with_client_plugin(
                             ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
                                 .with_config(config.config.clone())
                                 .with_runtime_components(config.runtime_components.clone())
-1484
+                        )
                         // codegen config
                         .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
                         .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())

↧ Expand context

                         .with_client_plugin(
                             ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
                                 .with_scope(scope)
                                 .with_time_source(config.runtime_components.time_source().unwrap_or_default())
                                 .build()
                                 .expect("All required fields have been set")
                         );
-1495
     for plugin in configured_plugins {
         plugins = plugins.with_client_plugin(plugin);
-1498
+    }
     plugins
-1500
+}
-1501
 pub use ::aws_smithy_types::config_bag::FrozenLayer;
-1503
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
-1505
 pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
-1507

Pages: 1 2