AWS SDK

rev. 2d483a0880c30683858329fc8411e9f9282de633 (ignoring whitespace)

Files changed:

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

@@ -18,18 +139,169 @@

-18
+    }
-19
+}
-20
 #[derive(Debug)]
 struct DowncastParams<T>(T);
 impl<T> ::aws_smithy_runtime_api::client::auth::ResolveAuthSchemeOptions for DowncastParams<T>
 where
     T: ResolveAuthScheme,
-26
+{
     fn resolve_auth_scheme_options_v2<'a>(
         &'a self,
         params: &'a ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams,
         cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         match params.get::<crate::config::auth::Params>() {
             ::std::option::Option::Some(concrete_params) => self.0.resolve_auth_scheme(concrete_params, cfg, runtime_components),
             ::std::option::Option::None => ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(::std::result::Result::Err(
                 "params of expected type was not present".into(),
             )),

-38
+        }
-39
+    }
-40
+}
-41
 /// The default auth scheme resolver
 #[derive(Debug)]
 #[allow(dead_code)]
 pub struct DefaultAuthSchemeResolver {
     service_defaults: Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>,
     operation_overrides: ::std::collections::HashMap<&'static str, Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>>,
     preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
-49
+}
-50
 // TODO(https://github.com/smithy-lang/smithy-rs/issues/4177): Remove `allow(...)` once the issue is addressed.
 // When generating code for tests (e.g., `codegen-client-test`), this manual implementation
 // of the `Default` trait may appear as if it could be derived automatically.
 // However, that is not the case in production.
 #[allow(clippy::derivable_impls)]
 impl Default for DefaultAuthSchemeResolver {
     fn default() -> Self {
         Self {
             service_defaults: vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                 .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                 .build()
                 .expect("required fields set")],
             operation_overrides: [
-64
+                (
                     "GetRoleCredentials",
                     vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                         ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                     )],
                 ),
-70
+                (
                     "ListAccountRoles",
                     vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                         ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                     )],
                 ),
-76
+                (
                     "ListAccounts",
                     vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                         ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                     )],
                 ),
-82
+                (
                     "Logout",
                     vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                         ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                     )],
                 ),
-88
+            ]
             .into(),
             preference: ::std::option::Option::None,
-91
+        }
-92
+    }
-93
+}
-94
 impl crate::config::auth::ResolveAuthScheme for DefaultAuthSchemeResolver {
     fn resolve_auth_scheme<'a>(
         &'a self,
         params: &'a crate::config::auth::Params,
         _cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         _runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         let operation_name = params.operation_name();
-103
         let modeled_auth_options = match self.operation_overrides.get(operation_name) {
             Some(overrides) => overrides,
             None => &self.service_defaults,
         };
-108
         let _fut = ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(Ok(modeled_auth_options.clone()));
-110
         _fut
         match &self.preference {
             ::std::option::Option::Some(preference) => {
                 _fut.map_ok({
                     // maps auth scheme ID to the index in the preference list
                     let preference_map: ::std::collections::HashMap<_, _> = preference.clone().into_iter().enumerate().map(|(i, s)| (s, i)).collect();
                     move |auth_scheme_options| {
                         let (mut preferred, non_preferred): (::std::vec::Vec<_>, ::std::vec::Vec<_>) = auth_scheme_options
                             .into_iter()
                             .partition(|auth_scheme_option| preference_map.contains_key(auth_scheme_option.scheme_id()));
-+
                         preferred.sort_by_key(|opt| preference_map.get(opt.scheme_id()).expect("guaranteed by `partition`"));
                         preferred.extend(non_preferred);
                         preferred
-+
+                    }
                 })
-+
+            }
             ::std::option::Option::None => _fut,
-+
+        }
-+
+    }
-+
+}
-+
 impl DefaultAuthSchemeResolver {
     /// Set auth scheme preference to the default auth scheme resolver
     pub fn with_auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.preference = ::std::option::Option::Some(preference.into());
         self
-140
+    }
-141
+}
-142
 /// Configuration parameters for resolving the correct auth scheme
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Params {
     operation_name: ::std::borrow::Cow<'static, str>,
-147
+}
 impl Params {
     /// Create a builder for [`Params`]

↧ Expand context

     pub fn builder() -> crate::config::auth::ParamsBuilder {
         crate::config::auth::ParamsBuilder::default()
-152
+    }
-153
     /// Return the operation name for [`Params`]
     pub fn operation_name(&self) -> &str {
         self.operation_name.as_ref()
-157
+    }
-158
+}
-159
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /// Builder for [`Params`]
 pub struct ParamsBuilder {
     operation_name: ::std::option::Option<::std::borrow::Cow<'static, str>>,
-164
+}
 impl ParamsBuilder {
     /// Set the operation name for the builder
     pub fn operation_name(self, operation_name: impl Into<::std::borrow::Cow<'static, str>>) -> Self {
         self.set_operation_name(::std::option::Option::Some(operation_name.into()))
-169
+    }

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

@@ -1,1 +83,83 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-ssooidc"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for AWS SSO OIDC"
 edition = "2021"
 license = "Apache-2.0"
 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.86.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]

 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.3"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.9"
-24
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.5"
 version = "1.3.0"
-28
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.62.1"
-32
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.4"
-36
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.8.4"
 version = "1.8.5"
-41
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.8.3"
 version = "1.8.4"
-46
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.3.2"
-50
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.7"
 version = "1.3.8"
-54
 [dependencies.bytes]
 version = "1.4.0"
-57
 [dependencies.fastrand]
 version = "2.0.0"
-60
 [dependencies.http]
 version = "0.2.9"
-63

↧ Expand context

 [dependencies.regex-lite]
 version = "0.1.5"
-66
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.3"
-73
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-77
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]
 rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]
 test-util = ["aws-credential-types/test-util", "aws-smithy-runtime/test-util"]

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

@@ -36,36 +95,99 @@

↥ Expand context

     ///
     pub fn builder() -> Builder {
         Builder::default()
-39
+    }
     /// Converts this config back into a builder so that it can be tweaked.
     pub fn to_builder(&self) -> Builder {
         Builder {
             config: self.cloneable.clone(),
             runtime_components: self.runtime_components.clone(),
             runtime_plugins: self.runtime_plugins.clone(),
             behavior_version: self.behavior_version,
-47
+        }
-48
+    }
     /// Return a reference to the stalled stream protection configuration contained in this config, if any.
     pub fn stalled_stream_protection(&self) -> ::std::option::Option<&crate::config::StalledStreamProtectionConfig> {
         self.config.load::<crate::config::StalledStreamProtectionConfig>()
-52
+    }
     /// Return the [`SharedHttpClient`](crate::config::SharedHttpClient) to use when making requests, if any.
     pub fn http_client(&self) -> Option<crate::config::SharedHttpClient> {
         self.runtime_components.http_client()

-56
+    }
     /// Return the auth schemes configured on this service config
     pub fn auth_schemes(&self) -> impl Iterator<Item = ::aws_smithy_runtime_api::client::auth::SharedAuthScheme> + '_ {
         self.runtime_components.auth_schemes()
-60
+    }
-61
     /// Return the auth scheme resolver configured on this service config
     pub fn auth_scheme_resolver(&self) -> ::std::option::Option<::aws_smithy_runtime_api::client::auth::SharedAuthSchemeOptionResolver> {
         self.runtime_components.auth_scheme_option_resolver()
-65
+    }
     /// Returns the configured auth scheme preference
     pub fn auth_scheme_preference(&self) -> ::std::option::Option<&::aws_smithy_runtime_api::client::auth::AuthSchemePreference> {
         self.config.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
-+
+    }
     /// Returns the endpoint resolver.
     pub fn endpoint_resolver(&self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver {
         self.runtime_components.endpoint_resolver().expect("resolver defaulted if not set")
-73
+    }
     /// Return a reference to the retry configuration contained in this config, if any.
     pub fn retry_config(&self) -> ::std::option::Option<&::aws_smithy_types::retry::RetryConfig> {
         self.config.load::<::aws_smithy_types::retry::RetryConfig>()
-77
+    }
-78
     /// Return a cloned shared async sleep implementation from this config, if any.

↧ Expand context

     pub fn sleep_impl(&self) -> ::std::option::Option<crate::config::SharedAsyncSleep> {
         self.runtime_components.sleep_impl()
-82
+    }
-83
     /// Return a reference to the timeout configuration contained in this config, if any.
     pub fn timeout_config(&self) -> ::std::option::Option<&::aws_smithy_types::timeout::TimeoutConfig> {
         self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>()
-87
+    }
-88
     /// Returns a reference to the retry partition contained in this config, if any.
     ///
     /// WARNING: This method is unstable and may be removed at any time. Do not rely on this
     /// method for anything!
     pub fn retry_partition(&self) -> ::std::option::Option<&::aws_smithy_runtime::client::retries::RetryPartition> {
         self.config.load::<::aws_smithy_runtime::client::retries::RetryPartition>()
-95
+    }
     /// Returns the configured identity cache for auth.
     pub fn identity_cache(&self) -> ::std::option::Option<crate::config::SharedIdentityCache> {
         self.runtime_components.identity_cache()
-99
+    }

@@ -149,153 +208,213 @@

↥ Expand context

     pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
     pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
-155
+}
 impl ::std::default::Default for Builder {
     fn default() -> Self {
         Self {
             config: ::std::default::Default::default(),
             runtime_components: crate::config::RuntimeComponentsBuilder::new("service config"),
             runtime_plugins: ::std::default::Default::default(),
             behavior_version: ::std::default::Default::default(),
-163
+        }
-164
+    }
-165
+}
 impl Builder {
     ///
     /// Constructs a config builder.
     /// <div class="warning">
     /// Note that a config created from this builder will not have the same safe defaults as one created by
     /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
     /// </div>

     ///
     pub fn new() -> Self {
         Self::default()
-176
+    }
     /// Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
     /// but not those in runtime components.
     #[allow(unused)]
     pub(crate) fn from_config_bag(config_bag: &::aws_smithy_types::config_bag::ConfigBag) -> Self {
         let mut builder = Self::new();
         builder.set_stalled_stream_protection(config_bag.load::<crate::config::StalledStreamProtectionConfig>().cloned());
         builder.set_auth_scheme_preference(config_bag.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>().cloned());
         builder.set_retry_config(config_bag.load::<::aws_smithy_types::retry::RetryConfig>().cloned());
         builder.set_timeout_config(config_bag.load::<::aws_smithy_types::timeout::TimeoutConfig>().cloned());
         builder.set_retry_partition(config_bag.load::<::aws_smithy_runtime::client::retries::RetryPartition>().cloned());
         builder.set_app_name(config_bag.load::<::aws_types::app_name::AppName>().cloned());
         builder.set_endpoint_url(config_bag.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()));
         builder.set_use_dual_stack(config_bag.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0));
         builder.set_use_fips(config_bag.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0));
         builder.set_region(config_bag.load::<crate::config::Region>().cloned());
         builder
-193
+    }

↧ Expand context

     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn stalled_stream_protection(mut self, stalled_stream_protection_config: crate::config::StalledStreamProtectionConfig) -> Self {
         self.set_stalled_stream_protection(::std::option::Option::Some(stalled_stream_protection_config));
         self
-199
+    }
     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn set_stalled_stream_protection(
         &mut self,
         stalled_stream_protection_config: ::std::option::Option<crate::config::StalledStreamProtectionConfig>,
     ) -> &mut Self {
         self.config.store_or_unset(stalled_stream_protection_config);
         self
-208
+    }
     /// Sets the HTTP client to use when making requests.
     ///
     /// # Examples
     /// ```no_run
     /// # #[cfg(test)]

@@ -398,403 +457,519 @@

↥ Expand context

     ///     fn resolve_auth_scheme<'a>(
     ///         &'a self,
     ///         _params: &'a aws_sdk_ssooidc::config::auth::Params,
     ///         _cfg: &'a ConfigBag,
     ///         _runtime_components: &'a RuntimeComponents,
     ///     ) -> AuthSchemeOptionsFuture<'a> {
     ///         // --snip--
     /// #      todo!()
     ///     }
     /// }
     ///
     /// let config = aws_sdk_ssooidc::Config::builder()
     ///     .auth_scheme_resolver(CustomAuthSchemeResolver)
     ///     // other configurations
     ///     .build();
     /// ```
     pub fn auth_scheme_resolver(mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> Self {
         self.set_auth_scheme_resolver(auth_scheme_resolver);
         self
-422
+    }

-423
     /// Set the auth scheme resolver for the builder
     ///
     /// # Examples
     /// See an example for [`Self::auth_scheme_resolver`].
     pub fn set_auth_scheme_resolver(&mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> &mut Self {
         self.runtime_components
             .set_auth_scheme_option_resolver(::std::option::Option::Some(auth_scheme_resolver.into_shared_resolver()));
         self
-432
+    }
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_ssooidc::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_ssooidc::Client::from_conf(config);
     /// ```
-+
     pub fn auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.set_auth_scheme_preference(::std::option::Option::Some(preference.into()));
         self
-+
+    }
-+
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_ssooidc::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_ssooidc::Client::from_conf(config);
     /// ```
-+
     pub fn set_auth_scheme_preference(
         &mut self,
         preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> &mut Self {
         self.config.store_or_unset(preference);
         self
-+
+    }
     /// Sets the endpoint resolver to use when making requests.
     ///
     ///
     /// When unset, the client will used a generated endpoint resolver based on the endpoint resolution
     /// rules for `aws_sdk_ssooidc`.
     ///
     ///
     /// Note: setting an endpoint resolver will replace any endpoint URL that has been set.
     /// This method accepts an endpoint resolver [specific to this service](crate::config::endpoint::ResolveEndpoint). If you want to
     /// provide a shared endpoint resolver, use [`Self::set_endpoint_resolver`].

↧ Expand context

     ///
     /// # Examples
     /// Create a custom endpoint resolver that resolves a different endpoing per-stage, e.g. staging vs. production.
     /// ```no_run
     /// use aws_sdk_ssooidc::config::endpoint::{ResolveEndpoint, EndpointFuture, Params, Endpoint};
     /// #[derive(Debug)]
     /// struct StageResolver { stage: String }
     /// impl ResolveEndpoint for StageResolver {
     ///     fn resolve_endpoint(&self, params: &Params) -> EndpointFuture<'_> {
     ///         let stage = &self.stage;
     ///         EndpointFuture::ready(Ok(Endpoint::builder().url(format!("{stage}.myservice.com")).build()))
     ///     }
     /// }
     /// let resolver = StageResolver { stage: std::env::var("STAGE").unwrap() };
     /// let config = aws_sdk_ssooidc::Config::builder().endpoint_resolver(resolver).build();
     /// let client = aws_sdk_ssooidc::Client::from_conf(config);
     /// ```
     pub fn endpoint_resolver(mut self, endpoint_resolver: impl crate::config::endpoint::ResolveEndpoint + 'static) -> Self {
         self.set_endpoint_resolver(::std::option::Option::Some(endpoint_resolver.into_shared_resolver()));
         self

@@ -1263,1325 +1323,1395 @@

↥ Expand context

             .load::<::aws_types::region::Region>()
             .cloned()
             .map(|r| layer.store_put(::aws_types::region::SigningRegion::from(r)));
         Config {
             config: crate::config::Layer::from(layer.clone())
                 .with_name("aws_sdk_ssooidc::config::Config")
                 .freeze(),
             cloneable: layer,
             runtime_components: self.runtime_components,
             runtime_plugins: self.runtime_plugins,
             behavior_version: self.behavior_version,
-1336
+        }
-1337
+    }
-1338
+}
 #[derive(::std::fmt::Debug)]
 pub(crate) struct ServiceRuntimePlugin {
     config: ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer>,
     runtime_components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
-1343
+}
-1344

 impl ServiceRuntimePlugin {
     pub fn new(_service_config: crate::config::Config) -> Self {
         let config = {
             let mut cfg = ::aws_smithy_types::config_bag::Layer::new("AWSSSOOIDCService");
             cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);
             ::std::option::Option::Some(cfg.freeze())
         };
         let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");
         runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({
             use crate::config::auth::ResolveAuthScheme;
             if let Some(preference) = _service_config
                 .config
                 .load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
                 .cloned()
-+
+            {
                 crate::config::auth::DefaultAuthSchemeResolver::default()
                     .with_auth_scheme_preference(preference)
                     .into_shared_resolver()
             } else {
                 crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()
-+
+            }
         }));
         runtime_components.set_endpoint_resolver(::std::option::Option::Some({
             use crate::config::endpoint::ResolveEndpoint;
             crate::config::endpoint::DefaultResolver::new().into_shared_resolver()
         }));
         runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());
         runtime_components.push_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::HttpStatusCodeClassifier::default());
         runtime_components.push_interceptor(crate::sdk_feature_tracker::retry_mode::RetryModeFeatureTrackerInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::service_clock_skew::ServiceClockSkewInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::request_info::RequestInfoInterceptor::new());

↧ Expand context

         runtime_components.push_interceptor(::aws_runtime::user_agent::UserAgentInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::invocation_id::InvocationIdInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::recursion_detection::RecursionDetectionInterceptor::new());
         runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(
             ::aws_runtime::auth::sigv4::SigV4AuthScheme::new(),
         ));
         Self { config, runtime_components }
-1383
+    }
-1384
+}
-1385
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ServiceRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         self.config.clone()
-1389
+    }
-1390
     fn order(&self) -> ::aws_smithy_runtime_api::client::runtime_plugin::Order {
         ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults
-1393
+    }
-1394
     fn runtime_components(

@@ -1389,1461 +1448,1521 @@

↥ Expand context

 pub use ::aws_credential_types::Credentials;
-1462
 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());
         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("AWS_ENDPOINT_URL", "endpoint_url"))
                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),

             );
-1482
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1487
         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));
-1495
+        }
-1496
         if let Some(cache) = input.identity_cache() {
             builder.set_identity_cache(cache);
-1499
+        }
         builder.set_app_name(input.app_name().cloned());
-1501

↧ Expand context

         builder
-1503
+    }
-1504
+}
-1505
 impl From<&::aws_types::sdk_config::SdkConfig> for Config {
     fn from(sdk_config: &::aws_types::sdk_config::SdkConfig) -> Self {
         Builder::from(sdk_config).build()
-1509
+    }
-1510
+}
-1511
 pub use ::aws_types::app_name::AppName;
-1513
 #[allow(dead_code)]
 fn service_config_key<'a>(env: &'a str, profile: &'a str) -> aws_types::service_config::ServiceConfigKey<'a> {
     ::aws_types::service_config::ServiceConfigKey::builder()
         .service_id("SSO OIDC")
         .env(env)
         .profile(profile)
         .build()
         .expect("all field sets explicitly, can't fail")

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

@@ -18,18 +133,163 @@

↥ Expand context

-18
+    }
-19
+}
-20
 #[derive(Debug)]
 struct DowncastParams<T>(T);
 impl<T> ::aws_smithy_runtime_api::client::auth::ResolveAuthSchemeOptions for DowncastParams<T>
 where
     T: ResolveAuthScheme,
-26
+{
     fn resolve_auth_scheme_options_v2<'a>(
         &'a self,
         params: &'a ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams,
         cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         match params.get::<crate::config::auth::Params>() {
             ::std::option::Option::Some(concrete_params) => self.0.resolve_auth_scheme(concrete_params, cfg, runtime_components),
             ::std::option::Option::None => ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(::std::result::Result::Err(
                 "params of expected type was not present".into(),
             )),

-38
+        }
-39
+    }
-40
+}
-41
 /// The default auth scheme resolver
 #[derive(Debug)]
 #[allow(dead_code)]
 pub struct DefaultAuthSchemeResolver {
     service_defaults: Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>,
     operation_overrides: ::std::collections::HashMap<&'static str, Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>>,
     preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
-49
+}
-50
 // TODO(https://github.com/smithy-lang/smithy-rs/issues/4177): Remove `allow(...)` once the issue is addressed.
 // When generating code for tests (e.g., `codegen-client-test`), this manual implementation
 // of the `Default` trait may appear as if it could be derived automatically.
 // However, that is not the case in production.
 #[allow(clippy::derivable_impls)]
 impl Default for DefaultAuthSchemeResolver {
     fn default() -> Self {
         Self {
             service_defaults: vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                 .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                 .build()
                 .expect("required fields set")],
             operation_overrides: [
-64
+                (
                     "CreateToken",
                     vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                         ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                     )],
                 ),
-70
+                (
                     "RegisterClient",
                     vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                         ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                     )],
                 ),
-76
+                (
                     "StartDeviceAuthorization",
                     vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                         ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                     )],
                 ),
-82
+            ]
             .into(),
             preference: ::std::option::Option::None,
-85
+        }
-86
+    }
-87
+}
-88
 impl crate::config::auth::ResolveAuthScheme for DefaultAuthSchemeResolver {
     fn resolve_auth_scheme<'a>(
         &'a self,
         params: &'a crate::config::auth::Params,
         _cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         _runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         let operation_name = params.operation_name();
-97
         let modeled_auth_options = match self.operation_overrides.get(operation_name) {
             Some(overrides) => overrides,
             None => &self.service_defaults,
         };
-102
         let _fut = ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(Ok(modeled_auth_options.clone()));
-104
         _fut
         match &self.preference {
             ::std::option::Option::Some(preference) => {
                 _fut.map_ok({
                     // maps auth scheme ID to the index in the preference list
                     let preference_map: ::std::collections::HashMap<_, _> = preference.clone().into_iter().enumerate().map(|(i, s)| (s, i)).collect();
                     move |auth_scheme_options| {
                         let (mut preferred, non_preferred): (::std::vec::Vec<_>, ::std::vec::Vec<_>) = auth_scheme_options
                             .into_iter()
                             .partition(|auth_scheme_option| preference_map.contains_key(auth_scheme_option.scheme_id()));
-+
                         preferred.sort_by_key(|opt| preference_map.get(opt.scheme_id()).expect("guaranteed by `partition`"));
                         preferred.extend(non_preferred);
                         preferred
-+
+                    }
                 })
-+
+            }
             ::std::option::Option::None => _fut,
-+
+        }
-+
+    }
-+
+}
-+
 impl DefaultAuthSchemeResolver {
     /// Set auth scheme preference to the default auth scheme resolver
     pub fn with_auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.preference = ::std::option::Option::Some(preference.into());
         self
-134
+    }
-135
+}
-136
 /// Configuration parameters for resolving the correct auth scheme
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Params {
     operation_name: ::std::borrow::Cow<'static, str>,
-141
+}
 impl Params {
     /// Create a builder for [`Params`]

↧ Expand context

     pub fn builder() -> crate::config::auth::ParamsBuilder {
         crate::config::auth::ParamsBuilder::default()
-146
+    }
-147
     /// Return the operation name for [`Params`]
     pub fn operation_name(&self) -> &str {
         self.operation_name.as_ref()
-151
+    }
-152
+}
-153
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /// Builder for [`Params`]
 pub struct ParamsBuilder {
     operation_name: ::std::option::Option<::std::borrow::Cow<'static, str>>,
-158
+}
 impl ParamsBuilder {
     /// Set the operation name for the builder
     pub fn operation_name(self, operation_name: impl Into<::std::borrow::Cow<'static, str>>) -> Self {
         self.set_operation_name(::std::option::Option::Some(operation_name.into()))
-163
+    }

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

@@ -1,1 +136,136 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-sts"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for AWS Security Token Service"
 edition = "2021"
 license = "Apache-2.0"
 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.86.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]

 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.3"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.9"
-24
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.5"
 version = "1.3.0"
-28
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.62.1"
-32
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.4"
-36
 [dependencies.aws-smithy-query]
 path = "../aws-smithy-query"
 version = "0.60.7"
-40
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.8.4"
 version = "1.8.5"
-45
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.8.3"
 version = "1.8.4"
-50
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.3.2"
-54
 [dependencies.aws-smithy-xml]
 path = "../aws-smithy-xml"
 version = "0.60.10"
-58
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.7"
 version = "1.3.8"
-62
 [dependencies.fastrand]
 version = "2.0.0"
-65
 [dependencies.http]
 version = "0.2.9"
-68
 [dependencies.regex-lite]
 version = "0.1.5"
-71
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.3"
-78
 [dev-dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["test-util"]
 version = "1.5.9"
-83
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.5"
 version = "1.3.0"
-88
 [dev-dependencies.aws-smithy-http-client]
 path = "../aws-smithy-http-client"
 features = ["test-util", "wire-mock"]
 version = "1.0.6"
-93
 [dev-dependencies.aws-smithy-protocol-test]
 path = "../aws-smithy-protocol-test"
 version = "0.63.4"
-97
 [dev-dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["test-util"]
 version = "1.8.4"
 version = "1.8.5"
-102
 [dev-dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["test-util"]
 version = "1.8.3"
 version = "1.8.4"
-107
 [dev-dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 features = ["test-util"]
 version = "1.3.2"
-112
 [dev-dependencies.futures-util]
 version = "0.3.25"
 features = ["alloc"]
 default-features = false

↧ Expand context

-117
 [dev-dependencies.http-1x]
 version = "1"
 package = "http"
-121
 [dev-dependencies.serde_json]
 version = "1.0.0"
-124
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-128
 [dev-dependencies.tracing-subscriber]
 version = "0.3.16"
 features = ["env-filter", "json"]
-132
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]

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

@@ -36,36 +95,99 @@

↥ Expand context

     ///
     pub fn builder() -> Builder {
         Builder::default()
-39
+    }
     /// Converts this config back into a builder so that it can be tweaked.
     pub fn to_builder(&self) -> Builder {
         Builder {
             config: self.cloneable.clone(),
             runtime_components: self.runtime_components.clone(),
             runtime_plugins: self.runtime_plugins.clone(),
             behavior_version: self.behavior_version,
-47
+        }
-48
+    }
     /// Return a reference to the stalled stream protection configuration contained in this config, if any.
     pub fn stalled_stream_protection(&self) -> ::std::option::Option<&crate::config::StalledStreamProtectionConfig> {
         self.config.load::<crate::config::StalledStreamProtectionConfig>()
-52
+    }
     /// Return the [`SharedHttpClient`](crate::config::SharedHttpClient) to use when making requests, if any.
     pub fn http_client(&self) -> Option<crate::config::SharedHttpClient> {
         self.runtime_components.http_client()

-56
+    }
     /// Return the auth schemes configured on this service config
     pub fn auth_schemes(&self) -> impl Iterator<Item = ::aws_smithy_runtime_api::client::auth::SharedAuthScheme> + '_ {
         self.runtime_components.auth_schemes()
-60
+    }
-61
     /// Return the auth scheme resolver configured on this service config
     pub fn auth_scheme_resolver(&self) -> ::std::option::Option<::aws_smithy_runtime_api::client::auth::SharedAuthSchemeOptionResolver> {
         self.runtime_components.auth_scheme_option_resolver()
-65
+    }
     /// Returns the configured auth scheme preference
     pub fn auth_scheme_preference(&self) -> ::std::option::Option<&::aws_smithy_runtime_api::client::auth::AuthSchemePreference> {
         self.config.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
-+
+    }
     /// Returns the endpoint resolver.
     pub fn endpoint_resolver(&self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver {
         self.runtime_components.endpoint_resolver().expect("resolver defaulted if not set")
-73
+    }
     /// Return a reference to the retry configuration contained in this config, if any.
     pub fn retry_config(&self) -> ::std::option::Option<&::aws_smithy_types::retry::RetryConfig> {
         self.config.load::<::aws_smithy_types::retry::RetryConfig>()
-77
+    }
-78
     /// Return a cloned shared async sleep implementation from this config, if any.

↧ Expand context

     pub fn sleep_impl(&self) -> ::std::option::Option<crate::config::SharedAsyncSleep> {
         self.runtime_components.sleep_impl()
-82
+    }
-83
     /// Return a reference to the timeout configuration contained in this config, if any.
     pub fn timeout_config(&self) -> ::std::option::Option<&::aws_smithy_types::timeout::TimeoutConfig> {
         self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>()
-87
+    }
-88
     /// Returns a reference to the retry partition contained in this config, if any.
     ///
     /// WARNING: This method is unstable and may be removed at any time. Do not rely on this
     /// method for anything!
     pub fn retry_partition(&self) -> ::std::option::Option<&::aws_smithy_runtime::client::retries::RetryPartition> {
         self.config.load::<::aws_smithy_runtime::client::retries::RetryPartition>()
-95
+    }
     /// Returns the configured identity cache for auth.
     pub fn identity_cache(&self) -> ::std::option::Option<crate::config::SharedIdentityCache> {
         self.runtime_components.identity_cache()
-99
+    }

@@ -149,153 +208,213 @@

↥ Expand context

     pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
     pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
-155
+}
 impl ::std::default::Default for Builder {
     fn default() -> Self {
         Self {
             config: ::std::default::Default::default(),
             runtime_components: crate::config::RuntimeComponentsBuilder::new("service config"),
             runtime_plugins: ::std::default::Default::default(),
             behavior_version: ::std::default::Default::default(),
-163
+        }
-164
+    }
-165
+}
 impl Builder {
     ///
     /// Constructs a config builder.
     /// <div class="warning">
     /// Note that a config created from this builder will not have the same safe defaults as one created by
     /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
     /// </div>

     ///
     pub fn new() -> Self {
         Self::default()
-176
+    }
     /// Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
     /// but not those in runtime components.
     #[allow(unused)]
     pub(crate) fn from_config_bag(config_bag: &::aws_smithy_types::config_bag::ConfigBag) -> Self {
         let mut builder = Self::new();
         builder.set_stalled_stream_protection(config_bag.load::<crate::config::StalledStreamProtectionConfig>().cloned());
         builder.set_auth_scheme_preference(config_bag.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>().cloned());
         builder.set_retry_config(config_bag.load::<::aws_smithy_types::retry::RetryConfig>().cloned());
         builder.set_timeout_config(config_bag.load::<::aws_smithy_types::timeout::TimeoutConfig>().cloned());
         builder.set_retry_partition(config_bag.load::<::aws_smithy_runtime::client::retries::RetryPartition>().cloned());
         builder.set_app_name(config_bag.load::<::aws_types::app_name::AppName>().cloned());
         builder.set_endpoint_url(config_bag.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()));
         builder.set_use_dual_stack(config_bag.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0));
         builder.set_use_fips(config_bag.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0));
         builder.set_region(config_bag.load::<crate::config::Region>().cloned());
         builder
-193
+    }

↧ Expand context

     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn stalled_stream_protection(mut self, stalled_stream_protection_config: crate::config::StalledStreamProtectionConfig) -> Self {
         self.set_stalled_stream_protection(::std::option::Option::Some(stalled_stream_protection_config));
         self
-199
+    }
     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn set_stalled_stream_protection(
         &mut self,
         stalled_stream_protection_config: ::std::option::Option<crate::config::StalledStreamProtectionConfig>,
     ) -> &mut Self {
         self.config.store_or_unset(stalled_stream_protection_config);
         self
-208
+    }
     /// Sets the HTTP client to use when making requests.
     ///
     /// # Examples
     /// ```no_run
     /// # #[cfg(test)]

@@ -398,403 +457,519 @@

↥ Expand context

     ///     fn resolve_auth_scheme<'a>(
     ///         &'a self,
     ///         _params: &'a aws_sdk_sts::config::auth::Params,
     ///         _cfg: &'a ConfigBag,
     ///         _runtime_components: &'a RuntimeComponents,
     ///     ) -> AuthSchemeOptionsFuture<'a> {
     ///         // --snip--
     /// #      todo!()
     ///     }
     /// }
     ///
     /// let config = aws_sdk_sts::Config::builder()
     ///     .auth_scheme_resolver(CustomAuthSchemeResolver)
     ///     // other configurations
     ///     .build();
     /// ```
     pub fn auth_scheme_resolver(mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> Self {
         self.set_auth_scheme_resolver(auth_scheme_resolver);
         self
-422
+    }

-423
     /// Set the auth scheme resolver for the builder
     ///
     /// # Examples
     /// See an example for [`Self::auth_scheme_resolver`].
     pub fn set_auth_scheme_resolver(&mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> &mut Self {
         self.runtime_components
             .set_auth_scheme_option_resolver(::std::option::Option::Some(auth_scheme_resolver.into_shared_resolver()));
         self
-432
+    }
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_sts::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_sts::Client::from_conf(config);
     /// ```
-+
     pub fn auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.set_auth_scheme_preference(::std::option::Option::Some(preference.into()));
         self
-+
+    }
-+
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_sts::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_sts::Client::from_conf(config);
     /// ```
-+
     pub fn set_auth_scheme_preference(
         &mut self,
         preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> &mut Self {
         self.config.store_or_unset(preference);
         self
-+
+    }
     /// Sets the endpoint resolver to use when making requests.
     ///
     ///
     /// When unset, the client will used a generated endpoint resolver based on the endpoint resolution
     /// rules for `aws_sdk_sts`.
     ///
     ///
     /// Note: setting an endpoint resolver will replace any endpoint URL that has been set.
     /// This method accepts an endpoint resolver [specific to this service](crate::config::endpoint::ResolveEndpoint). If you want to
     /// provide a shared endpoint resolver, use [`Self::set_endpoint_resolver`].

↧ Expand context

     ///
     /// # Examples
     /// Create a custom endpoint resolver that resolves a different endpoing per-stage, e.g. staging vs. production.
     /// ```no_run
     /// use aws_sdk_sts::config::endpoint::{ResolveEndpoint, EndpointFuture, Params, Endpoint};
     /// #[derive(Debug)]
     /// struct StageResolver { stage: String }
     /// impl ResolveEndpoint for StageResolver {
     ///     fn resolve_endpoint(&self, params: &Params) -> EndpointFuture<'_> {
     ///         let stage = &self.stage;
     ///         EndpointFuture::ready(Ok(Endpoint::builder().url(format!("{stage}.myservice.com")).build()))
     ///     }
     /// }
     /// let resolver = StageResolver { stage: std::env::var("STAGE").unwrap() };
     /// let config = aws_sdk_sts::Config::builder().endpoint_resolver(resolver).build();
     /// let client = aws_sdk_sts::Client::from_conf(config);
     /// ```
     pub fn endpoint_resolver(mut self, endpoint_resolver: impl crate::config::endpoint::ResolveEndpoint + 'static) -> Self {
         self.set_endpoint_resolver(::std::option::Option::Some(endpoint_resolver.into_shared_resolver()));
         self

@@ -1263,1325 +1323,1395 @@

↥ Expand context

             .load::<::aws_types::region::Region>()
             .cloned()
             .map(|r| layer.store_put(::aws_types::region::SigningRegion::from(r)));
         Config {
             config: crate::config::Layer::from(layer.clone())
                 .with_name("aws_sdk_sts::config::Config")
                 .freeze(),
             cloneable: layer,
             runtime_components: self.runtime_components,
             runtime_plugins: self.runtime_plugins,
             behavior_version: self.behavior_version,
-1336
+        }
-1337
+    }
-1338
+}
 #[derive(::std::fmt::Debug)]
 pub(crate) struct ServiceRuntimePlugin {
     config: ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer>,
     runtime_components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
-1343
+}
-1344

 impl ServiceRuntimePlugin {
     pub fn new(_service_config: crate::config::Config) -> Self {
         let config = {
             let mut cfg = ::aws_smithy_types::config_bag::Layer::new("AWSSecurityTokenServiceV20110615");
             cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);
             ::std::option::Option::Some(cfg.freeze())
         };
         let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");
         runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({
             use crate::config::auth::ResolveAuthScheme;
             if let Some(preference) = _service_config
                 .config
                 .load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
                 .cloned()
-+
+            {
                 crate::config::auth::DefaultAuthSchemeResolver::default()
                     .with_auth_scheme_preference(preference)
                     .into_shared_resolver()
             } else {
                 crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()
-+
+            }
         }));
         runtime_components.set_endpoint_resolver(::std::option::Option::Some({
             use crate::config::endpoint::ResolveEndpoint;
             crate::config::endpoint::DefaultResolver::new().into_shared_resolver()
         }));
         runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());
         runtime_components.push_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::HttpStatusCodeClassifier::default());
         runtime_components.push_interceptor(crate::sdk_feature_tracker::retry_mode::RetryModeFeatureTrackerInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::service_clock_skew::ServiceClockSkewInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::request_info::RequestInfoInterceptor::new());

↧ Expand context

         runtime_components.push_interceptor(::aws_runtime::user_agent::UserAgentInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::invocation_id::InvocationIdInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::recursion_detection::RecursionDetectionInterceptor::new());
         runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(
             ::aws_runtime::auth::sigv4::SigV4AuthScheme::new(),
         ));
         Self { config, runtime_components }
-1383
+    }
-1384
+}
-1385
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ServiceRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         self.config.clone()
-1389
+    }
-1390
     fn order(&self) -> ::aws_smithy_runtime_api::client::runtime_plugin::Order {
         ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults
-1393
+    }
-1394
     fn runtime_components(

@@ -1389,1461 +1448,1521 @@

↥ Expand context

 pub use ::aws_credential_types::Credentials;
-1462
 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());
         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("AWS_ENDPOINT_URL", "endpoint_url"))
                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),

             );
-1482
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1487
         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));
-1495
+        }
-1496
         if let Some(cache) = input.identity_cache() {
             builder.set_identity_cache(cache);
-1499
+        }
         builder.set_app_name(input.app_name().cloned());
-1501

↧ Expand context

         builder
-1503
+    }
-1504
+}
-1505
 impl From<&::aws_types::sdk_config::SdkConfig> for Config {
     fn from(sdk_config: &::aws_types::sdk_config::SdkConfig) -> Self {
         Builder::from(sdk_config).build()
-1509
+    }
-1510
+}
-1511
 pub use ::aws_types::app_name::AppName;
-1513
 #[allow(dead_code)]
 fn service_config_key<'a>(env: &'a str, profile: &'a str) -> aws_types::service_config::ServiceConfigKey<'a> {
     ::aws_types::service_config::ServiceConfigKey::builder()
         .service_id("STS")
         .env(env)
         .profile(profile)
         .build()
         .expect("all field sets explicitly, can't fail")

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

@@ -18,18 +139,169 @@

↥ Expand context

-18
+    }
-19
+}
-20
 #[derive(Debug)]
 struct DowncastParams<T>(T);
 impl<T> ::aws_smithy_runtime_api::client::auth::ResolveAuthSchemeOptions for DowncastParams<T>
 where
     T: ResolveAuthScheme,
-26
+{
     fn resolve_auth_scheme_options_v2<'a>(
         &'a self,
         params: &'a ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams,
         cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         match params.get::<crate::config::auth::Params>() {
             ::std::option::Option::Some(concrete_params) => self.0.resolve_auth_scheme(concrete_params, cfg, runtime_components),
             ::std::option::Option::None => ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(::std::result::Result::Err(
                 "params of expected type was not present".into(),
             )),

-38
+        }
-39
+    }
-40
+}
-41
 /// The default auth scheme resolver
 #[derive(Debug)]
 #[allow(dead_code)]
 pub struct DefaultAuthSchemeResolver {
     service_defaults: Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>,
     operation_overrides: ::std::collections::HashMap<&'static str, Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>>,
     preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
-49
+}
-50
 // TODO(https://github.com/smithy-lang/smithy-rs/issues/4177): Remove `allow(...)` once the issue is addressed.
 // When generating code for tests (e.g., `codegen-client-test`), this manual implementation
 // of the `Default` trait may appear as if it could be derived automatically.
 // However, that is not the case in production.
 #[allow(clippy::derivable_impls)]
 impl Default for DefaultAuthSchemeResolver {
     fn default() -> Self {
         Self {
             service_defaults: vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                 .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                 .build()
                 .expect("required fields set")],
             operation_overrides: [
-64
+                (
                     "AssumeRoleWithSAML",
                     vec![
                         ::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                             .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                             .build()
                             .expect("required fields set"),
                         ::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                         ),
                     ],
                 ),
-76
+                (
                     "AssumeRoleWithWebIdentity",
                     vec![
                         ::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                             .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                             .build()
                             .expect("required fields set"),
                         ::aws_smithy_runtime_api::client::auth::AuthSchemeOption::from(
                             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
                         ),
                     ],
                 ),
-88
+            ]
             .into(),
             preference: ::std::option::Option::None,
-91
+        }
-92
+    }
-93
+}
-94
 impl crate::config::auth::ResolveAuthScheme for DefaultAuthSchemeResolver {
     fn resolve_auth_scheme<'a>(
         &'a self,
         params: &'a crate::config::auth::Params,
         _cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         _runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         let operation_name = params.operation_name();
-103
         let modeled_auth_options = match self.operation_overrides.get(operation_name) {
             Some(overrides) => overrides,
             None => &self.service_defaults,
         };
-108
         let _fut = ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(Ok(modeled_auth_options.clone()));
-110
         _fut
         match &self.preference {
             ::std::option::Option::Some(preference) => {
                 _fut.map_ok({
                     // maps auth scheme ID to the index in the preference list
                     let preference_map: ::std::collections::HashMap<_, _> = preference.clone().into_iter().enumerate().map(|(i, s)| (s, i)).collect();
                     move |auth_scheme_options| {
                         let (mut preferred, non_preferred): (::std::vec::Vec<_>, ::std::vec::Vec<_>) = auth_scheme_options
                             .into_iter()
                             .partition(|auth_scheme_option| preference_map.contains_key(auth_scheme_option.scheme_id()));
-+
                         preferred.sort_by_key(|opt| preference_map.get(opt.scheme_id()).expect("guaranteed by `partition`"));
                         preferred.extend(non_preferred);
                         preferred
-+
+                    }
                 })
-+
+            }
             ::std::option::Option::None => _fut,
-+
+        }
-+
+    }
-+
+}
-+
 impl DefaultAuthSchemeResolver {
     /// Set auth scheme preference to the default auth scheme resolver
     pub fn with_auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.preference = ::std::option::Option::Some(preference.into());
         self
-140
+    }
-141
+}
-142
 /// Configuration parameters for resolving the correct auth scheme
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Params {
     operation_name: ::std::borrow::Cow<'static, str>,
-147
+}
 impl Params {
     /// Create a builder for [`Params`]

↧ Expand context

     pub fn builder() -> crate::config::auth::ParamsBuilder {
         crate::config::auth::ParamsBuilder::default()
-152
+    }
-153
     /// Return the operation name for [`Params`]
     pub fn operation_name(&self) -> &str {
         self.operation_name.as_ref()
-157
+    }
-158
+}
-159
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /// Builder for [`Params`]
 pub struct ParamsBuilder {
     operation_name: ::std::option::Option<::std::borrow::Cow<'static, str>>,
-164
+}
 impl ParamsBuilder {
     /// Set the operation name for the builder
     pub fn operation_name(self, operation_name: impl Into<::std::borrow::Cow<'static, str>>) -> Self {
         self.set_operation_name(::std::option::Option::Some(operation_name.into()))
-169
+    }

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

@@ -1,1 +139,139 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-timestreamquery"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon Timestream Query"
 edition = "2021"
 license = "Apache-2.0"
 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.86.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]

 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.3"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.9"
-24
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.5"
 version = "1.3.0"
-28
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.62.1"
-32
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.4"
-36
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.8.4"
 version = "1.8.5"
-41
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.8.3"
 version = "1.8.4"
-46
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.3.2"
-50
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.7"
 version = "1.3.8"
-54
 [dependencies.bytes]
 version = "1.4.0"
-57
 [dependencies.fastrand]
 version = "2.0.0"
-60
 [dependencies.http]
 version = "0.2.9"
-63
 [dependencies.regex-lite]
 version = "0.1.5"
-66
 [dependencies.tokio]
 version = "1.23.1"
 features = ["sync"]
-70
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.8.2"
 version = "1.8.3"
-76
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.3"
-81
 [dev-dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["test-util"]
 version = "1.5.9"
-86
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.5"
 version = "1.3.0"
-91
 [dev-dependencies.aws-smithy-http-client]
 path = "../aws-smithy-http-client"
 features = ["test-util", "wire-mock"]
 version = "1.0.6"
-96
 [dev-dependencies.aws-smithy-protocol-test]
 path = "../aws-smithy-protocol-test"
 version = "0.63.4"
-100
 [dev-dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["test-util"]
 version = "1.8.4"
 version = "1.8.5"
-105
 [dev-dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["test-util"]
 version = "1.8.3"
 version = "1.8.4"
-110
 [dev-dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 features = ["test-util"]
 version = "1.3.2"
-115
 [dev-dependencies.futures-util]
 version = "0.3.25"
 features = ["alloc"]
 default-features = false

↧ Expand context

-120
 [dev-dependencies.http-1x]
 version = "1"
 package = "http"
-124
 [dev-dependencies.serde_json]
 version = "1.0.0"
-127
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-131
 [dev-dependencies.tracing-subscriber]
 version = "0.3.16"
 features = ["env-filter", "json"]
-135
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]

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

@@ -36,36 +95,99 @@

↥ Expand context

     ///
     pub fn builder() -> Builder {
         Builder::default()
-39
+    }
     /// Converts this config back into a builder so that it can be tweaked.
     pub fn to_builder(&self) -> Builder {
         Builder {
             config: self.cloneable.clone(),
             runtime_components: self.runtime_components.clone(),
             runtime_plugins: self.runtime_plugins.clone(),
             behavior_version: self.behavior_version,
-47
+        }
-48
+    }
     /// Return a reference to the stalled stream protection configuration contained in this config, if any.
     pub fn stalled_stream_protection(&self) -> ::std::option::Option<&crate::config::StalledStreamProtectionConfig> {
         self.config.load::<crate::config::StalledStreamProtectionConfig>()
-52
+    }
     /// Return the [`SharedHttpClient`](crate::config::SharedHttpClient) to use when making requests, if any.
     pub fn http_client(&self) -> Option<crate::config::SharedHttpClient> {
         self.runtime_components.http_client()

-56
+    }
     /// Return the auth schemes configured on this service config
     pub fn auth_schemes(&self) -> impl Iterator<Item = ::aws_smithy_runtime_api::client::auth::SharedAuthScheme> + '_ {
         self.runtime_components.auth_schemes()
-60
+    }
-61
     /// Return the auth scheme resolver configured on this service config
     pub fn auth_scheme_resolver(&self) -> ::std::option::Option<::aws_smithy_runtime_api::client::auth::SharedAuthSchemeOptionResolver> {
         self.runtime_components.auth_scheme_option_resolver()
-65
+    }
     /// Returns the configured auth scheme preference
     pub fn auth_scheme_preference(&self) -> ::std::option::Option<&::aws_smithy_runtime_api::client::auth::AuthSchemePreference> {
         self.config.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
-+
+    }
     /// Returns the endpoint resolver.
     pub fn endpoint_resolver(&self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver {
         self.runtime_components.endpoint_resolver().expect("resolver defaulted if not set")
-73
+    }
     /// Return a reference to the retry configuration contained in this config, if any.
     pub fn retry_config(&self) -> ::std::option::Option<&::aws_smithy_types::retry::RetryConfig> {
         self.config.load::<::aws_smithy_types::retry::RetryConfig>()
-77
+    }
-78
     /// Return a cloned shared async sleep implementation from this config, if any.

↧ Expand context

     pub fn sleep_impl(&self) -> ::std::option::Option<crate::config::SharedAsyncSleep> {
         self.runtime_components.sleep_impl()
-82
+    }
-83
     /// Return a reference to the timeout configuration contained in this config, if any.
     pub fn timeout_config(&self) -> ::std::option::Option<&::aws_smithy_types::timeout::TimeoutConfig> {
         self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>()
-87
+    }
-88
     /// Returns a reference to the retry partition contained in this config, if any.
     ///
     /// WARNING: This method is unstable and may be removed at any time. Do not rely on this
     /// method for anything!
     pub fn retry_partition(&self) -> ::std::option::Option<&::aws_smithy_runtime::client::retries::RetryPartition> {
         self.config.load::<::aws_smithy_runtime::client::retries::RetryPartition>()
-95
+    }
     /// Returns the configured identity cache for auth.
     pub fn identity_cache(&self) -> ::std::option::Option<crate::config::SharedIdentityCache> {
         self.runtime_components.identity_cache()
-99
+    }

@@ -149,153 +208,213 @@

↥ Expand context

     pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
     pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
-155
+}
 impl ::std::default::Default for Builder {
     fn default() -> Self {
         Self {
             config: ::std::default::Default::default(),
             runtime_components: crate::config::RuntimeComponentsBuilder::new("service config"),
             runtime_plugins: ::std::default::Default::default(),
             behavior_version: ::std::default::Default::default(),
-163
+        }
-164
+    }
-165
+}
 impl Builder {
     ///
     /// Constructs a config builder.
     /// <div class="warning">
     /// Note that a config created from this builder will not have the same safe defaults as one created by
     /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
     /// </div>

     ///
     pub fn new() -> Self {
         Self::default()
-176
+    }
     /// Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
     /// but not those in runtime components.
     #[allow(unused)]
     pub(crate) fn from_config_bag(config_bag: &::aws_smithy_types::config_bag::ConfigBag) -> Self {
         let mut builder = Self::new();
         builder.set_stalled_stream_protection(config_bag.load::<crate::config::StalledStreamProtectionConfig>().cloned());
         builder.set_auth_scheme_preference(config_bag.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>().cloned());
         builder.set_retry_config(config_bag.load::<::aws_smithy_types::retry::RetryConfig>().cloned());
         builder.set_timeout_config(config_bag.load::<::aws_smithy_types::timeout::TimeoutConfig>().cloned());
         builder.set_retry_partition(config_bag.load::<::aws_smithy_runtime::client::retries::RetryPartition>().cloned());
         builder.set_app_name(config_bag.load::<::aws_types::app_name::AppName>().cloned());
         builder.set_endpoint_url(config_bag.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()));
         builder.set_use_dual_stack(config_bag.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0));
         builder.set_use_fips(config_bag.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0));
         builder.set_region(config_bag.load::<crate::config::Region>().cloned());
         builder
-193
+    }

↧ Expand context

     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn stalled_stream_protection(mut self, stalled_stream_protection_config: crate::config::StalledStreamProtectionConfig) -> Self {
         self.set_stalled_stream_protection(::std::option::Option::Some(stalled_stream_protection_config));
         self
-199
+    }
     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn set_stalled_stream_protection(
         &mut self,
         stalled_stream_protection_config: ::std::option::Option<crate::config::StalledStreamProtectionConfig>,
     ) -> &mut Self {
         self.config.store_or_unset(stalled_stream_protection_config);
         self
-208
+    }
     /// Sets the idempotency token provider to use for service calls that require tokens.
     pub fn idempotency_token_provider(
         mut self,
         idempotency_token_provider: impl ::std::convert::Into<crate::idempotency_token::IdempotencyTokenProvider>,
     ) -> Self {

@@ -414,419 +473,535 @@

↥ Expand context

     ///     fn resolve_auth_scheme<'a>(
     ///         &'a self,
     ///         _params: &'a aws_sdk_timestreamquery::config::auth::Params,
     ///         _cfg: &'a ConfigBag,
     ///         _runtime_components: &'a RuntimeComponents,
     ///     ) -> AuthSchemeOptionsFuture<'a> {
     ///         // --snip--
     /// #      todo!()
     ///     }
     /// }
     ///
     /// let config = aws_sdk_timestreamquery::Config::builder()
     ///     .auth_scheme_resolver(CustomAuthSchemeResolver)
     ///     // other configurations
     ///     .build();
     /// ```
     pub fn auth_scheme_resolver(mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> Self {
         self.set_auth_scheme_resolver(auth_scheme_resolver);
         self
-438
+    }

-439
     /// Set the auth scheme resolver for the builder
     ///
     /// # Examples
     /// See an example for [`Self::auth_scheme_resolver`].
     pub fn set_auth_scheme_resolver(&mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> &mut Self {
         self.runtime_components
             .set_auth_scheme_option_resolver(::std::option::Option::Some(auth_scheme_resolver.into_shared_resolver()));
         self
-448
+    }
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_timestreamquery::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_timestreamquery::Client::from_conf(config);
     /// ```
-+
     pub fn auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.set_auth_scheme_preference(::std::option::Option::Some(preference.into()));
         self
-+
+    }
-+
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_timestreamquery::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_timestreamquery::Client::from_conf(config);
     /// ```
-+
     pub fn set_auth_scheme_preference(
         &mut self,
         preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> &mut Self {
         self.config.store_or_unset(preference);
         self
-+
+    }
     /// Sets the endpoint resolver to use when making requests.
     ///
     ///
     /// When unset, the client will used a generated endpoint resolver based on the endpoint resolution
     /// rules for `aws_sdk_timestreamquery`.
     ///
     ///
     /// Note: setting an endpoint resolver will replace any endpoint URL that has been set.
     /// This method accepts an endpoint resolver [specific to this service](crate::config::endpoint::ResolveEndpoint). If you want to
     /// provide a shared endpoint resolver, use [`Self::set_endpoint_resolver`].

↧ Expand context

     ///
     /// # Examples
     /// Create a custom endpoint resolver that resolves a different endpoing per-stage, e.g. staging vs. production.
     /// ```no_run
     /// use aws_sdk_timestreamquery::config::endpoint::{ResolveEndpoint, EndpointFuture, Params, Endpoint};
     /// #[derive(Debug)]
     /// struct StageResolver { stage: String }
     /// impl ResolveEndpoint for StageResolver {
     ///     fn resolve_endpoint(&self, params: &Params) -> EndpointFuture<'_> {
     ///         let stage = &self.stage;
     ///         EndpointFuture::ready(Ok(Endpoint::builder().url(format!("{stage}.myservice.com")).build()))
     ///     }
     /// }
     /// let resolver = StageResolver { stage: std::env::var("STAGE").unwrap() };
     /// let config = aws_sdk_timestreamquery::Config::builder().endpoint_resolver(resolver).build();
     /// let client = aws_sdk_timestreamquery::Client::from_conf(config);
     /// ```
     pub fn endpoint_resolver(mut self, endpoint_resolver: impl crate::config::endpoint::ResolveEndpoint + 'static) -> Self {
         self.set_endpoint_resolver(::std::option::Option::Some(endpoint_resolver.into_shared_resolver()));
         self

@@ -1281,1343 +1341,1413 @@

↥ Expand context

             .cloned()
             .map(|r| layer.store_put(::aws_types::region::SigningRegion::from(r)));
         Config {
             config: crate::config::Layer::from(layer.clone())
                 .with_name("aws_sdk_timestreamquery::config::Config")
                 .freeze(),
             cloneable: layer,
             runtime_components: self.runtime_components,
             runtime_plugins: self.runtime_plugins,
             behavior_version: self.behavior_version,
-1353
+        }
-1354
+    }
-1355
+}
 #[derive(::std::fmt::Debug)]
 pub(crate) struct ServiceRuntimePlugin {
     config: ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer>,
     runtime_components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
-1360
+}
-1361
 impl ServiceRuntimePlugin {

     pub fn new(_service_config: crate::config::Config) -> Self {
         let config = {
             let mut cfg = ::aws_smithy_types::config_bag::Layer::new("Timestream_20181101");
             cfg.store_put(crate::idempotency_token::default_provider());
             cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);
             ::std::option::Option::Some(cfg.freeze())
         };
         let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");
         runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({
             use crate::config::auth::ResolveAuthScheme;
             if let Some(preference) = _service_config
                 .config
                 .load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
                 .cloned()
-+
+            {
                 crate::config::auth::DefaultAuthSchemeResolver::default()
                     .with_auth_scheme_preference(preference)
                     .into_shared_resolver()
             } else {
                 crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()
-+
+            }
         }));
         runtime_components.set_endpoint_resolver(::std::option::Option::Some({
             use crate::config::endpoint::ResolveEndpoint;
             crate::config::endpoint::DefaultResolver::new().into_shared_resolver()
         }));
         runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());
         runtime_components.push_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::HttpStatusCodeClassifier::default());
         runtime_components.push_interceptor(crate::sdk_feature_tracker::retry_mode::RetryModeFeatureTrackerInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::service_clock_skew::ServiceClockSkewInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::request_info::RequestInfoInterceptor::new());

↧ Expand context

         runtime_components.push_interceptor(::aws_runtime::user_agent::UserAgentInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::invocation_id::InvocationIdInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::recursion_detection::RecursionDetectionInterceptor::new());
         runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(
             ::aws_runtime::auth::sigv4::SigV4AuthScheme::new(),
         ));
         Self { config, runtime_components }
-1401
+    }
-1402
+}
-1403
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ServiceRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         self.config.clone()
-1407
+    }
-1408
     fn order(&self) -> ::aws_smithy_runtime_api::client::runtime_plugin::Order {
         ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults
-1411
+    }
-1412
     fn runtime_components(

@@ -1407,1479 +1466,1539 @@

↥ Expand context

 pub use ::aws_credential_types::Credentials;
-1480
 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());
         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("AWS_ENDPOINT_URL", "endpoint_url"))
                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),

             );
-1500
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1505
         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));
-1513
+        }
-1514
         if let Some(cache) = input.identity_cache() {
             builder.set_identity_cache(cache);
-1517
+        }
         builder.set_app_name(input.app_name().cloned());
-1519

↧ Expand context

         builder
-1521
+    }
-1522
+}
-1523
 impl From<&::aws_types::sdk_config::SdkConfig> for Config {
     fn from(sdk_config: &::aws_types::sdk_config::SdkConfig) -> Self {
         Builder::from(sdk_config).build()
-1527
+    }
-1528
+}
-1529
 pub use ::aws_types::app_name::AppName;
-1531
 #[allow(dead_code)]
 fn service_config_key<'a>(env: &'a str, profile: &'a str) -> aws_types::service_config::ServiceConfigKey<'a> {
     ::aws_types::service_config::ServiceConfigKey::builder()
         .service_id("Timestream Query")
         .env(env)
         .profile(profile)
         .build()
         .expect("all field sets explicitly, can't fail")

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

@@ -18,18 +113,143 @@

↥ Expand context

-18
+    }
-19
+}
-20
 #[derive(Debug)]
 struct DowncastParams<T>(T);
 impl<T> ::aws_smithy_runtime_api::client::auth::ResolveAuthSchemeOptions for DowncastParams<T>
 where
     T: ResolveAuthScheme,
-26
+{
     fn resolve_auth_scheme_options_v2<'a>(
         &'a self,
         params: &'a ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams,
         cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         match params.get::<crate::config::auth::Params>() {
             ::std::option::Option::Some(concrete_params) => self.0.resolve_auth_scheme(concrete_params, cfg, runtime_components),
             ::std::option::Option::None => ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(::std::result::Result::Err(
                 "params of expected type was not present".into(),
             )),

-38
+        }
-39
+    }
-40
+}
-41
 /// The default auth scheme resolver
 #[derive(Debug)]
 #[allow(dead_code)]
 pub struct DefaultAuthSchemeResolver {
     service_defaults: Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>,
     operation_overrides: ::std::collections::HashMap<&'static str, Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>>,
     preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
-49
+}
-50
 // TODO(https://github.com/smithy-lang/smithy-rs/issues/4177): Remove `allow(...)` once the issue is addressed.
 // When generating code for tests (e.g., `codegen-client-test`), this manual implementation
 // of the `Default` trait may appear as if it could be derived automatically.
 // However, that is not the case in production.
 #[allow(clippy::derivable_impls)]
 impl Default for DefaultAuthSchemeResolver {
     fn default() -> Self {
         Self {
             service_defaults: vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                 .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                 .build()
                 .expect("required fields set")],
             operation_overrides: ::std::collections::HashMap::new(),
             preference: ::std::option::Option::None,
-65
+        }
-66
+    }
-67
+}
-68
 impl crate::config::auth::ResolveAuthScheme for DefaultAuthSchemeResolver {
     fn resolve_auth_scheme<'a>(
         &'a self,
         params: &'a crate::config::auth::Params,
         _cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         _runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         let operation_name = params.operation_name();
-77
         let modeled_auth_options = match self.operation_overrides.get(operation_name) {
             Some(overrides) => overrides,
             None => &self.service_defaults,
         };
-82
         let _fut = ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(Ok(modeled_auth_options.clone()));
-84
         _fut
         match &self.preference {
             ::std::option::Option::Some(preference) => {
                 _fut.map_ok({
                     // maps auth scheme ID to the index in the preference list
                     let preference_map: ::std::collections::HashMap<_, _> = preference.clone().into_iter().enumerate().map(|(i, s)| (s, i)).collect();
                     move |auth_scheme_options| {
                         let (mut preferred, non_preferred): (::std::vec::Vec<_>, ::std::vec::Vec<_>) = auth_scheme_options
                             .into_iter()
                             .partition(|auth_scheme_option| preference_map.contains_key(auth_scheme_option.scheme_id()));
-+
                         preferred.sort_by_key(|opt| preference_map.get(opt.scheme_id()).expect("guaranteed by `partition`"));
                         preferred.extend(non_preferred);
                         preferred
-+
+                    }
                 })
-+
+            }
             ::std::option::Option::None => _fut,
-+
+        }
-+
+    }
-+
+}
-+
 impl DefaultAuthSchemeResolver {
     /// Set auth scheme preference to the default auth scheme resolver
     pub fn with_auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.preference = ::std::option::Option::Some(preference.into());
         self
-114
+    }
-115
+}
-116
 /// Configuration parameters for resolving the correct auth scheme
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Params {
     operation_name: ::std::borrow::Cow<'static, str>,
-121
+}
 impl Params {
     /// Create a builder for [`Params`]

↧ Expand context

     pub fn builder() -> crate::config::auth::ParamsBuilder {
         crate::config::auth::ParamsBuilder::default()
-126
+    }
-127
     /// Return the operation name for [`Params`]
     pub fn operation_name(&self) -> &str {
         self.operation_name.as_ref()
-131
+    }
-132
+}
-133
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /// Builder for [`Params`]
 pub struct ParamsBuilder {
     operation_name: ::std::option::Option<::std::borrow::Cow<'static, str>>,
-138
+}
 impl ParamsBuilder {
     /// Set the operation name for the builder
     pub fn operation_name(self, operation_name: impl Into<::std::borrow::Cow<'static, str>>) -> Self {
         self.set_operation_name(::std::option::Option::Some(operation_name.into()))
-143
+    }

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

@@ -1,1 +98,98 @@

↥ Expand context

 # Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 [package]
 name = "aws-sdk-timestreamwrite"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon Timestream Write"
 edition = "2021"
 license = "Apache-2.0"
 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.86.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]

 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.3"
-20
 [dependencies.aws-runtime]
 path = "../aws-runtime"
 version = "1.5.9"
-24
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.5"
 version = "1.3.0"
-28
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 version = "0.62.1"
-32
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.4"
-36
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.8.4"
 version = "1.8.5"
-41
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.8.3"
 version = "1.8.4"
-46
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 version = "1.3.2"
-50
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.7"
 version = "1.3.8"
-54
 [dependencies.bytes]
 version = "1.4.0"
-57
 [dependencies.fastrand]
 version = "2.0.0"
-60
 [dependencies.http]
 version = "0.2.9"
-63
 [dependencies.regex-lite]
 version = "0.1.5"
-66
 [dependencies.tokio]
 version = "1.23.1"
 features = ["sync"]
-70
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.8.2"
 version = "1.8.3"
-76
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.3"
-81
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.5"
 version = "1.3.0"
-86
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-90
 [features]
 behavior-version-latest = []
 rustls = ["aws-smithy-runtime/tls-rustls"]
 default-https-client = ["aws-smithy-runtime/default-https-client"]
 rt-tokio = ["aws-smithy-async/rt-tokio", "aws-smithy-types/rt-tokio"]

↧ Expand context

96 96	`test-util = ["aws-credential-types/test-util", "aws-smithy-runtime/test-util"]`
97 97	`gated-tests = []`
98 98	`default = ["rustls", "default-https-client", "rt-tokio"]`

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

@@ -36,36 +95,99 @@

↥ Expand context

     ///
     pub fn builder() -> Builder {
         Builder::default()
-39
+    }
     /// Converts this config back into a builder so that it can be tweaked.
     pub fn to_builder(&self) -> Builder {
         Builder {
             config: self.cloneable.clone(),
             runtime_components: self.runtime_components.clone(),
             runtime_plugins: self.runtime_plugins.clone(),
             behavior_version: self.behavior_version,
-47
+        }
-48
+    }
     /// Return a reference to the stalled stream protection configuration contained in this config, if any.
     pub fn stalled_stream_protection(&self) -> ::std::option::Option<&crate::config::StalledStreamProtectionConfig> {
         self.config.load::<crate::config::StalledStreamProtectionConfig>()
-52
+    }
     /// Return the [`SharedHttpClient`](crate::config::SharedHttpClient) to use when making requests, if any.
     pub fn http_client(&self) -> Option<crate::config::SharedHttpClient> {
         self.runtime_components.http_client()

-56
+    }
     /// Return the auth schemes configured on this service config
     pub fn auth_schemes(&self) -> impl Iterator<Item = ::aws_smithy_runtime_api::client::auth::SharedAuthScheme> + '_ {
         self.runtime_components.auth_schemes()
-60
+    }
-61
     /// Return the auth scheme resolver configured on this service config
     pub fn auth_scheme_resolver(&self) -> ::std::option::Option<::aws_smithy_runtime_api::client::auth::SharedAuthSchemeOptionResolver> {
         self.runtime_components.auth_scheme_option_resolver()
-65
+    }
     /// Returns the configured auth scheme preference
     pub fn auth_scheme_preference(&self) -> ::std::option::Option<&::aws_smithy_runtime_api::client::auth::AuthSchemePreference> {
         self.config.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
-+
+    }
     /// Returns the endpoint resolver.
     pub fn endpoint_resolver(&self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver {
         self.runtime_components.endpoint_resolver().expect("resolver defaulted if not set")
-73
+    }
     /// Return a reference to the retry configuration contained in this config, if any.
     pub fn retry_config(&self) -> ::std::option::Option<&::aws_smithy_types::retry::RetryConfig> {
         self.config.load::<::aws_smithy_types::retry::RetryConfig>()
-77
+    }
-78
     /// Return a cloned shared async sleep implementation from this config, if any.

↧ Expand context

     pub fn sleep_impl(&self) -> ::std::option::Option<crate::config::SharedAsyncSleep> {
         self.runtime_components.sleep_impl()
-82
+    }
-83
     /// Return a reference to the timeout configuration contained in this config, if any.
     pub fn timeout_config(&self) -> ::std::option::Option<&::aws_smithy_types::timeout::TimeoutConfig> {
         self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>()
-87
+    }
-88
     /// Returns a reference to the retry partition contained in this config, if any.
     ///
     /// WARNING: This method is unstable and may be removed at any time. Do not rely on this
     /// method for anything!
     pub fn retry_partition(&self) -> ::std::option::Option<&::aws_smithy_runtime::client::retries::RetryPartition> {
         self.config.load::<::aws_smithy_runtime::client::retries::RetryPartition>()
-95
+    }
     /// Returns the configured identity cache for auth.
     pub fn identity_cache(&self) -> ::std::option::Option<crate::config::SharedIdentityCache> {
         self.runtime_components.identity_cache()
-99
+    }

@@ -149,153 +208,213 @@

↥ Expand context

     pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
     pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
-155
+}
 impl ::std::default::Default for Builder {
     fn default() -> Self {
         Self {
             config: ::std::default::Default::default(),
             runtime_components: crate::config::RuntimeComponentsBuilder::new("service config"),
             runtime_plugins: ::std::default::Default::default(),
             behavior_version: ::std::default::Default::default(),
-163
+        }
-164
+    }
-165
+}
 impl Builder {
     ///
     /// Constructs a config builder.
     /// <div class="warning">
     /// Note that a config created from this builder will not have the same safe defaults as one created by
     /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
     /// </div>

     ///
     pub fn new() -> Self {
         Self::default()
-176
+    }
     /// Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
     /// but not those in runtime components.
     #[allow(unused)]
     pub(crate) fn from_config_bag(config_bag: &::aws_smithy_types::config_bag::ConfigBag) -> Self {
         let mut builder = Self::new();
         builder.set_stalled_stream_protection(config_bag.load::<crate::config::StalledStreamProtectionConfig>().cloned());
         builder.set_auth_scheme_preference(config_bag.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>().cloned());
         builder.set_retry_config(config_bag.load::<::aws_smithy_types::retry::RetryConfig>().cloned());
         builder.set_timeout_config(config_bag.load::<::aws_smithy_types::timeout::TimeoutConfig>().cloned());
         builder.set_retry_partition(config_bag.load::<::aws_smithy_runtime::client::retries::RetryPartition>().cloned());
         builder.set_app_name(config_bag.load::<::aws_types::app_name::AppName>().cloned());
         builder.set_endpoint_url(config_bag.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()));
         builder.set_use_dual_stack(config_bag.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0));
         builder.set_use_fips(config_bag.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0));
         builder.set_region(config_bag.load::<crate::config::Region>().cloned());
         builder
-193
+    }

↧ Expand context

     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn stalled_stream_protection(mut self, stalled_stream_protection_config: crate::config::StalledStreamProtectionConfig) -> Self {
         self.set_stalled_stream_protection(::std::option::Option::Some(stalled_stream_protection_config));
         self
-199
+    }
     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn set_stalled_stream_protection(
         &mut self,
         stalled_stream_protection_config: ::std::option::Option<crate::config::StalledStreamProtectionConfig>,
     ) -> &mut Self {
         self.config.store_or_unset(stalled_stream_protection_config);
         self
-208
+    }
     /// Sets the idempotency token provider to use for service calls that require tokens.
     pub fn idempotency_token_provider(
         mut self,
         idempotency_token_provider: impl ::std::convert::Into<crate::idempotency_token::IdempotencyTokenProvider>,
     ) -> Self {

@@ -414,419 +473,535 @@

↥ Expand context

     ///     fn resolve_auth_scheme<'a>(
     ///         &'a self,
     ///         _params: &'a aws_sdk_timestreamwrite::config::auth::Params,
     ///         _cfg: &'a ConfigBag,
     ///         _runtime_components: &'a RuntimeComponents,
     ///     ) -> AuthSchemeOptionsFuture<'a> {
     ///         // --snip--
     /// #      todo!()
     ///     }
     /// }
     ///
     /// let config = aws_sdk_timestreamwrite::Config::builder()
     ///     .auth_scheme_resolver(CustomAuthSchemeResolver)
     ///     // other configurations
     ///     .build();
     /// ```
     pub fn auth_scheme_resolver(mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> Self {
         self.set_auth_scheme_resolver(auth_scheme_resolver);
         self
-438
+    }

-439
     /// Set the auth scheme resolver for the builder
     ///
     /// # Examples
     /// See an example for [`Self::auth_scheme_resolver`].
     pub fn set_auth_scheme_resolver(&mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> &mut Self {
         self.runtime_components
             .set_auth_scheme_option_resolver(::std::option::Option::Some(auth_scheme_resolver.into_shared_resolver()));
         self
-448
+    }
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_timestreamwrite::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_timestreamwrite::Client::from_conf(config);
     /// ```
-+
     pub fn auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.set_auth_scheme_preference(::std::option::Option::Some(preference.into()));
         self
-+
+    }
-+
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_timestreamwrite::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_timestreamwrite::Client::from_conf(config);
     /// ```
-+
     pub fn set_auth_scheme_preference(
         &mut self,
         preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> &mut Self {
         self.config.store_or_unset(preference);
         self
-+
+    }
     /// Sets the endpoint resolver to use when making requests.
     ///
     ///
     /// When unset, the client will used a generated endpoint resolver based on the endpoint resolution
     /// rules for `aws_sdk_timestreamwrite`.
     ///
     ///
     /// Note: setting an endpoint resolver will replace any endpoint URL that has been set.
     /// This method accepts an endpoint resolver [specific to this service](crate::config::endpoint::ResolveEndpoint). If you want to
     /// provide a shared endpoint resolver, use [`Self::set_endpoint_resolver`].

↧ Expand context

     ///
     /// # Examples
     /// Create a custom endpoint resolver that resolves a different endpoing per-stage, e.g. staging vs. production.
     /// ```no_run
     /// use aws_sdk_timestreamwrite::config::endpoint::{ResolveEndpoint, EndpointFuture, Params, Endpoint};
     /// #[derive(Debug)]
     /// struct StageResolver { stage: String }
     /// impl ResolveEndpoint for StageResolver {
     ///     fn resolve_endpoint(&self, params: &Params) -> EndpointFuture<'_> {
     ///         let stage = &self.stage;
     ///         EndpointFuture::ready(Ok(Endpoint::builder().url(format!("{stage}.myservice.com")).build()))
     ///     }
     /// }
     /// let resolver = StageResolver { stage: std::env::var("STAGE").unwrap() };
     /// let config = aws_sdk_timestreamwrite::Config::builder().endpoint_resolver(resolver).build();
     /// let client = aws_sdk_timestreamwrite::Client::from_conf(config);
     /// ```
     pub fn endpoint_resolver(mut self, endpoint_resolver: impl crate::config::endpoint::ResolveEndpoint + 'static) -> Self {
         self.set_endpoint_resolver(::std::option::Option::Some(endpoint_resolver.into_shared_resolver()));
         self

@@ -1281,1343 +1341,1413 @@

↥ Expand context

             .cloned()
             .map(|r| layer.store_put(::aws_types::region::SigningRegion::from(r)));
         Config {
             config: crate::config::Layer::from(layer.clone())
                 .with_name("aws_sdk_timestreamwrite::config::Config")
                 .freeze(),
             cloneable: layer,
             runtime_components: self.runtime_components,
             runtime_plugins: self.runtime_plugins,
             behavior_version: self.behavior_version,
-1353
+        }
-1354
+    }
-1355
+}
 #[derive(::std::fmt::Debug)]
 pub(crate) struct ServiceRuntimePlugin {
     config: ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer>,
     runtime_components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
-1360
+}
-1361
 impl ServiceRuntimePlugin {

     pub fn new(_service_config: crate::config::Config) -> Self {
         let config = {
             let mut cfg = ::aws_smithy_types::config_bag::Layer::new("Timestream_20181101");
             cfg.store_put(crate::idempotency_token::default_provider());
             cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);
             ::std::option::Option::Some(cfg.freeze())
         };
         let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");
         runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({
             use crate::config::auth::ResolveAuthScheme;
             if let Some(preference) = _service_config
                 .config
                 .load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
                 .cloned()
-+
+            {
                 crate::config::auth::DefaultAuthSchemeResolver::default()
                     .with_auth_scheme_preference(preference)
                     .into_shared_resolver()
             } else {
                 crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()
-+
+            }
         }));
         runtime_components.set_endpoint_resolver(::std::option::Option::Some({
             use crate::config::endpoint::ResolveEndpoint;
             crate::config::endpoint::DefaultResolver::new().into_shared_resolver()
         }));
         runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());
         runtime_components.push_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::HttpStatusCodeClassifier::default());
         runtime_components.push_interceptor(crate::sdk_feature_tracker::retry_mode::RetryModeFeatureTrackerInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::service_clock_skew::ServiceClockSkewInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::request_info::RequestInfoInterceptor::new());

↧ Expand context

         runtime_components.push_interceptor(::aws_runtime::user_agent::UserAgentInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::invocation_id::InvocationIdInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::recursion_detection::RecursionDetectionInterceptor::new());
         runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(
             ::aws_runtime::auth::sigv4::SigV4AuthScheme::new(),
         ));
         Self { config, runtime_components }
-1401
+    }
-1402
+}
-1403
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ServiceRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         self.config.clone()
-1407
+    }
-1408
     fn order(&self) -> ::aws_smithy_runtime_api::client::runtime_plugin::Order {
         ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults
-1411
+    }
-1412
     fn runtime_components(

@@ -1407,1479 +1466,1539 @@

↥ Expand context

 pub use ::aws_credential_types::Credentials;
-1480
 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());
         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("AWS_ENDPOINT_URL", "endpoint_url"))
                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),

             );
-1500
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1505
         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));
-1513
+        }
-1514
         if let Some(cache) = input.identity_cache() {
             builder.set_identity_cache(cache);
-1517
+        }
         builder.set_app_name(input.app_name().cloned());
-1519

↧ Expand context

         builder
-1521
+    }
-1522
+}
-1523
 impl From<&::aws_types::sdk_config::SdkConfig> for Config {
     fn from(sdk_config: &::aws_types::sdk_config::SdkConfig) -> Self {
         Builder::from(sdk_config).build()
-1527
+    }
-1528
+}
-1529
 pub use ::aws_types::app_name::AppName;
-1531
 #[allow(dead_code)]
 fn service_config_key<'a>(env: &'a str, profile: &'a str) -> aws_types::service_config::ServiceConfigKey<'a> {
     ::aws_types::service_config::ServiceConfigKey::builder()
         .service_id("Timestream Write")
         .env(env)
         .profile(profile)
         .build()
         .expect("all field sets explicitly, can't fail")

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

@@ -18,18 +113,143 @@

↥ Expand context

-18
+    }
-19
+}
-20
 #[derive(Debug)]
 struct DowncastParams<T>(T);
 impl<T> ::aws_smithy_runtime_api::client::auth::ResolveAuthSchemeOptions for DowncastParams<T>
 where
     T: ResolveAuthScheme,
-26
+{
     fn resolve_auth_scheme_options_v2<'a>(
         &'a self,
         params: &'a ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams,
         cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         match params.get::<crate::config::auth::Params>() {
             ::std::option::Option::Some(concrete_params) => self.0.resolve_auth_scheme(concrete_params, cfg, runtime_components),
             ::std::option::Option::None => ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(::std::result::Result::Err(
                 "params of expected type was not present".into(),
             )),

-38
+        }
-39
+    }
-40
+}
-41
 /// The default auth scheme resolver
 #[derive(Debug)]
 #[allow(dead_code)]
 pub struct DefaultAuthSchemeResolver {
     service_defaults: Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>,
     operation_overrides: ::std::collections::HashMap<&'static str, Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>>,
     preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
-49
+}
-50
 // TODO(https://github.com/smithy-lang/smithy-rs/issues/4177): Remove `allow(...)` once the issue is addressed.
 // When generating code for tests (e.g., `codegen-client-test`), this manual implementation
 // of the `Default` trait may appear as if it could be derived automatically.
 // However, that is not the case in production.
 #[allow(clippy::derivable_impls)]
 impl Default for DefaultAuthSchemeResolver {
     fn default() -> Self {
         Self {
             service_defaults: vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                 .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                 .build()
                 .expect("required fields set")],
             operation_overrides: ::std::collections::HashMap::new(),
             preference: ::std::option::Option::None,
-65
+        }
-66
+    }
-67
+}
-68
 impl crate::config::auth::ResolveAuthScheme for DefaultAuthSchemeResolver {
     fn resolve_auth_scheme<'a>(
         &'a self,
         params: &'a crate::config::auth::Params,
         _cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         _runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         let operation_name = params.operation_name();
-77
         let modeled_auth_options = match self.operation_overrides.get(operation_name) {
             Some(overrides) => overrides,
             None => &self.service_defaults,
         };
-82
         let _fut = ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(Ok(modeled_auth_options.clone()));
-84
         _fut
         match &self.preference {
             ::std::option::Option::Some(preference) => {
                 _fut.map_ok({
                     // maps auth scheme ID to the index in the preference list
                     let preference_map: ::std::collections::HashMap<_, _> = preference.clone().into_iter().enumerate().map(|(i, s)| (s, i)).collect();
                     move |auth_scheme_options| {
                         let (mut preferred, non_preferred): (::std::vec::Vec<_>, ::std::vec::Vec<_>) = auth_scheme_options
                             .into_iter()
                             .partition(|auth_scheme_option| preference_map.contains_key(auth_scheme_option.scheme_id()));
-+
                         preferred.sort_by_key(|opt| preference_map.get(opt.scheme_id()).expect("guaranteed by `partition`"));
                         preferred.extend(non_preferred);
                         preferred
-+
+                    }
                 })
-+
+            }
             ::std::option::Option::None => _fut,
-+
+        }
-+
+    }
-+
+}
-+
 impl DefaultAuthSchemeResolver {
     /// Set auth scheme preference to the default auth scheme resolver
     pub fn with_auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.preference = ::std::option::Option::Some(preference.into());
         self
-114
+    }
-115
+}
-116
 /// Configuration parameters for resolving the correct auth scheme
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Params {
     operation_name: ::std::borrow::Cow<'static, str>,
-121
+}
 impl Params {
     /// Create a builder for [`Params`]

↧ Expand context

     pub fn builder() -> crate::config::auth::ParamsBuilder {
         crate::config::auth::ParamsBuilder::default()
-126
+    }
-127
     /// Return the operation name for [`Params`]
     pub fn operation_name(&self) -> &str {
         self.operation_name.as_ref()
-131
+    }
-132
+}
-133
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /// Builder for [`Params`]
 pub struct ParamsBuilder {
     operation_name: ::std::option::Option<::std::borrow::Cow<'static, str>>,
-138
+}
 impl ParamsBuilder {
     /// Set the operation name for the builder
     pub fn operation_name(self, operation_name: impl Into<::std::borrow::Cow<'static, str>>) -> Self {
         self.set_operation_name(::std::option::Option::Some(operation_name.into()))
-143
+    }

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

@@ -2,2 +158,158 @@

↥ Expand context

 [package]
 name = "aws-sdk-transcribestreaming"
 version = "0.0.0-local"
 authors = ["AWS Rust SDK Team <aws-sdk-rust@amazon.com>", "Russell Cohen <rcoh@amazon.com>"]
 description = "AWS SDK for Amazon Transcribe Streaming Service"
 edition = "2021"
 license = "Apache-2.0"
 repository = "https://github.com/awslabs/aws-sdk-rust"
 rust-version = "1.86.0"
 readme = "README.md"
 [package.metadata.smithy]
 codegen-version = "ci"
 [package.metadata.docs.rs]
 all-features = true
 targets = ["x86_64-unknown-linux-gnu"]
 [dependencies.aws-credential-types]
 path = "../aws-credential-types"
 version = "1.2.3"
-20
 [dependencies.aws-runtime]

 path = "../aws-runtime"
 features = ["event-stream"]
 version = "1.5.9"
-25
 [dependencies.aws-sigv4]
 path = "../aws-sigv4"
 version = "1.3.3"
-29
 [dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 version = "1.2.5"
 version = "1.3.0"
-33
 [dependencies.aws-smithy-eventstream]
 path = "../aws-smithy-eventstream"
 version = "0.60.9"
-37
 [dependencies.aws-smithy-http]
 path = "../aws-smithy-http"
 features = ["event-stream"]
 version = "0.62.1"
-42
 [dependencies.aws-smithy-json]
 path = "../aws-smithy-json"
 version = "0.61.4"
-46
 [dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["client"]
 version = "1.8.4"
 version = "1.8.5"
-51
 [dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["client", "http-02x"]
 version = "1.8.3"
 version = "1.8.4"
-56
 [dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 features = ["http-body-0-4-x"]
 version = "1.3.2"
-61
 [dependencies.aws-types]
 path = "../aws-types"
 version = "1.3.7"
 version = "1.3.8"
-65
 [dependencies.bytes]
 version = "1.4.0"
-68
 [dependencies.fastrand]
 version = "2.0.0"
-71
 [dependencies.http]
 version = "0.2.9"
-74
 [dependencies.hyper]
 version = "0.14.26"
 features = ["stream"]
-78
 [dependencies.regex-lite]
 version = "0.1.5"
-81
 [dependencies.tracing]
 version = "0.1"
 [dev-dependencies.async-stream]
 version = "0.3.0"
-86
 [dev-dependencies.aws-config]
 path = "../aws-config"
 version = "1.8.2"
 version = "1.8.3"
-90
 [dev-dependencies.aws-credential-types]
 path = "../aws-credential-types"
 features = ["test-util"]
 version = "1.2.3"
-95
 [dev-dependencies.aws-runtime]
 path = "../aws-runtime"
 features = ["test-util"]
 version = "1.5.9"
-100
 [dev-dependencies.aws-smithy-async]
 path = "../aws-smithy-async"
 features = ["test-util"]
 version = "1.2.5"
 version = "1.3.0"
-105
 [dev-dependencies.aws-smithy-eventstream]
 path = "../aws-smithy-eventstream"
 features = ["test-util"]
 version = "0.60.9"
-110
 [dev-dependencies.aws-smithy-http-client]
 path = "../aws-smithy-http-client"
 features = ["test-util", "wire-mock"]
 version = "1.0.6"
-115
 [dev-dependencies.aws-smithy-protocol-test]
 path = "../aws-smithy-protocol-test"
 version = "0.63.4"
-119
 [dev-dependencies.aws-smithy-runtime]
 path = "../aws-smithy-runtime"
 features = ["test-util"]
 version = "1.8.4"
 version = "1.8.5"
-124
 [dev-dependencies.aws-smithy-runtime-api]
 path = "../aws-smithy-runtime-api"
 features = ["test-util"]
 version = "1.8.3"
 version = "1.8.4"
-129
 [dev-dependencies.aws-smithy-types]
 path = "../aws-smithy-types"
 features = ["test-util"]
 version = "1.3.2"
-134
 [dev-dependencies.futures-core]
 version = "0.3.25"
-137
 [dev-dependencies.futures-util]

↧ Expand context

 version = "0.3.25"
 features = ["alloc"]
 default-features = false
-142
 [dev-dependencies.hound]
 version = "3.4.0"
-145
 [dev-dependencies.http-1x]
 version = "1"
 package = "http"
-149
 [dev-dependencies.serde_json]
 version = "1.0.0"
-152
 [dev-dependencies.tokio]
 version = "1.23.1"
 features = ["macros", "test-util", "rt-multi-thread"]
-156
 [dev-dependencies.tracing-subscriber]
 version = "0.3.16"

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

@@ -36,36 +95,99 @@

↥ Expand context

     ///
     pub fn builder() -> Builder {
         Builder::default()
-39
+    }
     /// Converts this config back into a builder so that it can be tweaked.
     pub fn to_builder(&self) -> Builder {
         Builder {
             config: self.cloneable.clone(),
             runtime_components: self.runtime_components.clone(),
             runtime_plugins: self.runtime_plugins.clone(),
             behavior_version: self.behavior_version,
-47
+        }
-48
+    }
     /// Return a reference to the stalled stream protection configuration contained in this config, if any.
     pub fn stalled_stream_protection(&self) -> ::std::option::Option<&crate::config::StalledStreamProtectionConfig> {
         self.config.load::<crate::config::StalledStreamProtectionConfig>()
-52
+    }
     /// Return the [`SharedHttpClient`](crate::config::SharedHttpClient) to use when making requests, if any.
     pub fn http_client(&self) -> Option<crate::config::SharedHttpClient> {
         self.runtime_components.http_client()

-56
+    }
     /// Return the auth schemes configured on this service config
     pub fn auth_schemes(&self) -> impl Iterator<Item = ::aws_smithy_runtime_api::client::auth::SharedAuthScheme> + '_ {
         self.runtime_components.auth_schemes()
-60
+    }
-61
     /// Return the auth scheme resolver configured on this service config
     pub fn auth_scheme_resolver(&self) -> ::std::option::Option<::aws_smithy_runtime_api::client::auth::SharedAuthSchemeOptionResolver> {
         self.runtime_components.auth_scheme_option_resolver()
-65
+    }
     /// Returns the configured auth scheme preference
     pub fn auth_scheme_preference(&self) -> ::std::option::Option<&::aws_smithy_runtime_api::client::auth::AuthSchemePreference> {
         self.config.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
-+
+    }
     /// Returns the endpoint resolver.
     pub fn endpoint_resolver(&self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver {
         self.runtime_components.endpoint_resolver().expect("resolver defaulted if not set")
-73
+    }
     /// Return a reference to the retry configuration contained in this config, if any.
     pub fn retry_config(&self) -> ::std::option::Option<&::aws_smithy_types::retry::RetryConfig> {
         self.config.load::<::aws_smithy_types::retry::RetryConfig>()
-77
+    }
-78
     /// Return a cloned shared async sleep implementation from this config, if any.

↧ Expand context

     pub fn sleep_impl(&self) -> ::std::option::Option<crate::config::SharedAsyncSleep> {
         self.runtime_components.sleep_impl()
-82
+    }
-83
     /// Return a reference to the timeout configuration contained in this config, if any.
     pub fn timeout_config(&self) -> ::std::option::Option<&::aws_smithy_types::timeout::TimeoutConfig> {
         self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>()
-87
+    }
-88
     /// Returns a reference to the retry partition contained in this config, if any.
     ///
     /// WARNING: This method is unstable and may be removed at any time. Do not rely on this
     /// method for anything!
     pub fn retry_partition(&self) -> ::std::option::Option<&::aws_smithy_runtime::client::retries::RetryPartition> {
         self.config.load::<::aws_smithy_runtime::client::retries::RetryPartition>()
-95
+    }
     /// Returns the configured identity cache for auth.
     pub fn identity_cache(&self) -> ::std::option::Option<crate::config::SharedIdentityCache> {
         self.runtime_components.identity_cache()
-99
+    }

@@ -149,153 +208,213 @@

↥ Expand context

     pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
     pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
-155
+}
 impl ::std::default::Default for Builder {
     fn default() -> Self {
         Self {
             config: ::std::default::Default::default(),
             runtime_components: crate::config::RuntimeComponentsBuilder::new("service config"),
             runtime_plugins: ::std::default::Default::default(),
             behavior_version: ::std::default::Default::default(),
-163
+        }
-164
+    }
-165
+}
 impl Builder {
     ///
     /// Constructs a config builder.
     /// <div class="warning">
     /// Note that a config created from this builder will not have the same safe defaults as one created by
     /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
     /// </div>

     ///
     pub fn new() -> Self {
         Self::default()
-176
+    }
     /// Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
     /// but not those in runtime components.
     #[allow(unused)]
     pub(crate) fn from_config_bag(config_bag: &::aws_smithy_types::config_bag::ConfigBag) -> Self {
         let mut builder = Self::new();
         builder.set_stalled_stream_protection(config_bag.load::<crate::config::StalledStreamProtectionConfig>().cloned());
         builder.set_auth_scheme_preference(config_bag.load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>().cloned());
         builder.set_retry_config(config_bag.load::<::aws_smithy_types::retry::RetryConfig>().cloned());
         builder.set_timeout_config(config_bag.load::<::aws_smithy_types::timeout::TimeoutConfig>().cloned());
         builder.set_retry_partition(config_bag.load::<::aws_smithy_runtime::client::retries::RetryPartition>().cloned());
         builder.set_app_name(config_bag.load::<::aws_types::app_name::AppName>().cloned());
         builder.set_endpoint_url(config_bag.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()));
         builder.set_use_dual_stack(config_bag.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0));
         builder.set_use_fips(config_bag.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0));
         builder.set_region(config_bag.load::<crate::config::Region>().cloned());
         builder
-193
+    }

↧ Expand context

     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn stalled_stream_protection(mut self, stalled_stream_protection_config: crate::config::StalledStreamProtectionConfig) -> Self {
         self.set_stalled_stream_protection(::std::option::Option::Some(stalled_stream_protection_config));
         self
-199
+    }
     /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
     /// to configure protection for stalled streams.
     pub fn set_stalled_stream_protection(
         &mut self,
         stalled_stream_protection_config: ::std::option::Option<crate::config::StalledStreamProtectionConfig>,
     ) -> &mut Self {
         self.config.store_or_unset(stalled_stream_protection_config);
         self
-208
+    }
     /// Sets the HTTP client to use when making requests.
     ///
     /// # Examples
     /// ```no_run
     /// # #[cfg(test)]

@@ -398,403 +457,519 @@

↥ Expand context

     ///     fn resolve_auth_scheme<'a>(
     ///         &'a self,
     ///         _params: &'a aws_sdk_transcribestreaming::config::auth::Params,
     ///         _cfg: &'a ConfigBag,
     ///         _runtime_components: &'a RuntimeComponents,
     ///     ) -> AuthSchemeOptionsFuture<'a> {
     ///         // --snip--
     /// #      todo!()
     ///     }
     /// }
     ///
     /// let config = aws_sdk_transcribestreaming::Config::builder()
     ///     .auth_scheme_resolver(CustomAuthSchemeResolver)
     ///     // other configurations
     ///     .build();
     /// ```
     pub fn auth_scheme_resolver(mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> Self {
         self.set_auth_scheme_resolver(auth_scheme_resolver);
         self
-422
+    }

-423
     /// Set the auth scheme resolver for the builder
     ///
     /// # Examples
     /// See an example for [`Self::auth_scheme_resolver`].
     pub fn set_auth_scheme_resolver(&mut self, auth_scheme_resolver: impl crate::config::auth::ResolveAuthScheme + 'static) -> &mut Self {
         self.runtime_components
             .set_auth_scheme_option_resolver(::std::option::Option::Some(auth_scheme_resolver.into_shared_resolver()));
         self
-432
+    }
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_transcribestreaming::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_transcribestreaming::Client::from_conf(config);
     /// ```
-+
     pub fn auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.set_auth_scheme_preference(::std::option::Option::Some(preference.into()));
         self
-+
+    }
-+
     /// Set the auth scheme preference for an auth scheme resolver
     /// (typically the default auth scheme resolver).
     ///
     /// Each operation has a predefined order of auth schemes, as determined by the service,
     /// for auth scheme resolution. By using the auth scheme preference, customers
     /// can reorder the schemes resolved by the auth scheme resolver.
     ///
     /// The preference list is intended as a hint rather than a strict override.
     /// Any schemes not present in the originally resolved auth schemes will be ignored.
     ///
     /// # Examples
     ///
     /// ```no_run
     /// # use aws_smithy_runtime_api::client::auth::AuthSchemeId;
     /// let config = aws_sdk_transcribestreaming::Config::builder()
     ///     .auth_scheme_preference([AuthSchemeId::from("scheme1"), AuthSchemeId::from("scheme2")])
     ///     // ...
     ///     .build();
     /// let client = aws_sdk_transcribestreaming::Client::from_conf(config);
     /// ```
-+
     pub fn set_auth_scheme_preference(
         &mut self,
         preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> &mut Self {
         self.config.store_or_unset(preference);
         self
-+
+    }
     /// Sets the endpoint resolver to use when making requests.
     ///
     ///
     /// When unset, the client will used a generated endpoint resolver based on the endpoint resolution
     /// rules for `aws_sdk_transcribestreaming`.
     ///
     ///
     /// Note: setting an endpoint resolver will replace any endpoint URL that has been set.
     /// This method accepts an endpoint resolver [specific to this service](crate::config::endpoint::ResolveEndpoint). If you want to
     /// provide a shared endpoint resolver, use [`Self::set_endpoint_resolver`].

↧ Expand context

     ///
     /// # Examples
     /// Create a custom endpoint resolver that resolves a different endpoing per-stage, e.g. staging vs. production.
     /// ```no_run
     /// use aws_sdk_transcribestreaming::config::endpoint::{ResolveEndpoint, EndpointFuture, Params, Endpoint};
     /// #[derive(Debug)]
     /// struct StageResolver { stage: String }
     /// impl ResolveEndpoint for StageResolver {
     ///     fn resolve_endpoint(&self, params: &Params) -> EndpointFuture<'_> {
     ///         let stage = &self.stage;
     ///         EndpointFuture::ready(Ok(Endpoint::builder().url(format!("{stage}.myservice.com")).build()))
     ///     }
     /// }
     /// let resolver = StageResolver { stage: std::env::var("STAGE").unwrap() };
     /// let config = aws_sdk_transcribestreaming::Config::builder().endpoint_resolver(resolver).build();
     /// let client = aws_sdk_transcribestreaming::Client::from_conf(config);
     /// ```
     pub fn endpoint_resolver(mut self, endpoint_resolver: impl crate::config::endpoint::ResolveEndpoint + 'static) -> Self {
         self.set_endpoint_resolver(::std::option::Option::Some(endpoint_resolver.into_shared_resolver()));
         self

@@ -1263,1325 +1323,1395 @@

↥ Expand context

             .load::<::aws_types::region::Region>()
             .cloned()
             .map(|r| layer.store_put(::aws_types::region::SigningRegion::from(r)));
         Config {
             config: crate::config::Layer::from(layer.clone())
                 .with_name("aws_sdk_transcribestreaming::config::Config")
                 .freeze(),
             cloneable: layer,
             runtime_components: self.runtime_components,
             runtime_plugins: self.runtime_plugins,
             behavior_version: self.behavior_version,
-1336
+        }
-1337
+    }
-1338
+}
 #[derive(::std::fmt::Debug)]
 pub(crate) struct ServiceRuntimePlugin {
     config: ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer>,
     runtime_components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
-1343
+}
-1344

 impl ServiceRuntimePlugin {
     pub fn new(_service_config: crate::config::Config) -> Self {
         let config = {
             let mut cfg = ::aws_smithy_types::config_bag::Layer::new("Transcribe");
             cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);
             ::std::option::Option::Some(cfg.freeze())
         };
         let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");
         runtime_components.set_auth_scheme_option_resolver(::std::option::Option::Some({
             use crate::config::auth::ResolveAuthScheme;
             if let Some(preference) = _service_config
                 .config
                 .load::<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>()
                 .cloned()
-+
+            {
                 crate::config::auth::DefaultAuthSchemeResolver::default()
                     .with_auth_scheme_preference(preference)
                     .into_shared_resolver()
             } else {
                 crate::config::auth::DefaultAuthSchemeResolver::default().into_shared_resolver()
-+
+            }
         }));
         runtime_components.set_endpoint_resolver(::std::option::Option::Some({
             use crate::config::endpoint::ResolveEndpoint;
             crate::config::endpoint::DefaultResolver::new().into_shared_resolver()
         }));
         runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());
         runtime_components.push_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::HttpStatusCodeClassifier::default());
         runtime_components.push_interceptor(crate::sdk_feature_tracker::retry_mode::RetryModeFeatureTrackerInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::service_clock_skew::ServiceClockSkewInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::request_info::RequestInfoInterceptor::new());

↧ Expand context

         runtime_components.push_interceptor(::aws_runtime::user_agent::UserAgentInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::invocation_id::InvocationIdInterceptor::new());
         runtime_components.push_interceptor(::aws_runtime::recursion_detection::RecursionDetectionInterceptor::new());
         runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(
             ::aws_runtime::auth::sigv4::SigV4AuthScheme::new(),
         ));
         Self { config, runtime_components }
-1383
+    }
-1384
+}
-1385
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ServiceRuntimePlugin {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         self.config.clone()
-1389
+    }
-1390
     fn order(&self) -> ::aws_smithy_runtime_api::client::runtime_plugin::Order {
         ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults
-1393
+    }
-1394
     fn runtime_components(

@@ -1389,1461 +1448,1521 @@

↥ Expand context

 pub use ::aws_credential_types::Credentials;
-1462
 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());
         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("AWS_ENDPOINT_URL", "endpoint_url"))
                             .map(|it| it.parse().unwrap())
                     })
                     .or_else(|| input.endpoint_url().map(|s| s.to_string())),

             );
-1482
+        }
         // resiliency
         builder.set_retry_config(input.retry_config().cloned());
         builder.set_timeout_config(input.timeout_config().cloned());
         builder.set_sleep_impl(input.sleep_impl());
-1487
         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));
-1495
+        }
-1496
         if let Some(cache) = input.identity_cache() {
             builder.set_identity_cache(cache);
-1499
+        }
         builder.set_app_name(input.app_name().cloned());
-1501

↧ Expand context

         builder
-1503
+    }
-1504
+}
-1505
 impl From<&::aws_types::sdk_config::SdkConfig> for Config {
     fn from(sdk_config: &::aws_types::sdk_config::SdkConfig) -> Self {
         Builder::from(sdk_config).build()
-1509
+    }
-1510
+}
-1511
 pub use ::aws_types::app_name::AppName;
-1513
 #[allow(dead_code)]
 fn service_config_key<'a>(env: &'a str, profile: &'a str) -> aws_types::service_config::ServiceConfigKey<'a> {
     ::aws_types::service_config::ServiceConfigKey::builder()
         .service_id("Transcribe Streaming")
         .env(env)
         .profile(profile)
         .build()
         .expect("all field sets explicitly, can't fail")

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

@@ -18,18 +113,143 @@

↥ Expand context

-18
+    }
-19
+}
-20
 #[derive(Debug)]
 struct DowncastParams<T>(T);
 impl<T> ::aws_smithy_runtime_api::client::auth::ResolveAuthSchemeOptions for DowncastParams<T>
 where
     T: ResolveAuthScheme,
-26
+{
     fn resolve_auth_scheme_options_v2<'a>(
         &'a self,
         params: &'a ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams,
         cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         match params.get::<crate::config::auth::Params>() {
             ::std::option::Option::Some(concrete_params) => self.0.resolve_auth_scheme(concrete_params, cfg, runtime_components),
             ::std::option::Option::None => ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(::std::result::Result::Err(
                 "params of expected type was not present".into(),
             )),

-38
+        }
-39
+    }
-40
+}
-41
 /// The default auth scheme resolver
 #[derive(Debug)]
 #[allow(dead_code)]
 pub struct DefaultAuthSchemeResolver {
     service_defaults: Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>,
     operation_overrides: ::std::collections::HashMap<&'static str, Vec<::aws_smithy_runtime_api::client::auth::AuthSchemeOption>>,
     preference: ::std::option::Option<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
-49
+}
-50
 // TODO(https://github.com/smithy-lang/smithy-rs/issues/4177): Remove `allow(...)` once the issue is addressed.
 // When generating code for tests (e.g., `codegen-client-test`), this manual implementation
 // of the `Default` trait may appear as if it could be derived automatically.
 // However, that is not the case in production.
 #[allow(clippy::derivable_impls)]
 impl Default for DefaultAuthSchemeResolver {
     fn default() -> Self {
         Self {
             service_defaults: vec![::aws_smithy_runtime_api::client::auth::AuthSchemeOption::builder()
                 .scheme_id(::aws_runtime::auth::sigv4::SCHEME_ID)
                 .build()
                 .expect("required fields set")],
             operation_overrides: ::std::collections::HashMap::new(),
             preference: ::std::option::Option::None,
-65
+        }
-66
+    }
-67
+}
-68
 impl crate::config::auth::ResolveAuthScheme for DefaultAuthSchemeResolver {
     fn resolve_auth_scheme<'a>(
         &'a self,
         params: &'a crate::config::auth::Params,
         _cfg: &'a ::aws_smithy_types::config_bag::ConfigBag,
         _runtime_components: &'a ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents,
     ) -> ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture<'a> {
         let operation_name = params.operation_name();
-77
         let modeled_auth_options = match self.operation_overrides.get(operation_name) {
             Some(overrides) => overrides,
             None => &self.service_defaults,
         };
-82
         let _fut = ::aws_smithy_runtime_api::client::auth::AuthSchemeOptionsFuture::ready(Ok(modeled_auth_options.clone()));
-84
         _fut
         match &self.preference {
             ::std::option::Option::Some(preference) => {
                 _fut.map_ok({
                     // maps auth scheme ID to the index in the preference list
                     let preference_map: ::std::collections::HashMap<_, _> = preference.clone().into_iter().enumerate().map(|(i, s)| (s, i)).collect();
                     move |auth_scheme_options| {
                         let (mut preferred, non_preferred): (::std::vec::Vec<_>, ::std::vec::Vec<_>) = auth_scheme_options
                             .into_iter()
                             .partition(|auth_scheme_option| preference_map.contains_key(auth_scheme_option.scheme_id()));
-+
                         preferred.sort_by_key(|opt| preference_map.get(opt.scheme_id()).expect("guaranteed by `partition`"));
                         preferred.extend(non_preferred);
                         preferred
-+
+                    }
                 })
-+
+            }
             ::std::option::Option::None => _fut,
-+
+        }
-+
+    }
-+
+}
-+
 impl DefaultAuthSchemeResolver {
     /// Set auth scheme preference to the default auth scheme resolver
     pub fn with_auth_scheme_preference(
         mut self,
         preference: impl ::std::convert::Into<::aws_smithy_runtime_api::client::auth::AuthSchemePreference>,
     ) -> Self {
         self.preference = ::std::option::Option::Some(preference.into());
         self
-114
+    }
-115
+}
-116
 /// Configuration parameters for resolving the correct auth scheme
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct Params {
     operation_name: ::std::borrow::Cow<'static, str>,
-121
+}
 impl Params {
     /// Create a builder for [`Params`]

↧ Expand context

     pub fn builder() -> crate::config::auth::ParamsBuilder {
         crate::config::auth::ParamsBuilder::default()
-126
+    }
-127
     /// Return the operation name for [`Params`]
     pub fn operation_name(&self) -> &str {
         self.operation_name.as_ref()
-131
+    }
-132
+}
-133
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /// Builder for [`Params`]
 pub struct ParamsBuilder {
     operation_name: ::std::option::Option<::std::borrow::Cow<'static, str>>,
-138
+}
 impl ParamsBuilder {
     /// Set the operation name for the builder
     pub fn operation_name(self, operation_name: impl Into<::std::borrow::Cow<'static, str>>) -> Self {
         self.set_operation_name(::std::option::Option::Some(operation_name.into()))
-143
+    }

Pages: 1 2 3 4 5 6 7