AWS SDK

tmp-codegen-diff/aws-sdk/sdk/aws-runtime/src/endpoint_override.rs

@@ -0,1 +0,35 @@

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-+
 //! Endpoint override detection for business metrics tracking
-+
 use aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
 use aws_smithy_types::config_bag::{FrozenLayer, Layer};
-+
 use crate::sdk_feature::AwsSdkFeature;
-+
 /// Runtime plugin that tracks when a custom endpoint URL has been configured.
 #[derive(Debug, Default)]
 #[non_exhaustive]
 pub struct EndpointOverrideRuntimePlugin {
     config: Option<FrozenLayer>,
-+
+}
-+
 impl EndpointOverrideRuntimePlugin {
     /// Creates a new `EndpointOverrideRuntimePlugin` with the endpoint override feature flag set
     pub fn new_with_feature_flag() -> Self {
         let mut layer = Layer::new("endpoint_override");
         layer.store_append(AwsSdkFeature::EndpointOverride);
         Self {
             config: Some(layer.freeze()),
-+
+        }
-+
+    }
-+
+}
-+
 impl RuntimePlugin for EndpointOverrideRuntimePlugin {
     fn config(&self) -> Option<FrozenLayer> {
         self.config.clone()
-+
+    }
-+
+}

tmp-codegen-diff/aws-sdk/sdk/aws-runtime/src/lib.rs

@@ -1,1 +53,56 @@

↥ Expand context

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 /* Automatically managed default lints */
 #![cfg_attr(docsrs, feature(doc_cfg))]
 /* End of automatically managed default lints */
 //! Runtime support code for the AWS SDK. This crate isn't intended to be used directly.
-10
 #![warn(
     missing_docs,
     rustdoc::missing_crate_level_docs,
     missing_debug_implementations,
     rust_2018_idioms,
     unreachable_pub
 )]
-18

 /// Supporting code for authentication in the AWS SDK.
 pub mod auth;
-21
 /// AWS-specific content-encoding tools
 #[cfg(feature = "http-02x")]
 pub mod content_encoding;
-25
 /// Supporting code for recursion detection in the AWS SDK.
 pub mod recursion_detection;
-28
 /// Supporting code for endpoint override detection in the AWS SDK.
 pub mod endpoint_override;
-+
 /// Supporting code for user agent headers in the AWS SDK.
 pub mod user_agent;
-34
 /// Supporting code for retry behavior specific to the AWS SDK.
 pub mod retries;
-37
 /// Supporting code for invocation ID headers in the AWS SDK.
 pub mod invocation_id;
-40
 /// Supporting code for request metadata headers in the AWS SDK.

↧ Expand context

 pub mod request_info;
-43
 /// AWS SDK feature identifies.
 #[doc(hidden)]
 pub mod sdk_feature;
-47
 /// Interceptor that determines the clock skew between the client and service.
 pub mod service_clock_skew;
-50
 /// Filesystem utilities
 pub mod fs_util;
-53
 /// Supporting code for parsing AWS config values set in a user's environment or
 /// in a shared config file.
 pub mod env_config;

tmp-codegen-diff/aws-sdk/sdk/aws-runtime/src/sdk_feature.rs

@@ -1,1 +31,33 @@

↥ Expand context

 /*
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0
  */
-5
 /// Note: This code originally lived in the `aws-runtime` crate. It was moved here to avoid circular dependencies
 /// This module is re-exported in `aws-runtime`, and so even though this is a pre-1.0 crate, this module should not
 /// have any breaking changes
 use aws_smithy_types::config_bag::{Storable, StoreAppend};
-10
 /// IDs for the features that may be used in the AWS SDK
 #[non_exhaustive]
 #[derive(Clone, Debug, Eq, PartialEq)]
 pub enum AwsSdkFeature {
     /// An operation called with account ID mode set to preferred
     AccountIdModePreferred,

     /// An operation called with account ID mode set to disabled
     AccountIdModeDisabled,
     /// An operation called with account ID mode set to required
     AccountIdModeRequired,
     /// Indicates that an operation was called by the S3 Transfer Manager
     S3Transfer,
     /// Calling an SSO-OIDC operation as part of the SSO login flow, when using the OAuth2.0 device code grant
     SsoLoginDevice,
     /// Calling an SSO-OIDC operation as part of the SSO login flow, when using the OAuth2.0 authorization code grant
     SsoLoginAuth,
     /// Indicates that a custom endpoint URL was configured
     EndpointOverride,
-29
+}
-30
 impl Storable for AwsSdkFeature {
     type Storer = StoreAppend<Self>;
-33
+}

tmp-codegen-diff/aws-sdk/sdk/aws-runtime/src/user_agent/metrics.rs

@@ -207,207 +266,267 @@

↥ Expand context

             FlexibleChecksumsResWhenSupported => {
                 Some(BusinessMetric::FlexibleChecksumsResWhenSupported)
-209
+            }
             FlexibleChecksumsResWhenRequired => {
                 Some(BusinessMetric::FlexibleChecksumsResWhenRequired)
-212
+            }
             otherwise => {
                 // This may occur if a customer upgrades only the `aws-smithy-runtime-api` crate
                 // while continuing to use an outdated version of an SDK crate or the `aws-runtime`
                 // crate.
                 tracing::warn!(
                     "Attempted to provide `BusinessMetric` for `{otherwise:?}`, which is not recognized in the current version of the `aws-runtime` crate. \
                     Consider upgrading to the latest version to ensure that all tracked features are properly reported in your metrics."
                 );
                 None
-222
+            }
-223
+        }
-224
+    }
-225
+}
-226

 impl ProvideBusinessMetric for AwsSdkFeature {
     fn provide_business_metric(&self) -> Option<BusinessMetric> {
         use AwsSdkFeature::*;
         match self {
             AccountIdModePreferred => Some(BusinessMetric::AccountIdModePreferred),
             AccountIdModeDisabled => Some(BusinessMetric::AccountIdModeDisabled),
             AccountIdModeRequired => Some(BusinessMetric::AccountIdModeRequired),
             S3Transfer => Some(BusinessMetric::S3Transfer),
             SsoLoginDevice => Some(BusinessMetric::SsoLoginDevice),
             SsoLoginAuth => Some(BusinessMetric::SsoLoginAuth),
             EndpointOverride => Some(BusinessMetric::EndpointOverride),
-238
+        }
-239
+    }
-240
+}
-241
 impl ProvideBusinessMetric for AwsCredentialFeature {
     fn provide_business_metric(&self) -> Option<BusinessMetric> {
         use AwsCredentialFeature::*;
         match self {
             ResolvedAccountId => Some(BusinessMetric::ResolvedAccountId),
             CredentialsCode => Some(BusinessMetric::CredentialsCode),

↧ Expand context

             CredentialsEnvVars => Some(BusinessMetric::CredentialsEnvVars),
             CredentialsEnvVarsStsWebIdToken => {
                 Some(BusinessMetric::CredentialsEnvVarsStsWebIdToken)
-251
+            }
             CredentialsStsAssumeRole => Some(BusinessMetric::CredentialsStsAssumeRole),
             CredentialsStsAssumeRoleSaml => Some(BusinessMetric::CredentialsStsAssumeRoleSaml),
             CredentialsStsAssumeRoleWebId => Some(BusinessMetric::CredentialsStsAssumeRoleWebId),
             CredentialsStsFederationToken => Some(BusinessMetric::CredentialsStsFederationToken),
             CredentialsStsSessionToken => Some(BusinessMetric::CredentialsStsSessionToken),
             CredentialsProfile => Some(BusinessMetric::CredentialsProfile),
             CredentialsProfileSourceProfile => {
                 Some(BusinessMetric::CredentialsProfileSourceProfile)
-260
+            }
             CredentialsProfileNamedProvider => {
                 Some(BusinessMetric::CredentialsProfileNamedProvider)
-263
+            }
             CredentialsProfileStsWebIdToken => {
                 Some(BusinessMetric::CredentialsProfileStsWebIdToken)
-266
+            }
             CredentialsProfileSso => Some(BusinessMetric::CredentialsProfileSso),

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

@@ -1430,1430 +1489,1501 @@

↥ Expand context

                 .freeze(),
             components,
-1432
+        }
-1433
+    }
-1434
+}
-1435
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1439
+    }
-1440
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1446
+    }
-1447
+}
-1448
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1452
 pub use ::aws_credential_types::Credentials;
-1454
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("Bedrock Runtime", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("Bedrock Runtime", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1486
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1491
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1499
+        }
-1500
         if let Some(cache) = input.identity_cache() {

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

@@ -1381,1381 +1440,1452 @@

↥ Expand context

                 .freeze(),
             components,
-1383
+        }
-1384
+    }
-1385
+}
-1386
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1390
+    }
-1391
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1397
+    }
-1398
+}
-1399
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1403
 pub use ::aws_credential_types::Credentials;
-1405
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("CloudWatch Logs", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("CloudWatch Logs", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1437
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1442
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1450
+        }
-1451
         if let Some(cache) = input.identity_cache() {

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

@@ -1370,1370 +1429,1441 @@

↥ Expand context

         Self {
             config: ::aws_smithy_types::config_bag::Layer::from(layer)
                 .with_name("aws_sdk_codecatalyst::config::ConfigOverrideRuntimePlugin")
                 .freeze(),
             components,
-1375
+        }
-1376
+    }
-1377
+}
-1378
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1382
+    }
-1383
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1389
+    }

-1390
+}
-1391
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;
 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1395
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("CodeCatalyst", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("CodeCatalyst", "AWS_ENDPOINT_URL", "endpoint_url"))
                             .map(|it| it.parse().unwrap())

↧ Expand context

                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1425
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1430
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1438
+        }
-1439
         if let Some(cache) = input.identity_cache() {
             builder.set_identity_cache(cache);

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

@@ -1363,1363 +1422,1434 @@

↥ Expand context

                 .freeze(),
             components,
-1365
+        }
-1366
+    }
-1367
+}
-1368
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1372
+    }
-1373
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1379
+    }
-1380
+}
-1381
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1385
 pub use ::aws_credential_types::Credentials;
-1387
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("Config Service", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("Config Service", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1419
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1424
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1432
+        }
-1433
         if let Some(cache) = input.identity_cache() {

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

@@ -1396,1396 +1455,1467 @@

↥ Expand context

                 .freeze(),
             components,
-1398
+        }
-1399
+    }
-1400
+}
-1401
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1405
+    }
-1406
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1412
+    }
-1413
+}
-1414
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1418
 pub use ::aws_credential_types::Credentials;
-1420
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("DynamoDB", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("DynamoDB", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1452
+        }
         builder.set_account_id_endpoint_mode(input.account_id_endpoint_mode().cloned());
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1458
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1466
+        }
-1467

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

@@ -1381,1381 +1440,1452 @@

↥ Expand context

                 .freeze(),
             components,
-1383
+        }
-1384
+    }
-1385
+}
-1386
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1390
+    }
-1391
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1397
+    }
-1398
+}
-1399
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1403
 pub use ::aws_credential_types::Credentials;
-1405
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("EC2", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("EC2", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1437
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1442
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1450
+        }
-1451
         if let Some(cache) = input.identity_cache() {

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

@@ -1381,1381 +1440,1452 @@

↥ Expand context

                 .freeze(),
             components,
-1383
+        }
-1384
+    }
-1385
+}
-1386
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1390
+    }
-1391
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1397
+    }
-1398
+}
-1399
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1403
 pub use ::aws_credential_types::Credentials;
-1405
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("ECS", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("ECS", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1437
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1442
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1450
+        }
-1451
         if let Some(cache) = input.identity_cache() {

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

@@ -1364,1364 +1423,1435 @@

↥ Expand context

                 .freeze(),
             components,
-1366
+        }
-1367
+    }
-1368
+}
-1369
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1373
+    }
-1374
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1380
+    }
-1381
+}
-1382
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1386
 pub use ::aws_credential_types::Credentials;
-1388
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("Glacier", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("Glacier", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1420
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1425
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1433
+        }
-1434
         if let Some(cache) = input.identity_cache() {

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

@@ -1363,1363 +1422,1434 @@

↥ Expand context

                 .freeze(),
             components,
-1365
+        }
-1366
+    }
-1367
+}
-1368
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1372
+    }
-1373
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1379
+    }
-1380
+}
-1381
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1385
 pub use ::aws_credential_types::Credentials;
-1387
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("IAM", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("IAM", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1419
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1424
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1432
+        }
-1433
         if let Some(cache) = input.identity_cache() {

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

@@ -1363,1363 +1422,1434 @@

↥ Expand context

                 .freeze(),
             components,
-1365
+        }
-1366
+    }
-1367
+}
-1368
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1372
+    }
-1373
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1379
+    }
-1380
+}
-1381
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1385
 pub use ::aws_credential_types::Credentials;
-1387
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("KMS", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("KMS", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1419
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1424
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1432
+        }
-1433
         if let Some(cache) = input.identity_cache() {

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

@@ -1363,1363 +1422,1434 @@

↥ Expand context

                 .freeze(),
             components,
-1365
+        }
-1366
+    }
-1367
+}
-1368
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         Some(self.config.clone())
-1372
+    }
-1373
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         ::std::borrow::Cow::Borrowed(&self.components)
-1379
+    }
-1380
+}
-1381
 pub use ::aws_smithy_runtime::client::identity::IdentityCache;

 pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 pub use ::aws_smithy_types::config_bag::ConfigBag;
-1385
 pub use ::aws_credential_types::Credentials;
-1387
 impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
     fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
         let mut builder = Builder::default();
         builder.set_credentials_provider(input.credentials_provider());
         builder = builder.region(input.region().cloned());
         // Track endpoint override metric if endpoint URL is configured from any source
         let has_global_endpoint = input.endpoint_url().is_some();
         let has_service_specific_endpoint = input
             .service_config()
             .and_then(|conf| conf.load_config(service_config_key("Lambda", "AWS_ENDPOINT_URL", "endpoint_url")))
             .is_some();
-+
         if has_global_endpoint || has_service_specific_endpoint {
             builder.push_runtime_plugin(::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin::new(
                 ::aws_runtime::endpoint_override::EndpointOverrideRuntimePlugin::new_with_feature_flag(),
             ));
-+
+        }
         builder.set_use_fips(input.use_fips());
         builder.set_use_dual_stack(input.use_dual_stack());
         if input.get_origin("endpoint_url").is_client_config() {
             builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
         } else {
             builder.set_endpoint_url(
                 input
                     .service_config()
                     .and_then(|conf| {
                         conf.load_config(service_config_key("Lambda", "AWS_ENDPOINT_URL", "endpoint_url"))

↧ Expand context

                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),
             );
-1419
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1424
         builder.set_http_client(input.http_client());
         builder.set_time_source(input.time_source());
         builder.set_behavior_version(input.behavior_version());
         builder.set_auth_scheme_preference(input.auth_scheme_preference().cloned());
         // setting `None` here removes the default
         if let Some(config) = input.stalled_stream_protection() {
             builder.set_stalled_stream_protection(Some(config));
-1432
+        }
-1433
         if let Some(cache) = input.identity_cache() {

AWS SDK

Files changed: