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;