aws_sdk_codecatalyst/
config.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2
3/// Configuration for a aws_sdk_codecatalyst service client.
4///
5///
6/// Service configuration allows for customization of endpoints, region, credentials providers,
7/// and retry configuration. Generally, it is constructed automatically for you from a shared
8/// configuration loaded by the `aws-config` crate. For example:
9///
10/// ```ignore
11/// // Load a shared config from the environment
12/// let shared_config = aws_config::from_env().load().await;
13/// // The client constructor automatically converts the shared config into the service config
14/// let client = Client::new(&shared_config);
15/// ```
16///
17/// The service config can also be constructed manually using its builder.
18///
19#[derive(::std::clone::Clone, ::std::fmt::Debug)]
20pub struct Config {
21    // Both `config` and `cloneable` are the same config, but the cloneable one
22    // is kept around so that it is possible to convert back into a builder. This can be
23    // optimized in the future.
24    pub(crate) config: crate::config::FrozenLayer,
25    cloneable: ::aws_smithy_types::config_bag::CloneableLayer,
26    pub(crate) runtime_components: crate::config::RuntimeComponentsBuilder,
27    pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
28    behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
29}
30impl Config {
31    ///
32    /// Constructs a config builder.
33    /// <div class="warning">
34    /// Note that a config created from this builder will not have the same safe defaults as one created by
35    /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
36    /// </div>
37    ///
38    pub fn builder() -> Builder {
39        Builder::default()
40    }
41    /// Converts this config back into a builder so that it can be tweaked.
42    pub fn to_builder(&self) -> Builder {
43        Builder {
44            config: self.cloneable.clone(),
45            runtime_components: self.runtime_components.clone(),
46            runtime_plugins: self.runtime_plugins.clone(),
47            behavior_version: self.behavior_version,
48        }
49    }
50    /// Return a reference to the stalled stream protection configuration contained in this config, if any.
51    pub fn stalled_stream_protection(&self) -> ::std::option::Option<&crate::config::StalledStreamProtectionConfig> {
52        self.config.load::<crate::config::StalledStreamProtectionConfig>()
53    }
54    /// Return the [`SharedHttpClient`](crate::config::SharedHttpClient) to use when making requests, if any.
55    pub fn http_client(&self) -> Option<crate::config::SharedHttpClient> {
56        self.runtime_components.http_client()
57    }
58    /// Returns the endpoint resolver.
59    pub fn endpoint_resolver(&self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver {
60        self.runtime_components.endpoint_resolver().expect("resolver defaulted if not set")
61    }
62    /// Return a reference to the retry configuration contained in this config, if any.
63    pub fn retry_config(&self) -> ::std::option::Option<&::aws_smithy_types::retry::RetryConfig> {
64        self.config.load::<::aws_smithy_types::retry::RetryConfig>()
65    }
66
67    /// Return a cloned shared async sleep implementation from this config, if any.
68    pub fn sleep_impl(&self) -> ::std::option::Option<crate::config::SharedAsyncSleep> {
69        self.runtime_components.sleep_impl()
70    }
71
72    /// Return a reference to the timeout configuration contained in this config, if any.
73    pub fn timeout_config(&self) -> ::std::option::Option<&::aws_smithy_types::timeout::TimeoutConfig> {
74        self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>()
75    }
76
77    /// Returns a reference to the retry partition contained in this config, if any.
78    ///
79    /// WARNING: This method is unstable and may be removed at any time. Do not rely on this
80    /// method for anything!
81    pub fn retry_partition(&self) -> ::std::option::Option<&::aws_smithy_runtime::client::retries::RetryPartition> {
82        self.config.load::<::aws_smithy_runtime::client::retries::RetryPartition>()
83    }
84    /// Returns the configured identity cache for auth.
85    pub fn identity_cache(&self) -> ::std::option::Option<crate::config::SharedIdentityCache> {
86        self.runtime_components.identity_cache()
87    }
88    /// Returns interceptors currently registered by the user.
89    pub fn interceptors(&self) -> impl Iterator<Item = crate::config::SharedInterceptor> + '_ {
90        self.runtime_components.interceptors()
91    }
92    /// Return time source used for this service.
93    pub fn time_source(&self) -> ::std::option::Option<::aws_smithy_async::time::SharedTimeSource> {
94        self.runtime_components.time_source()
95    }
96    /// Returns retry classifiers currently registered by the user.
97    pub fn retry_classifiers(&self) -> impl Iterator<Item = ::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier> + '_ {
98        self.runtime_components.retry_classifiers()
99    }
100    /// Returns the name of the app that is using the client, if it was provided.
101    ///
102    /// This _optional_ name is used to identify the application in the user agent that
103    /// gets sent along with requests.
104    pub fn app_name(&self) -> ::std::option::Option<&::aws_types::app_name::AppName> {
105        self.config.load::<::aws_types::app_name::AppName>()
106    }
107    /// Returns the invocation ID generator if one was given in config.
108    ///
109    /// The invocation ID generator generates ID values for the `amz-sdk-invocation-id` header. By default, this will be a random UUID. Overriding it may be useful in tests that examine the HTTP request and need to be deterministic.
110    pub fn invocation_id_generator(&self) -> ::std::option::Option<::aws_runtime::invocation_id::SharedInvocationIdGenerator> {
111        self.config.load::<::aws_runtime::invocation_id::SharedInvocationIdGenerator>().cloned()
112    }
113    /// Creates a new [service config](crate::Config) from a [shared `config`](::aws_types::sdk_config::SdkConfig).
114    pub fn new(config: &::aws_types::sdk_config::SdkConfig) -> Self {
115        Builder::from(config).build()
116    }
117    /// Returns the AWS region, if it was provided.
118    pub fn region(&self) -> ::std::option::Option<&crate::config::Region> {
119        self.config.load::<crate::config::Region>()
120    }
121}
122/// Builder for creating a `Config`.
123#[derive(::std::clone::Clone, ::std::fmt::Debug)]
124pub struct Builder {
125    pub(crate) config: ::aws_smithy_types::config_bag::CloneableLayer,
126    pub(crate) runtime_components: crate::config::RuntimeComponentsBuilder,
127    pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
128    pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
129}
130impl ::std::default::Default for Builder {
131    fn default() -> Self {
132        Self {
133            config: ::std::default::Default::default(),
134            runtime_components: crate::config::RuntimeComponentsBuilder::new("service config"),
135            runtime_plugins: ::std::default::Default::default(),
136            behavior_version: ::std::default::Default::default(),
137        }
138    }
139}
140impl Builder {
141    ///
142    /// Constructs a config builder.
143    /// <div class="warning">
144    /// Note that a config created from this builder will not have the same safe defaults as one created by
145    /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
146    /// </div>
147    ///
148    pub fn new() -> Self {
149        Self::default()
150    }
151    /// Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
152    /// but not those in runtime components.
153    #[allow(unused)]
154    pub(crate) fn from_config_bag(config_bag: &::aws_smithy_types::config_bag::ConfigBag) -> Self {
155        let mut builder = Self::new();
156        builder.set_stalled_stream_protection(config_bag.load::<crate::config::StalledStreamProtectionConfig>().cloned());
157        builder.set_retry_config(config_bag.load::<::aws_smithy_types::retry::RetryConfig>().cloned());
158        builder.set_timeout_config(config_bag.load::<::aws_smithy_types::timeout::TimeoutConfig>().cloned());
159        builder.set_retry_partition(config_bag.load::<::aws_smithy_runtime::client::retries::RetryPartition>().cloned());
160        builder.set_app_name(config_bag.load::<::aws_types::app_name::AppName>().cloned());
161        builder.set_endpoint_url(config_bag.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()));
162        builder.set_use_fips(config_bag.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0));
163        builder.set_region(config_bag.load::<crate::config::Region>().cloned());
164        builder
165    }
166    /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
167    /// to configure protection for stalled streams.
168    pub fn stalled_stream_protection(mut self, stalled_stream_protection_config: crate::config::StalledStreamProtectionConfig) -> Self {
169        self.set_stalled_stream_protection(::std::option::Option::Some(stalled_stream_protection_config));
170        self
171    }
172    /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
173    /// to configure protection for stalled streams.
174    pub fn set_stalled_stream_protection(
175        &mut self,
176        stalled_stream_protection_config: ::std::option::Option<crate::config::StalledStreamProtectionConfig>,
177    ) -> &mut Self {
178        self.config.store_or_unset(stalled_stream_protection_config);
179        self
180    }
181    /// Sets the idempotency token provider to use for service calls that require tokens.
182    pub fn idempotency_token_provider(
183        mut self,
184        idempotency_token_provider: impl ::std::convert::Into<crate::idempotency_token::IdempotencyTokenProvider>,
185    ) -> Self {
186        self.set_idempotency_token_provider(::std::option::Option::Some(idempotency_token_provider.into()));
187        self
188    }
189    /// Sets the idempotency token provider to use for service calls that require tokens.
190    pub fn set_idempotency_token_provider(
191        &mut self,
192        idempotency_token_provider: ::std::option::Option<crate::idempotency_token::IdempotencyTokenProvider>,
193    ) -> &mut Self {
194        self.config.store_or_unset(idempotency_token_provider);
195        self
196    }
197    /// Sets the HTTP client to use when making requests.
198    ///
199    /// # Examples
200    /// ```no_run
201    /// # #[cfg(test)]
202    /// # mod tests {
203    /// # #[test]
204    /// # fn example() {
205    /// use std::time::Duration;
206    /// use aws_sdk_codecatalyst::config::Config;
207    /// use aws_smithy_runtime::client::http::hyper_014::HyperClientBuilder;
208    ///
209    /// let https_connector = hyper_rustls::HttpsConnectorBuilder::new()
210    ///     .with_webpki_roots()
211    ///     .https_only()
212    ///     .enable_http1()
213    ///     .enable_http2()
214    ///     .build();
215    /// let hyper_client = HyperClientBuilder::new().build(https_connector);
216    ///
217    /// // This connector can then be given to a generated service Config
218    /// let config = my_service_client::Config::builder()
219    ///     .endpoint_url("https://example.com")
220    ///     .http_client(hyper_client)
221    ///     .build();
222    /// let client = my_service_client::Client::from_conf(config);
223    /// # }
224    /// # }
225    /// ```
226    pub fn http_client(mut self, http_client: impl crate::config::HttpClient + 'static) -> Self {
227        self.set_http_client(::std::option::Option::Some(crate::config::IntoShared::into_shared(http_client)));
228        self
229    }
230
231    /// Sets the HTTP client to use when making requests.
232    ///
233    /// # Examples
234    /// ```no_run
235    /// # #[cfg(test)]
236    /// # mod tests {
237    /// # #[test]
238    /// # fn example() {
239    /// use std::time::Duration;
240    /// use aws_sdk_codecatalyst::config::{Builder, Config};
241    /// use aws_smithy_runtime::client::http::hyper_014::HyperClientBuilder;
242    ///
243    /// fn override_http_client(builder: &mut Builder) {
244    ///     let https_connector = hyper_rustls::HttpsConnectorBuilder::new()
245    ///         .with_webpki_roots()
246    ///         .https_only()
247    ///         .enable_http1()
248    ///         .enable_http2()
249    ///         .build();
250    ///     let hyper_client = HyperClientBuilder::new().build(https_connector);
251    ///     builder.set_http_client(Some(hyper_client));
252    /// }
253    ///
254    /// let mut builder = aws_sdk_codecatalyst::Config::builder();
255    /// override_http_client(&mut builder);
256    /// let config = builder.build();
257    /// # }
258    /// # }
259    /// ```
260    pub fn set_http_client(&mut self, http_client: Option<crate::config::SharedHttpClient>) -> &mut Self {
261        self.runtime_components.set_http_client(http_client);
262        self
263    }
264    /// Sets the bearer token that will be used for HTTP bearer auth.
265    pub fn bearer_token(self, bearer_token: crate::config::Token) -> Self {
266        self.bearer_token_resolver(bearer_token)
267    }
268
269    /// Sets a bearer token provider that will be used for HTTP bearer auth.
270    pub fn bearer_token_resolver(mut self, bearer_token_resolver: impl crate::config::ResolveIdentity + 'static) -> Self {
271        self.runtime_components.set_identity_resolver(
272            ::aws_smithy_runtime_api::client::auth::http::HTTP_BEARER_AUTH_SCHEME_ID,
273            ::aws_smithy_runtime_api::shared::IntoShared::<::aws_smithy_runtime_api::client::identity::SharedIdentityResolver>::into_shared(
274                bearer_token_resolver,
275            ),
276        );
277        self
278    }
279    /// Sets the endpoint resolver to use when making requests.
280    ///
281
282    /// When unset, the client will used a generated endpoint resolver based on the endpoint resolution
283    /// rules for `aws_sdk_codecatalyst`.
284
285    ///
286    /// Note: setting an endpoint resolver will replace any endpoint URL that has been set.
287    /// This method accepts an endpoint resolver [specific to this service](crate::config::endpoint::ResolveEndpoint). If you want to
288    /// provide a shared endpoint resolver, use [`Self::set_endpoint_resolver`].
289    ///
290    /// # Examples
291    /// Create a custom endpoint resolver that resolves a different endpoing per-stage, e.g. staging vs. production.
292    /// ```no_run
293    /// use aws_sdk_codecatalyst::config::endpoint::{ResolveEndpoint, EndpointFuture, Params, Endpoint};
294    /// #[derive(Debug)]
295    /// struct StageResolver { stage: String }
296    /// impl ResolveEndpoint for StageResolver {
297    ///     fn resolve_endpoint(&self, params: &Params) -> EndpointFuture<'_> {
298    ///         let stage = &self.stage;
299    ///         EndpointFuture::ready(Ok(Endpoint::builder().url(format!("{stage}.myservice.com")).build()))
300    ///     }
301    /// }
302    /// let resolver = StageResolver { stage: std::env::var("STAGE").unwrap() };
303    /// let config = aws_sdk_codecatalyst::Config::builder().endpoint_resolver(resolver).build();
304    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
305    /// ```
306    pub fn endpoint_resolver(mut self, endpoint_resolver: impl crate::config::endpoint::ResolveEndpoint + 'static) -> Self {
307        self.set_endpoint_resolver(::std::option::Option::Some(endpoint_resolver.into_shared_resolver()));
308        self
309    }
310
311    /// Sets the endpoint resolver to use when making requests.
312    ///
313
314    /// When unset, the client will used a generated endpoint resolver based on the endpoint resolution
315    /// rules for `aws_sdk_codecatalyst`.
316    pub fn set_endpoint_resolver(
317        &mut self,
318        endpoint_resolver: ::std::option::Option<::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver>,
319    ) -> &mut Self {
320        self.runtime_components.set_endpoint_resolver(endpoint_resolver);
321        self
322    }
323    /// Set the retry_config for the builder
324    ///
325    /// # Examples
326    /// ```no_run
327    /// use aws_sdk_codecatalyst::config::Config;
328    /// use aws_sdk_codecatalyst::config::retry::RetryConfig;
329    ///
330    /// let retry_config = RetryConfig::standard().with_max_attempts(5);
331    /// let config = Config::builder().retry_config(retry_config).build();
332    /// ```
333    pub fn retry_config(mut self, retry_config: ::aws_smithy_types::retry::RetryConfig) -> Self {
334        self.set_retry_config(Some(retry_config));
335        self
336    }
337
338    /// Set the retry_config for the builder
339    ///
340    /// # Examples
341    /// ```no_run
342    /// use aws_sdk_codecatalyst::config::{Builder, Config};
343    /// use aws_sdk_codecatalyst::config::retry::RetryConfig;
344    ///
345    /// fn disable_retries(builder: &mut Builder) {
346    ///     let retry_config = RetryConfig::standard().with_max_attempts(1);
347    ///     builder.set_retry_config(Some(retry_config));
348    /// }
349    ///
350    /// let mut builder = Config::builder();
351    /// disable_retries(&mut builder);
352    /// let config = builder.build();
353    /// ```
354    pub fn set_retry_config(&mut self, retry_config: ::std::option::Option<::aws_smithy_types::retry::RetryConfig>) -> &mut Self {
355        retry_config.map(|r| self.config.store_put(r));
356        self
357    }
358    /// Set the sleep_impl for the builder
359    ///
360    /// # Examples
361    ///
362    /// ```no_run
363    /// use aws_sdk_codecatalyst::config::{AsyncSleep, Config, SharedAsyncSleep, Sleep};
364    ///
365    /// #[derive(Debug)]
366    /// pub struct ForeverSleep;
367    ///
368    /// impl AsyncSleep for ForeverSleep {
369    ///     fn sleep(&self, duration: std::time::Duration) -> Sleep {
370    ///         Sleep::new(std::future::pending())
371    ///     }
372    /// }
373    ///
374    /// let sleep_impl = SharedAsyncSleep::new(ForeverSleep);
375    /// let config = Config::builder().sleep_impl(sleep_impl).build();
376    /// ```
377    pub fn sleep_impl(mut self, sleep_impl: impl crate::config::AsyncSleep + 'static) -> Self {
378        self.set_sleep_impl(Some(::aws_smithy_runtime_api::shared::IntoShared::into_shared(sleep_impl)));
379        self
380    }
381
382    /// Set the sleep_impl for the builder
383    ///
384    /// # Examples
385    ///
386    /// ```no_run
387    /// use aws_sdk_codecatalyst::config::{AsyncSleep, Builder, Config, SharedAsyncSleep, Sleep};
388    ///
389    /// #[derive(Debug)]
390    /// pub struct ForeverSleep;
391    ///
392    /// impl AsyncSleep for ForeverSleep {
393    ///     fn sleep(&self, duration: std::time::Duration) -> Sleep {
394    ///         Sleep::new(std::future::pending())
395    ///     }
396    /// }
397    ///
398    /// fn set_never_ending_sleep_impl(builder: &mut Builder) {
399    ///     let sleep_impl = SharedAsyncSleep::new(ForeverSleep);
400    ///     builder.set_sleep_impl(Some(sleep_impl));
401    /// }
402    ///
403    /// let mut builder = Config::builder();
404    /// set_never_ending_sleep_impl(&mut builder);
405    /// let config = builder.build();
406    /// ```
407    pub fn set_sleep_impl(&mut self, sleep_impl: ::std::option::Option<crate::config::SharedAsyncSleep>) -> &mut Self {
408        self.runtime_components.set_sleep_impl(sleep_impl);
409        self
410    }
411    /// Set the timeout_config for the builder
412    ///
413    /// # Examples
414    ///
415    /// ```no_run
416    /// # use std::time::Duration;
417    /// use aws_sdk_codecatalyst::config::Config;
418    /// use aws_sdk_codecatalyst::config::timeout::TimeoutConfig;
419    ///
420    /// let timeout_config = TimeoutConfig::builder()
421    ///     .operation_attempt_timeout(Duration::from_secs(1))
422    ///     .build();
423    /// let config = Config::builder().timeout_config(timeout_config).build();
424    /// ```
425    pub fn timeout_config(mut self, timeout_config: ::aws_smithy_types::timeout::TimeoutConfig) -> Self {
426        self.set_timeout_config(Some(timeout_config));
427        self
428    }
429
430    /// Set the timeout_config for the builder.
431    ///
432    /// Setting this to `None` has no effect if another source of configuration has set timeouts. If you
433    /// are attempting to disable timeouts, use [`TimeoutConfig::disabled`](::aws_smithy_types::timeout::TimeoutConfig::disabled)
434    ///
435    ///
436    /// # Examples
437    ///
438    /// ```no_run
439    /// # use std::time::Duration;
440    /// use aws_sdk_codecatalyst::config::{Builder, Config};
441    /// use aws_sdk_codecatalyst::config::timeout::TimeoutConfig;
442    ///
443    /// fn set_request_timeout(builder: &mut Builder) {
444    ///     let timeout_config = TimeoutConfig::builder()
445    ///         .operation_attempt_timeout(Duration::from_secs(1))
446    ///         .build();
447    ///     builder.set_timeout_config(Some(timeout_config));
448    /// }
449    ///
450    /// let mut builder = Config::builder();
451    /// set_request_timeout(&mut builder);
452    /// let config = builder.build();
453    /// ```
454    pub fn set_timeout_config(&mut self, timeout_config: ::std::option::Option<::aws_smithy_types::timeout::TimeoutConfig>) -> &mut Self {
455        // passing None has no impact.
456        let Some(mut timeout_config) = timeout_config else { return self };
457
458        if let Some(base) = self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>() {
459            timeout_config.take_defaults_from(base);
460        }
461        self.config.store_put(timeout_config);
462        self
463    }
464    /// Set the partition for retry-related state. When clients share a retry partition, they will
465    /// also share things like token buckets and client rate limiters. By default, all clients
466    /// for the same service will share a partition.
467    pub fn retry_partition(mut self, retry_partition: ::aws_smithy_runtime::client::retries::RetryPartition) -> Self {
468        self.set_retry_partition(Some(retry_partition));
469        self
470    }
471    /// Set the partition for retry-related state. When clients share a retry partition, they will
472    /// also share things like token buckets and client rate limiters. By default, all clients
473    /// for the same service will share a partition.
474    pub fn set_retry_partition(
475        &mut self,
476        retry_partition: ::std::option::Option<::aws_smithy_runtime::client::retries::RetryPartition>,
477    ) -> &mut Self {
478        retry_partition.map(|r| self.config.store_put(r));
479        self
480    }
481    /// Set the identity cache for auth.
482    ///
483    /// The identity cache defaults to a lazy caching implementation that will resolve
484    /// an identity when it is requested, and place it in the cache thereafter. Subsequent
485    /// requests will take the value from the cache while it is still valid. Once it expires,
486    /// the next request will result in refreshing the identity.
487    ///
488    /// This configuration allows you to disable or change the default caching mechanism.
489    /// To use a custom caching mechanism, implement the [`ResolveCachedIdentity`](crate::config::ResolveCachedIdentity)
490    /// trait and pass that implementation into this function.
491    ///
492    /// # Examples
493    ///
494    /// Disabling identity caching:
495    /// ```no_run
496    /// use aws_sdk_codecatalyst::config::IdentityCache;
497    ///
498    /// let config = aws_sdk_codecatalyst::Config::builder()
499    ///     .identity_cache(IdentityCache::no_cache())
500    ///     // ...
501    ///     .build();
502    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
503    /// ```
504    ///
505    /// Customizing lazy caching:
506    /// ```no_run
507    /// use aws_sdk_codecatalyst::config::IdentityCache;
508    /// use std::time::Duration;
509    ///
510    /// let config = aws_sdk_codecatalyst::Config::builder()
511    ///     .identity_cache(
512    ///         IdentityCache::lazy()
513    ///             // change the load timeout to 10 seconds
514    ///             .load_timeout(Duration::from_secs(10))
515    ///             .build()
516    ///     )
517    ///     // ...
518    ///     .build();
519    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
520    /// ```
521
522    pub fn identity_cache(mut self, identity_cache: impl crate::config::ResolveCachedIdentity + 'static) -> Self {
523        self.set_identity_cache(identity_cache);
524        self
525    }
526
527    /// Set the identity cache for auth.
528    ///
529    /// The identity cache defaults to a lazy caching implementation that will resolve
530    /// an identity when it is requested, and place it in the cache thereafter. Subsequent
531    /// requests will take the value from the cache while it is still valid. Once it expires,
532    /// the next request will result in refreshing the identity.
533    ///
534    /// This configuration allows you to disable or change the default caching mechanism.
535    /// To use a custom caching mechanism, implement the [`ResolveCachedIdentity`](crate::config::ResolveCachedIdentity)
536    /// trait and pass that implementation into this function.
537    ///
538    /// # Examples
539    ///
540    /// Disabling identity caching:
541    /// ```no_run
542    /// use aws_sdk_codecatalyst::config::IdentityCache;
543    ///
544    /// let config = aws_sdk_codecatalyst::Config::builder()
545    ///     .identity_cache(IdentityCache::no_cache())
546    ///     // ...
547    ///     .build();
548    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
549    /// ```
550    ///
551    /// Customizing lazy caching:
552    /// ```no_run
553    /// use aws_sdk_codecatalyst::config::IdentityCache;
554    /// use std::time::Duration;
555    ///
556    /// let config = aws_sdk_codecatalyst::Config::builder()
557    ///     .identity_cache(
558    ///         IdentityCache::lazy()
559    ///             // change the load timeout to 10 seconds
560    ///             .load_timeout(Duration::from_secs(10))
561    ///             .build()
562    ///     )
563    ///     // ...
564    ///     .build();
565    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
566    /// ```
567
568    pub fn set_identity_cache(&mut self, identity_cache: impl crate::config::ResolveCachedIdentity + 'static) -> &mut Self {
569        self.runtime_components.set_identity_cache(::std::option::Option::Some(identity_cache));
570        self
571    }
572    /// Add an [interceptor](crate::config::Intercept) that runs at specific stages of the request execution pipeline.
573    ///
574    /// Interceptors targeted at a certain stage are executed according to the pre-defined priority.
575    /// The SDK provides a default set of interceptors. An interceptor configured by this method
576    /// will run after those default interceptors.
577    ///
578    /// # Examples
579    /// ```no_run
580    /// # #[cfg(test)]
581    /// # mod tests {
582    /// # #[test]
583    /// # fn example() {
584    /// use aws_smithy_runtime_api::client::interceptors::context::phase::BeforeTransmit;
585    /// use aws_smithy_runtime_api::client::interceptors::{Interceptor, InterceptorContext};
586    /// use aws_smithy_types::config_bag::ConfigBag;
587    /// use aws_sdk_codecatalyst::config::Config;
588    ///
589    /// fn base_url() -> String {
590    ///     // ...
591    ///     # String::new()
592    /// }
593    ///
594    /// #[derive(Debug)]
595    /// pub struct UriModifierInterceptor;
596    /// impl Intercept for UriModifierInterceptor {
597    ///     fn modify_before_signing(
598    ///         &self,
599    ///         context: &mut InterceptorContext<BeforeTransmit>,
600    ///         _cfg: &mut ConfigBag,
601    ///     ) -> Result<(), aws_smithy_runtime_api::client::interceptors::BoxError> {
602    ///         let request = context.request_mut();
603    ///         let uri = format!("{}{}", base_url(), request.uri().path());
604    ///         *request.uri_mut() = uri.parse()?;
605    ///
606    ///         Ok(())
607    ///     }
608    /// }
609    ///
610    /// let config = Config::builder()
611    ///     .interceptor(UriModifierInterceptor)
612    ///     .build();
613    /// # }
614    /// # }
615    /// ```
616    pub fn interceptor(mut self, interceptor: impl crate::config::Intercept + 'static) -> Self {
617        self.push_interceptor(crate::config::SharedInterceptor::new(interceptor));
618        self
619    }
620
621    /// Add a [`SharedInterceptor`](crate::config::SharedInterceptor) that runs at specific stages of the request execution pipeline.
622    ///
623    /// Interceptors targeted at a certain stage are executed according to the pre-defined priority.
624    /// The SDK provides a default set of interceptors. An interceptor configured by this method
625    /// will run after those default interceptors.
626    ///
627    /// # Examples
628    /// ```no_run
629    /// # #[cfg(test)]
630    /// # mod tests {
631    /// # #[test]
632    /// # fn example() {
633    /// use aws_smithy_runtime_api::client::interceptors::context::phase::BeforeTransmit;
634    /// use aws_smithy_runtime_api::client::interceptors::{Interceptor, InterceptorContext, SharedInterceptor};
635    /// use aws_smithy_types::config_bag::ConfigBag;
636    /// use aws_sdk_codecatalyst::config::{Builder, Config};
637    ///
638    /// fn base_url() -> String {
639    ///     // ...
640    ///     # String::new()
641    /// }
642    ///
643    /// fn modify_request_uri(builder: &mut Builder) {
644    ///     #[derive(Debug)]
645    ///     pub struct UriModifierInterceptor;
646    ///     impl Intercept for UriModifierInterceptor {
647    ///         fn modify_before_signing(
648    ///             &self,
649    ///             context: &mut InterceptorContext<BeforeTransmit>,
650    ///             _cfg: &mut ConfigBag,
651    ///         ) -> Result<(), aws_smithy_runtime_api::client::interceptors::BoxError> {
652    ///             let request = context.request_mut();
653    ///             let uri = format!("{}{}", base_url(), request.uri().path());
654    ///             *request.uri_mut() = uri.parse()?;
655    ///
656    ///             Ok(())
657    ///         }
658    ///     }
659    ///     builder.push_interceptor(SharedInterceptor::new(UriModifierInterceptor));
660    /// }
661    ///
662    /// let mut builder = Config::builder();
663    /// modify_request_uri(&mut builder);
664    /// let config = builder.build();
665    /// # }
666    /// # }
667    /// ```
668    pub fn push_interceptor(&mut self, interceptor: crate::config::SharedInterceptor) -> &mut Self {
669        self.runtime_components.push_interceptor(interceptor);
670        self
671    }
672
673    /// Set [`SharedInterceptor`](crate::config::SharedInterceptor)s for the builder.
674    pub fn set_interceptors(&mut self, interceptors: impl IntoIterator<Item = crate::config::SharedInterceptor>) -> &mut Self {
675        self.runtime_components.set_interceptors(interceptors.into_iter());
676        self
677    }
678    /// Sets the time source used for this service
679    pub fn time_source(mut self, time_source: impl ::aws_smithy_async::time::TimeSource + 'static) -> Self {
680        self.set_time_source(::std::option::Option::Some(::aws_smithy_runtime_api::shared::IntoShared::into_shared(
681            time_source,
682        )));
683        self
684    }
685    /// Sets the time source used for this service
686    pub fn set_time_source(&mut self, time_source: ::std::option::Option<::aws_smithy_async::time::SharedTimeSource>) -> &mut Self {
687        self.runtime_components.set_time_source(time_source);
688        self
689    }
690    /// Add type implementing [`ClassifyRetry`](::aws_smithy_runtime_api::client::retries::classifiers::ClassifyRetry) that will be used by the
691    /// [`RetryStrategy`](::aws_smithy_runtime_api::client::retries::RetryStrategy) to determine what responses should be retried.
692    ///
693    /// A retry classifier configured by this method will run according to its [priority](::aws_smithy_runtime_api::client::retries::classifiers::RetryClassifierPriority).
694    ///
695    /// # Examples
696    /// ```no_run
697    /// # #[cfg(test)]
698    /// # mod tests {
699    /// # #[test]
700    /// # fn example() {
701    /// use aws_smithy_runtime_api::client::interceptors::context::InterceptorContext;
702    /// use aws_smithy_runtime_api::client::orchestrator::OrchestratorError;
703    /// use aws_smithy_runtime_api::client::retries::classifiers::{
704    ///     ClassifyRetry, RetryAction, RetryClassifierPriority,
705    /// };
706    /// use aws_smithy_types::error::metadata::ProvideErrorMetadata;
707    /// use aws_smithy_types::retry::ErrorKind;
708    /// use std::error::Error as StdError;
709    /// use std::marker::PhantomData;
710    /// use aws_sdk_codecatalyst::config::Config;
711    /// # struct SomeOperationError {}
712    ///
713    /// const RETRYABLE_ERROR_CODES: &[&str] = [
714    ///     // List error codes to be retried here...
715    /// ];
716    ///
717    /// // When classifying at an operation's error type, classifiers require a generic parameter.
718    /// // When classifying the HTTP response alone, no generic is needed.
719    /// #[derive(Debug, Default)]
720    /// pub struct ErrorCodeClassifier<E> {
721    ///     _inner: PhantomData<E>,
722    /// }
723    ///
724    /// impl<E> ExampleErrorCodeClassifier<E> {
725    ///     pub fn new() -> Self {
726    ///         Self {
727    ///             _inner: PhantomData,
728    ///         }
729    ///     }
730    /// }
731    ///
732    /// impl<E> ClassifyRetry for ExampleErrorCodeClassifier<E>
733    /// where
734    ///     // Adding a trait bound for ProvideErrorMetadata allows us to inspect the error code.
735    ///     E: StdError + ProvideErrorMetadata + Send + Sync + 'static,
736    /// {
737    ///     fn classify_retry(&self, ctx: &InterceptorContext) -> RetryAction {
738    ///         // Check for a result
739    ///         let output_or_error = ctx.output_or_error();
740    ///         // Check for an error
741    ///         let error = match output_or_error {
742    ///             Some(Ok(_)) | None => return RetryAction::NoActionIndicated,
743    ///               Some(Err(err)) => err,
744    ///         };
745    ///
746    ///         // Downcast the generic error and extract the code
747    ///         let error_code = OrchestratorError::as_operation_error(error)
748    ///             .and_then(|err| err.downcast_ref::<E>())
749    ///             .and_then(|err| err.code());
750    ///
751    ///         // If this error's code is in our list, return an action that tells the RetryStrategy to retry this request.
752    ///         if let Some(error_code) = error_code {
753    ///             if RETRYABLE_ERROR_CODES.contains(&error_code) {
754    ///                 return RetryAction::transient_error();
755    ///             }
756    ///         }
757    ///
758    ///         // Otherwise, return that no action is indicated i.e. that this classifier doesn't require a retry.
759    ///         // Another classifier may still classify this response as retryable.
760    ///         RetryAction::NoActionIndicated
761    ///     }
762    ///
763    ///     fn name(&self) -> &'static str { "Example Error Code Classifier" }
764    /// }
765    ///
766    /// let config = Config::builder()
767    ///     .retry_classifier(ExampleErrorCodeClassifier::<SomeOperationError>::new())
768    ///     .build();
769    /// # }
770    /// # }
771    /// ```
772    pub fn retry_classifier(
773        mut self,
774        retry_classifier: impl ::aws_smithy_runtime_api::client::retries::classifiers::ClassifyRetry + 'static,
775    ) -> Self {
776        self.push_retry_classifier(::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier::new(
777            retry_classifier,
778        ));
779        self
780    }
781
782    /// Add a [`SharedRetryClassifier`](::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier) that will be used by the
783    /// [`RetryStrategy`](::aws_smithy_runtime_api::client::retries::RetryStrategy) to determine what responses should be retried.
784    ///
785    /// A retry classifier configured by this method will run according to its priority.
786    ///
787    /// # Examples
788    /// ```no_run
789    /// # #[cfg(test)]
790    /// # mod tests {
791    /// # #[test]
792    /// # fn example() {
793    /// use aws_smithy_runtime_api::client::interceptors::context::InterceptorContext;
794    /// use aws_smithy_runtime_api::client::orchestrator::OrchestratorError;
795    /// use aws_smithy_runtime_api::client::retries::classifiers::{
796    ///     ClassifyRetry, RetryAction, RetryClassifierPriority,
797    /// };
798    /// use aws_smithy_types::error::metadata::ProvideErrorMetadata;
799    /// use aws_smithy_types::retry::ErrorKind;
800    /// use std::error::Error as StdError;
801    /// use std::marker::PhantomData;
802    /// use aws_sdk_codecatalyst::config::{Builder, Config};
803    /// # struct SomeOperationError {}
804    ///
805    /// const RETRYABLE_ERROR_CODES: &[&str] = [
806    ///     // List error codes to be retried here...
807    /// ];
808    /// fn set_example_error_code_classifier(builder: &mut Builder) {
809    ///     // When classifying at an operation's error type, classifiers require a generic parameter.
810    ///     // When classifying the HTTP response alone, no generic is needed.
811    ///     #[derive(Debug, Default)]
812    ///     pub struct ExampleErrorCodeClassifier<E> {
813    ///         _inner: PhantomData<E>,
814    ///     }
815    ///
816    ///     impl<E> ExampleErrorCodeClassifier<E> {
817    ///         pub fn new() -> Self {
818    ///             Self {
819    ///                 _inner: PhantomData,
820    ///             }
821    ///         }
822    ///     }
823    ///
824    ///     impl<E> ClassifyRetry for ExampleErrorCodeClassifier<E>
825    ///     where
826    ///         // Adding a trait bound for ProvideErrorMetadata allows us to inspect the error code.
827    ///         E: StdError + ProvideErrorMetadata + Send + Sync + 'static,
828    ///     {
829    ///         fn classify_retry(&self, ctx: &InterceptorContext) -> RetryAction {
830    ///             // Check for a result
831    ///             let output_or_error = ctx.output_or_error();
832    ///             // Check for an error
833    ///             let error = match output_or_error {
834    ///                 Some(Ok(_)) | None => return RetryAction::NoActionIndicated,
835    ///                   Some(Err(err)) => err,
836    ///             };
837    ///
838    ///             // Downcast the generic error and extract the code
839    ///             let error_code = OrchestratorError::as_operation_error(error)
840    ///                 .and_then(|err| err.downcast_ref::<E>())
841    ///                 .and_then(|err| err.code());
842    ///
843    ///             // If this error's code is in our list, return an action that tells the RetryStrategy to retry this request.
844    ///             if let Some(error_code) = error_code {
845    ///                 if RETRYABLE_ERROR_CODES.contains(&error_code) {
846    ///                     return RetryAction::transient_error();
847    ///                 }
848    ///             }
849    ///
850    ///             // Otherwise, return that no action is indicated i.e. that this classifier doesn't require a retry.
851    ///             // Another classifier may still classify this response as retryable.
852    ///             RetryAction::NoActionIndicated
853    ///         }
854    ///
855    ///         fn name(&self) -> &'static str { "Example Error Code Classifier" }
856    ///     }
857    ///
858    ///     builder.push_retry_classifier(ExampleErrorCodeClassifier::<SomeOperationError>::new())
859    /// }
860    ///
861    /// let mut builder = Config::builder();
862    /// set_example_error_code_classifier(&mut builder);
863    /// let config = builder.build();
864    /// # }
865    /// # }
866    /// ```
867    pub fn push_retry_classifier(
868        &mut self,
869        retry_classifier: ::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier,
870    ) -> &mut Self {
871        self.runtime_components.push_retry_classifier(retry_classifier);
872        self
873    }
874
875    /// Set [`SharedRetryClassifier`](::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier)s for the builder, replacing any that
876    /// were previously set.
877    pub fn set_retry_classifiers(
878        &mut self,
879        retry_classifiers: impl IntoIterator<Item = ::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier>,
880    ) -> &mut Self {
881        self.runtime_components.set_retry_classifiers(retry_classifiers.into_iter());
882        self
883    }
884    /// Sets the name of the app that is using the client.
885    ///
886    /// This _optional_ name is used to identify the application in the user agent that
887    /// gets sent along with requests.
888    pub fn app_name(mut self, app_name: ::aws_types::app_name::AppName) -> Self {
889        self.set_app_name(Some(app_name));
890        self
891    }
892    /// Sets the name of the app that is using the client.
893    ///
894    /// This _optional_ name is used to identify the application in the user agent that
895    /// gets sent along with requests.
896    pub fn set_app_name(&mut self, app_name: ::std::option::Option<::aws_types::app_name::AppName>) -> &mut Self {
897        self.config.store_or_unset(app_name);
898        self
899    }
900    /// Sets the access token provider for this service
901    ///
902    /// Note: the [`Self::bearer_token`] and [`Self::bearer_token_resolver`] methods are
903    /// equivalent to this method, but take the [`Token`] and [`ResolveIdentity`] types
904    /// respectively.
905    ///
906    /// [`Token`]: crate::config::Token
907    /// [`ResolveIdentity`]: crate::config::ResolveIdentity
908    pub fn token_provider(mut self, token_provider: impl crate::config::ProvideToken + 'static) -> Self {
909        self.set_token_provider(::std::option::Option::Some(::aws_smithy_runtime_api::shared::IntoShared::<
910            crate::config::SharedTokenProvider,
911        >::into_shared(token_provider)));
912        self
913    }
914
915    /// Sets the access token provider for this service
916    ///
917    /// Note: the [`Self::bearer_token`] and [`Self::bearer_token_resolver`] methods are
918    /// equivalent to this method, but take the [`Token`] and [`ResolveIdentity`] types
919    /// respectively.
920    ///
921    /// [`Token`]: crate::config::Token
922    /// [`ResolveIdentity`]: crate::config::ResolveIdentity
923    pub fn set_token_provider(&mut self, token_provider: ::std::option::Option<crate::config::SharedTokenProvider>) -> &mut Self {
924        if let Some(token_provider) = token_provider {
925            self.runtime_components
926                .set_identity_resolver(::aws_smithy_runtime_api::client::auth::http::HTTP_BEARER_AUTH_SCHEME_ID, token_provider);
927        }
928        self
929    }
930    /// Overrides the default invocation ID generator.
931    ///
932    /// The invocation ID generator generates ID values for the `amz-sdk-invocation-id` header. By default, this will be a random UUID. Overriding it may be useful in tests that examine the HTTP request and need to be deterministic.
933    pub fn invocation_id_generator(mut self, gen: impl ::aws_runtime::invocation_id::InvocationIdGenerator + 'static) -> Self {
934        self.set_invocation_id_generator(::std::option::Option::Some(
935            ::aws_runtime::invocation_id::SharedInvocationIdGenerator::new(gen),
936        ));
937        self
938    }
939    /// Overrides the default invocation ID generator.
940    ///
941    /// The invocation ID generator generates ID values for the `amz-sdk-invocation-id` header. By default, this will be a random UUID. Overriding it may be useful in tests that examine the HTTP request and need to be deterministic.
942    pub fn set_invocation_id_generator(
943        &mut self,
944        gen: ::std::option::Option<::aws_runtime::invocation_id::SharedInvocationIdGenerator>,
945    ) -> &mut Self {
946        self.config.store_or_unset(gen);
947        self
948    }
949    /// Sets the endpoint URL used to communicate with this service
950
951    /// Note: this is used in combination with other endpoint rules, e.g. an API that applies a host-label prefix
952    /// will be prefixed onto this URL. To fully override the endpoint resolver, use
953    /// [`Builder::endpoint_resolver`].
954    pub fn endpoint_url(mut self, endpoint_url: impl Into<::std::string::String>) -> Self {
955        self.set_endpoint_url(Some(endpoint_url.into()));
956        self
957    }
958    /// Sets the endpoint URL used to communicate with this service
959
960    /// Note: this is used in combination with other endpoint rules, e.g. an API that applies a host-label prefix
961    /// will be prefixed onto this URL. To fully override the endpoint resolver, use
962    /// [`Builder::endpoint_resolver`].
963    pub fn set_endpoint_url(&mut self, endpoint_url: Option<::std::string::String>) -> &mut Self {
964        self.config.store_or_unset(endpoint_url.map(::aws_types::endpoint_config::EndpointUrl));
965        self
966    }
967    /// When true, send this request to the FIPS-compliant regional endpoint. If the configured endpoint does not have a FIPS compliant endpoint, dispatching the request will return an error.
968    pub fn use_fips(mut self, use_fips: impl Into<bool>) -> Self {
969        self.set_use_fips(Some(use_fips.into()));
970        self
971    }
972    /// When true, send this request to the FIPS-compliant regional endpoint. If the configured endpoint does not have a FIPS compliant endpoint, dispatching the request will return an error.
973    pub fn set_use_fips(&mut self, use_fips: Option<bool>) -> &mut Self {
974        self.config.store_or_unset(use_fips.map(::aws_types::endpoint_config::UseFips));
975        self
976    }
977    /// Sets the AWS region to use when making requests.
978    ///
979    /// # Examples
980    /// ```no_run
981    /// use aws_types::region::Region;
982    /// use aws_sdk_codecatalyst::config::{Builder, Config};
983    ///
984    /// let config = aws_sdk_codecatalyst::Config::builder()
985    ///     .region(Region::new("us-east-1"))
986    ///     .build();
987    /// ```
988    pub fn region(mut self, region: impl ::std::convert::Into<::std::option::Option<crate::config::Region>>) -> Self {
989        self.set_region(region.into());
990        self
991    }
992    /// Sets the AWS region to use when making requests.
993    pub fn set_region(&mut self, region: ::std::option::Option<crate::config::Region>) -> &mut Self {
994        self.config.store_or_unset(region);
995        self
996    }
997    /// Sets the [`behavior major version`](crate::config::BehaviorVersion).
998    ///
999    /// Over time, new best-practice behaviors are introduced. However, these behaviors might not be backwards
1000    /// compatible. For example, a change which introduces new default timeouts or a new retry-mode for
1001    /// all operations might be the ideal behavior but could break existing applications.
1002    ///
1003    /// # Examples
1004    ///
1005    /// Set the behavior major version to `latest`. This is equivalent to enabling the `behavior-version-latest` cargo feature.
1006    /// ```no_run
1007    /// use aws_sdk_codecatalyst::config::BehaviorVersion;
1008    ///
1009    /// let config = aws_sdk_codecatalyst::Config::builder()
1010    ///     .behavior_version(BehaviorVersion::latest())
1011    ///     // ...
1012    ///     .build();
1013    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
1014    /// ```
1015    ///
1016    /// Customizing behavior major version:
1017    /// ```no_run
1018    /// use aws_sdk_codecatalyst::config::BehaviorVersion;
1019    ///
1020    /// let config = aws_sdk_codecatalyst::Config::builder()
1021    ///     .behavior_version(BehaviorVersion::v2023_11_09())
1022    ///     // ...
1023    ///     .build();
1024    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
1025    /// ```
1026
1027    pub fn behavior_version(mut self, behavior_version: crate::config::BehaviorVersion) -> Self {
1028        self.set_behavior_version(Some(behavior_version));
1029        self
1030    }
1031
1032    /// Sets the [`behavior major version`](crate::config::BehaviorVersion).
1033    ///
1034    /// Over time, new best-practice behaviors are introduced. However, these behaviors might not be backwards
1035    /// compatible. For example, a change which introduces new default timeouts or a new retry-mode for
1036    /// all operations might be the ideal behavior but could break existing applications.
1037    ///
1038    /// # Examples
1039    ///
1040    /// Set the behavior major version to `latest`. This is equivalent to enabling the `behavior-version-latest` cargo feature.
1041    /// ```no_run
1042    /// use aws_sdk_codecatalyst::config::BehaviorVersion;
1043    ///
1044    /// let config = aws_sdk_codecatalyst::Config::builder()
1045    ///     .behavior_version(BehaviorVersion::latest())
1046    ///     // ...
1047    ///     .build();
1048    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
1049    /// ```
1050    ///
1051    /// Customizing behavior major version:
1052    /// ```no_run
1053    /// use aws_sdk_codecatalyst::config::BehaviorVersion;
1054    ///
1055    /// let config = aws_sdk_codecatalyst::Config::builder()
1056    ///     .behavior_version(BehaviorVersion::v2023_11_09())
1057    ///     // ...
1058    ///     .build();
1059    /// let client = aws_sdk_codecatalyst::Client::from_conf(config);
1060    /// ```
1061
1062    pub fn set_behavior_version(&mut self, behavior_version: Option<crate::config::BehaviorVersion>) -> &mut Self {
1063        self.behavior_version = behavior_version;
1064        self
1065    }
1066
1067    /// Convenience method to set the latest behavior major version
1068    ///
1069    /// This is equivalent to enabling the `behavior-version-latest` Cargo feature
1070    pub fn behavior_version_latest(mut self) -> Self {
1071        self.set_behavior_version(Some(crate::config::BehaviorVersion::latest()));
1072        self
1073    }
1074    /// Adds a runtime plugin to the config.
1075    #[allow(unused)]
1076    pub(crate) fn runtime_plugin(mut self, plugin: impl crate::config::RuntimePlugin + 'static) -> Self {
1077        self.push_runtime_plugin(crate::config::SharedRuntimePlugin::new(plugin));
1078        self
1079    }
1080    /// Adds a runtime plugin to the config.
1081    #[allow(unused)]
1082    pub(crate) fn push_runtime_plugin(&mut self, plugin: crate::config::SharedRuntimePlugin) -> &mut Self {
1083        self.runtime_plugins.push(plugin);
1084        self
1085    }
1086    #[cfg(any(feature = "test-util", test))]
1087    #[allow(unused_mut)]
1088    /// Apply test defaults to the builder
1089    pub fn apply_test_defaults(&mut self) -> &mut Self {
1090        self.set_idempotency_token_provider(Some("00000000-0000-4000-8000-000000000000".into()));
1091        self.set_time_source(::std::option::Option::Some(::aws_smithy_async::time::SharedTimeSource::new(
1092            ::aws_smithy_async::time::StaticTimeSource::new(::std::time::UNIX_EPOCH + ::std::time::Duration::from_secs(1234567890)),
1093        )));
1094        self.config.store_put(::aws_runtime::user_agent::AwsUserAgent::for_tests());
1095        self.set_token_provider(Some(crate::config::SharedTokenProvider::new(::aws_credential_types::Token::for_tests())));
1096        self.behavior_version = ::std::option::Option::Some(crate::config::BehaviorVersion::latest());
1097        self
1098    }
1099    #[cfg(any(feature = "test-util", test))]
1100    #[allow(unused_mut)]
1101    /// Apply test defaults to the builder
1102    pub fn with_test_defaults(mut self) -> Self {
1103        self.apply_test_defaults();
1104        self
1105    }
1106    /// Builds a [`Config`].
1107    #[allow(unused_mut)]
1108    pub fn build(mut self) -> Config {
1109        let mut layer = self.config;
1110        if self.runtime_components.time_source().is_none() {
1111            self.runtime_components
1112                .set_time_source(::std::option::Option::Some(::std::default::Default::default()));
1113        }
1114        layer.store_put(crate::meta::API_METADATA.clone());
1115        Config {
1116            config: crate::config::Layer::from(layer.clone())
1117                .with_name("aws_sdk_codecatalyst::config::Config")
1118                .freeze(),
1119            cloneable: layer,
1120            runtime_components: self.runtime_components,
1121            runtime_plugins: self.runtime_plugins,
1122            behavior_version: self.behavior_version,
1123        }
1124    }
1125}
1126#[derive(::std::fmt::Debug)]
1127pub(crate) struct ServiceRuntimePlugin {
1128    config: ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer>,
1129    runtime_components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
1130}
1131
1132impl ServiceRuntimePlugin {
1133    pub fn new(_service_config: crate::config::Config) -> Self {
1134        let config = {
1135            let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CodeCatalyst");
1136            cfg.store_put(crate::idempotency_token::default_provider());
1137            ::std::option::Option::Some(cfg.freeze())
1138        };
1139        let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");
1140        runtime_components.push_auth_scheme(::aws_smithy_runtime_api::client::auth::SharedAuthScheme::new(
1141            ::aws_smithy_runtime::client::auth::http::BearerAuthScheme::new(),
1142        ));
1143        runtime_components.set_endpoint_resolver(Some({
1144            use crate::config::endpoint::ResolveEndpoint;
1145            crate::config::endpoint::DefaultResolver::new().into_shared_resolver()
1146        }));
1147        runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());
1148        runtime_components.push_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::HttpStatusCodeClassifier::default());
1149        runtime_components.push_interceptor(crate::sdk_feature_tracker::retry_mode::RetryModeFeatureTrackerInterceptor::new());
1150        runtime_components.push_interceptor(::aws_runtime::service_clock_skew::ServiceClockSkewInterceptor::new());
1151        runtime_components.push_interceptor(::aws_runtime::request_info::RequestInfoInterceptor::new());
1152        runtime_components.push_interceptor(::aws_runtime::user_agent::UserAgentInterceptor::new());
1153        runtime_components.push_interceptor(::aws_runtime::invocation_id::InvocationIdInterceptor::new());
1154        runtime_components.push_interceptor(::aws_runtime::recursion_detection::RecursionDetectionInterceptor::new());
1155        Self { config, runtime_components }
1156    }
1157}
1158
1159impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ServiceRuntimePlugin {
1160    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
1161        self.config.clone()
1162    }
1163
1164    fn order(&self) -> ::aws_smithy_runtime_api::client::runtime_plugin::Order {
1165        ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults
1166    }
1167
1168    fn runtime_components(
1169        &self,
1170        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
1171    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
1172        ::std::borrow::Cow::Borrowed(&self.runtime_components)
1173    }
1174}
1175
1176/// Cross-operation shared-state singletons
1177
1178/// A plugin that enables configuration for a single operation invocation
1179///
1180/// The `config` method will return a `FrozenLayer` by storing values from `config_override`.
1181/// In the case of default values requested, they will be obtained from `client_config`.
1182#[derive(Debug)]
1183pub(crate) struct ConfigOverrideRuntimePlugin {
1184    pub(crate) config: ::aws_smithy_types::config_bag::FrozenLayer,
1185    pub(crate) components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
1186}
1187
1188impl ConfigOverrideRuntimePlugin {
1189    #[allow(dead_code)] // unused when a service does not provide any operations
1190    pub(crate) fn new(
1191        config_override: Builder,
1192        initial_config: ::aws_smithy_types::config_bag::FrozenLayer,
1193        initial_components: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
1194    ) -> Self {
1195        let mut layer = config_override.config;
1196        let mut components = config_override.runtime_components;
1197        #[allow(unused_mut)]
1198        let mut resolver =
1199            ::aws_smithy_runtime::client::config_override::Resolver::overrid(initial_config, initial_components, &mut layer, &mut components);
1200
1201        let _ = resolver;
1202        Self {
1203            config: ::aws_smithy_types::config_bag::Layer::from(layer)
1204                .with_name("aws_sdk_codecatalyst::config::ConfigOverrideRuntimePlugin")
1205                .freeze(),
1206            components,
1207        }
1208    }
1209}
1210
1211impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
1212    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
1213        Some(self.config.clone())
1214    }
1215
1216    fn runtime_components(
1217        &self,
1218        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
1219    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
1220        ::std::borrow::Cow::Borrowed(&self.components)
1221    }
1222}
1223
1224pub use ::aws_smithy_runtime::client::identity::IdentityCache;
1225pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
1226pub use ::aws_smithy_types::config_bag::ConfigBag;
1227
1228impl From<&::aws_types::sdk_config::SdkConfig> for Builder {
1229    fn from(input: &::aws_types::sdk_config::SdkConfig) -> Self {
1230        let mut builder = Builder::default();
1231        builder = builder.region(input.region().cloned());
1232        builder.set_use_fips(input.use_fips());
1233        if input.get_origin("endpoint_url").is_client_config() {
1234            builder.set_endpoint_url(input.endpoint_url().map(|s| s.to_string()));
1235        } else {
1236            builder.set_endpoint_url(
1237                input
1238                    .service_config()
1239                    .and_then(|conf| {
1240                        conf.load_config(service_config_key("AWS_ENDPOINT_URL", "endpoint_url"))
1241                            .map(|it| it.parse().unwrap())
1242                    })
1243                    .or_else(|| input.endpoint_url().map(|s| s.to_string())),
1244            );
1245        }
1246        // resiliency
1247        builder.set_retry_config(input.retry_config().cloned());
1248        builder.set_timeout_config(input.timeout_config().cloned());
1249        builder.set_sleep_impl(input.sleep_impl());
1250
1251        builder.set_http_client(input.http_client());
1252        builder.set_time_source(input.time_source());
1253        builder.set_behavior_version(input.behavior_version());
1254        // setting `None` here removes the default
1255        if let Some(config) = input.stalled_stream_protection() {
1256            builder.set_stalled_stream_protection(Some(config));
1257        }
1258
1259        if let Some(cache) = input.identity_cache() {
1260            builder.set_identity_cache(cache);
1261        }
1262        builder.set_token_provider(input.token_provider());
1263        builder.set_app_name(input.app_name().cloned());
1264
1265        builder
1266    }
1267}
1268
1269impl From<&::aws_types::sdk_config::SdkConfig> for Config {
1270    fn from(sdk_config: &::aws_types::sdk_config::SdkConfig) -> Self {
1271        Builder::from(sdk_config).build()
1272    }
1273}
1274
1275pub use ::aws_types::app_name::AppName;
1276
1277#[allow(dead_code)]
1278fn service_config_key<'a>(env: &'a str, profile: &'a str) -> aws_types::service_config::ServiceConfigKey<'a> {
1279    ::aws_types::service_config::ServiceConfigKey::builder()
1280        .service_id("codecatalyst")
1281        .env(env)
1282        .profile(profile)
1283        .build()
1284        .expect("all field sets explicitly, can't fail")
1285}
1286
1287pub use ::aws_smithy_async::rt::sleep::Sleep;
1288
1289pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
1290    let mut configured_plugins = ::std::vec::Vec::new();
1291    ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
1292    #[cfg(feature = "behavior-version-latest")]
1293    {
1294        if config.behavior_version.is_none() {
1295            config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
1296        }
1297    }
1298
1299    let default_retry_partition = "codecatalyst";
1300    let default_retry_partition = match config.region() {
1301        Some(region) => ::std::borrow::Cow::from(format!("{default_retry_partition}-{}", region)),
1302        None => ::std::borrow::Cow::from(default_retry_partition),
1303    };
1304
1305    let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
1306                        // defaults
1307                        .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
1308                            ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
1309                                .with_retry_partition_name(default_retry_partition)
1310                                .with_behavior_version(config.behavior_version.expect("Invalid client configuration: A behavior major version must be set when sending a request or constructing a client. You must set it during client construction or by enabling the `behavior-version-latest` cargo feature."))
1311                        ))
1312                        // user config
1313                        .with_client_plugin(
1314                            ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
1315                                .with_config(config.config.clone())
1316                                .with_runtime_components(config.runtime_components.clone())
1317                        )
1318                        // codegen config
1319                        .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
1320                        .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new());
1321
1322    for plugin in configured_plugins {
1323        plugins = plugins.with_client_plugin(plugin);
1324    }
1325    plugins
1326}
1327
1328pub use ::aws_smithy_types::config_bag::FrozenLayer;
1329
1330pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
1331
1332pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
1333
1334pub use ::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion;
1335
1336pub use ::aws_smithy_runtime_api::client::stalled_stream_protection::StalledStreamProtectionConfig;
1337
1338pub use ::aws_smithy_runtime_api::client::http::SharedHttpClient;
1339
1340pub use ::aws_smithy_async::rt::sleep::SharedAsyncSleep;
1341
1342pub use ::aws_smithy_runtime_api::client::identity::SharedIdentityCache;
1343
1344pub use ::aws_smithy_runtime_api::client::interceptors::SharedInterceptor;
1345
1346pub use ::aws_types::region::Region;
1347
1348pub use ::aws_smithy_runtime_api::client::http::HttpClient;
1349
1350pub use ::aws_smithy_runtime_api::shared::IntoShared;
1351
1352pub use ::aws_smithy_runtime_api::client::identity::http::Token;
1353
1354pub use ::aws_smithy_runtime_api::client::identity::ResolveIdentity;
1355
1356pub use ::aws_smithy_async::rt::sleep::AsyncSleep;
1357
1358pub use ::aws_smithy_runtime_api::client::identity::ResolveCachedIdentity;
1359
1360pub use ::aws_smithy_runtime_api::client::interceptors::Intercept;
1361
1362pub use ::aws_credential_types::provider::token::ProvideToken;
1363
1364pub use ::aws_credential_types::provider::token::SharedTokenProvider;
1365
1366pub use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
1367
1368pub use ::aws_smithy_types::config_bag::Layer;
1369
1370/// Types needed to configure endpoint resolution.
1371pub mod endpoint;
1372
1373/// HTTP request and response types.
1374pub mod http;
1375
1376/// Types needed to implement [`Intercept`](crate::config::Intercept).
1377pub mod interceptors;
1378
1379/// Retry configuration.
1380pub mod retry;
1381
1382/// Timeout configuration.
1383pub mod timeout;