aws_sdk_datapipeline/config/
endpoint.rs1pub use ::aws_smithy_runtime_api::client::endpoint::EndpointFuture;
3pub use ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver;
4pub use ::aws_smithy_types::endpoint::Endpoint;
5
6#[cfg(test)]
7mod test {
8
9 #[test]
11 fn test_1() {
12 let params = crate::config::endpoint::Params::builder()
13 .region("ap-northeast-1".to_string())
14 .use_fips(false)
15 .use_dual_stack(false)
16 .build()
17 .expect("invalid params");
18 let resolver = crate::config::endpoint::DefaultResolver::new();
19 let endpoint = resolver.resolve_endpoint(¶ms);
20 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.ap-northeast-1.amazonaws.com");
21 assert_eq!(
22 endpoint,
23 ::aws_smithy_types::endpoint::Endpoint::builder()
24 .url("https://datapipeline.ap-northeast-1.amazonaws.com")
25 .build()
26 );
27 }
28
29 #[test]
31 fn test_2() {
32 let params = crate::config::endpoint::Params::builder()
33 .region("ap-southeast-2".to_string())
34 .use_fips(false)
35 .use_dual_stack(false)
36 .build()
37 .expect("invalid params");
38 let resolver = crate::config::endpoint::DefaultResolver::new();
39 let endpoint = resolver.resolve_endpoint(¶ms);
40 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.ap-southeast-2.amazonaws.com");
41 assert_eq!(
42 endpoint,
43 ::aws_smithy_types::endpoint::Endpoint::builder()
44 .url("https://datapipeline.ap-southeast-2.amazonaws.com")
45 .build()
46 );
47 }
48
49 #[test]
51 fn test_3() {
52 let params = crate::config::endpoint::Params::builder()
53 .region("eu-west-1".to_string())
54 .use_fips(false)
55 .use_dual_stack(false)
56 .build()
57 .expect("invalid params");
58 let resolver = crate::config::endpoint::DefaultResolver::new();
59 let endpoint = resolver.resolve_endpoint(¶ms);
60 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.eu-west-1.amazonaws.com");
61 assert_eq!(
62 endpoint,
63 ::aws_smithy_types::endpoint::Endpoint::builder()
64 .url("https://datapipeline.eu-west-1.amazonaws.com")
65 .build()
66 );
67 }
68
69 #[test]
71 fn test_4() {
72 let params = crate::config::endpoint::Params::builder()
73 .region("us-east-1".to_string())
74 .use_fips(false)
75 .use_dual_stack(false)
76 .build()
77 .expect("invalid params");
78 let resolver = crate::config::endpoint::DefaultResolver::new();
79 let endpoint = resolver.resolve_endpoint(¶ms);
80 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.us-east-1.amazonaws.com");
81 assert_eq!(
82 endpoint,
83 ::aws_smithy_types::endpoint::Endpoint::builder()
84 .url("https://datapipeline.us-east-1.amazonaws.com")
85 .build()
86 );
87 }
88
89 #[test]
91 fn test_5() {
92 let params = crate::config::endpoint::Params::builder()
93 .region("us-west-2".to_string())
94 .use_fips(false)
95 .use_dual_stack(false)
96 .build()
97 .expect("invalid params");
98 let resolver = crate::config::endpoint::DefaultResolver::new();
99 let endpoint = resolver.resolve_endpoint(¶ms);
100 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.us-west-2.amazonaws.com");
101 assert_eq!(
102 endpoint,
103 ::aws_smithy_types::endpoint::Endpoint::builder()
104 .url("https://datapipeline.us-west-2.amazonaws.com")
105 .build()
106 );
107 }
108
109 #[test]
111 fn test_6() {
112 let params = crate::config::endpoint::Params::builder()
113 .region("us-east-1".to_string())
114 .use_fips(true)
115 .use_dual_stack(true)
116 .build()
117 .expect("invalid params");
118 let resolver = crate::config::endpoint::DefaultResolver::new();
119 let endpoint = resolver.resolve_endpoint(¶ms);
120 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.us-east-1.api.aws");
121 assert_eq!(
122 endpoint,
123 ::aws_smithy_types::endpoint::Endpoint::builder()
124 .url("https://datapipeline-fips.us-east-1.api.aws")
125 .build()
126 );
127 }
128
129 #[test]
131 fn test_7() {
132 let params = crate::config::endpoint::Params::builder()
133 .region("us-east-1".to_string())
134 .use_fips(true)
135 .use_dual_stack(false)
136 .build()
137 .expect("invalid params");
138 let resolver = crate::config::endpoint::DefaultResolver::new();
139 let endpoint = resolver.resolve_endpoint(¶ms);
140 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.us-east-1.amazonaws.com");
141 assert_eq!(
142 endpoint,
143 ::aws_smithy_types::endpoint::Endpoint::builder()
144 .url("https://datapipeline-fips.us-east-1.amazonaws.com")
145 .build()
146 );
147 }
148
149 #[test]
151 fn test_8() {
152 let params = crate::config::endpoint::Params::builder()
153 .region("us-east-1".to_string())
154 .use_fips(false)
155 .use_dual_stack(true)
156 .build()
157 .expect("invalid params");
158 let resolver = crate::config::endpoint::DefaultResolver::new();
159 let endpoint = resolver.resolve_endpoint(¶ms);
160 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.us-east-1.api.aws");
161 assert_eq!(
162 endpoint,
163 ::aws_smithy_types::endpoint::Endpoint::builder()
164 .url("https://datapipeline.us-east-1.api.aws")
165 .build()
166 );
167 }
168
169 #[test]
171 fn test_9() {
172 let params = crate::config::endpoint::Params::builder()
173 .region("cn-north-1".to_string())
174 .use_fips(true)
175 .use_dual_stack(true)
176 .build()
177 .expect("invalid params");
178 let resolver = crate::config::endpoint::DefaultResolver::new();
179 let endpoint = resolver.resolve_endpoint(¶ms);
180 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.cn-north-1.api.amazonwebservices.com.cn");
181 assert_eq!(
182 endpoint,
183 ::aws_smithy_types::endpoint::Endpoint::builder()
184 .url("https://datapipeline-fips.cn-north-1.api.amazonwebservices.com.cn")
185 .build()
186 );
187 }
188
189 #[test]
191 fn test_10() {
192 let params = crate::config::endpoint::Params::builder()
193 .region("cn-north-1".to_string())
194 .use_fips(true)
195 .use_dual_stack(false)
196 .build()
197 .expect("invalid params");
198 let resolver = crate::config::endpoint::DefaultResolver::new();
199 let endpoint = resolver.resolve_endpoint(¶ms);
200 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.cn-north-1.amazonaws.com.cn");
201 assert_eq!(
202 endpoint,
203 ::aws_smithy_types::endpoint::Endpoint::builder()
204 .url("https://datapipeline-fips.cn-north-1.amazonaws.com.cn")
205 .build()
206 );
207 }
208
209 #[test]
211 fn test_11() {
212 let params = crate::config::endpoint::Params::builder()
213 .region("cn-north-1".to_string())
214 .use_fips(false)
215 .use_dual_stack(true)
216 .build()
217 .expect("invalid params");
218 let resolver = crate::config::endpoint::DefaultResolver::new();
219 let endpoint = resolver.resolve_endpoint(¶ms);
220 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.cn-north-1.api.amazonwebservices.com.cn");
221 assert_eq!(
222 endpoint,
223 ::aws_smithy_types::endpoint::Endpoint::builder()
224 .url("https://datapipeline.cn-north-1.api.amazonwebservices.com.cn")
225 .build()
226 );
227 }
228
229 #[test]
231 fn test_12() {
232 let params = crate::config::endpoint::Params::builder()
233 .region("cn-north-1".to_string())
234 .use_fips(false)
235 .use_dual_stack(false)
236 .build()
237 .expect("invalid params");
238 let resolver = crate::config::endpoint::DefaultResolver::new();
239 let endpoint = resolver.resolve_endpoint(¶ms);
240 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.cn-north-1.amazonaws.com.cn");
241 assert_eq!(
242 endpoint,
243 ::aws_smithy_types::endpoint::Endpoint::builder()
244 .url("https://datapipeline.cn-north-1.amazonaws.com.cn")
245 .build()
246 );
247 }
248
249 #[test]
251 fn test_13() {
252 let params = crate::config::endpoint::Params::builder()
253 .region("us-gov-east-1".to_string())
254 .use_fips(true)
255 .use_dual_stack(true)
256 .build()
257 .expect("invalid params");
258 let resolver = crate::config::endpoint::DefaultResolver::new();
259 let endpoint = resolver.resolve_endpoint(¶ms);
260 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.us-gov-east-1.api.aws");
261 assert_eq!(
262 endpoint,
263 ::aws_smithy_types::endpoint::Endpoint::builder()
264 .url("https://datapipeline-fips.us-gov-east-1.api.aws")
265 .build()
266 );
267 }
268
269 #[test]
271 fn test_14() {
272 let params = crate::config::endpoint::Params::builder()
273 .region("us-gov-east-1".to_string())
274 .use_fips(true)
275 .use_dual_stack(false)
276 .build()
277 .expect("invalid params");
278 let resolver = crate::config::endpoint::DefaultResolver::new();
279 let endpoint = resolver.resolve_endpoint(¶ms);
280 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.us-gov-east-1.amazonaws.com");
281 assert_eq!(
282 endpoint,
283 ::aws_smithy_types::endpoint::Endpoint::builder()
284 .url("https://datapipeline-fips.us-gov-east-1.amazonaws.com")
285 .build()
286 );
287 }
288
289 #[test]
291 fn test_15() {
292 let params = crate::config::endpoint::Params::builder()
293 .region("us-gov-east-1".to_string())
294 .use_fips(false)
295 .use_dual_stack(true)
296 .build()
297 .expect("invalid params");
298 let resolver = crate::config::endpoint::DefaultResolver::new();
299 let endpoint = resolver.resolve_endpoint(¶ms);
300 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.us-gov-east-1.api.aws");
301 assert_eq!(
302 endpoint,
303 ::aws_smithy_types::endpoint::Endpoint::builder()
304 .url("https://datapipeline.us-gov-east-1.api.aws")
305 .build()
306 );
307 }
308
309 #[test]
311 fn test_16() {
312 let params = crate::config::endpoint::Params::builder()
313 .region("us-gov-east-1".to_string())
314 .use_fips(false)
315 .use_dual_stack(false)
316 .build()
317 .expect("invalid params");
318 let resolver = crate::config::endpoint::DefaultResolver::new();
319 let endpoint = resolver.resolve_endpoint(¶ms);
320 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.us-gov-east-1.amazonaws.com");
321 assert_eq!(
322 endpoint,
323 ::aws_smithy_types::endpoint::Endpoint::builder()
324 .url("https://datapipeline.us-gov-east-1.amazonaws.com")
325 .build()
326 );
327 }
328
329 #[test]
331 fn test_17() {
332 let params = crate::config::endpoint::Params::builder()
333 .region("us-iso-east-1".to_string())
334 .use_fips(false)
335 .use_dual_stack(false)
336 .build()
337 .expect("invalid params");
338 let resolver = crate::config::endpoint::DefaultResolver::new();
339 let endpoint = resolver.resolve_endpoint(¶ms);
340 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.us-iso-east-1.c2s.ic.gov");
341 assert_eq!(
342 endpoint,
343 ::aws_smithy_types::endpoint::Endpoint::builder()
344 .url("https://datapipeline.us-iso-east-1.c2s.ic.gov")
345 .build()
346 );
347 }
348
349 #[test]
351 fn test_18() {
352 let params = crate::config::endpoint::Params::builder()
353 .region("us-iso-east-1".to_string())
354 .use_fips(true)
355 .use_dual_stack(false)
356 .build()
357 .expect("invalid params");
358 let resolver = crate::config::endpoint::DefaultResolver::new();
359 let endpoint = resolver.resolve_endpoint(¶ms);
360 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.us-iso-east-1.c2s.ic.gov");
361 assert_eq!(
362 endpoint,
363 ::aws_smithy_types::endpoint::Endpoint::builder()
364 .url("https://datapipeline-fips.us-iso-east-1.c2s.ic.gov")
365 .build()
366 );
367 }
368
369 #[test]
371 fn test_19() {
372 let params = crate::config::endpoint::Params::builder()
373 .region("us-isob-east-1".to_string())
374 .use_fips(true)
375 .use_dual_stack(false)
376 .build()
377 .expect("invalid params");
378 let resolver = crate::config::endpoint::DefaultResolver::new();
379 let endpoint = resolver.resolve_endpoint(¶ms);
380 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline-fips.us-isob-east-1.sc2s.sgov.gov");
381 assert_eq!(
382 endpoint,
383 ::aws_smithy_types::endpoint::Endpoint::builder()
384 .url("https://datapipeline-fips.us-isob-east-1.sc2s.sgov.gov")
385 .build()
386 );
387 }
388
389 #[test]
391 fn test_20() {
392 let params = crate::config::endpoint::Params::builder()
393 .region("us-isob-east-1".to_string())
394 .use_fips(false)
395 .use_dual_stack(false)
396 .build()
397 .expect("invalid params");
398 let resolver = crate::config::endpoint::DefaultResolver::new();
399 let endpoint = resolver.resolve_endpoint(¶ms);
400 let endpoint = endpoint.expect("Expected valid endpoint: https://datapipeline.us-isob-east-1.sc2s.sgov.gov");
401 assert_eq!(
402 endpoint,
403 ::aws_smithy_types::endpoint::Endpoint::builder()
404 .url("https://datapipeline.us-isob-east-1.sc2s.sgov.gov")
405 .build()
406 );
407 }
408
409 #[test]
411 fn test_21() {
412 let params = crate::config::endpoint::Params::builder()
413 .region("us-east-1".to_string())
414 .use_fips(false)
415 .use_dual_stack(false)
416 .endpoint("https://example.com".to_string())
417 .build()
418 .expect("invalid params");
419 let resolver = crate::config::endpoint::DefaultResolver::new();
420 let endpoint = resolver.resolve_endpoint(¶ms);
421 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
422 assert_eq!(
423 endpoint,
424 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
425 );
426 }
427
428 #[test]
430 fn test_22() {
431 let params = crate::config::endpoint::Params::builder()
432 .use_fips(false)
433 .use_dual_stack(false)
434 .endpoint("https://example.com".to_string())
435 .build()
436 .expect("invalid params");
437 let resolver = crate::config::endpoint::DefaultResolver::new();
438 let endpoint = resolver.resolve_endpoint(¶ms);
439 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
440 assert_eq!(
441 endpoint,
442 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
443 );
444 }
445
446 #[test]
448 fn test_23() {
449 let params = crate::config::endpoint::Params::builder()
450 .region("us-east-1".to_string())
451 .use_fips(true)
452 .use_dual_stack(false)
453 .endpoint("https://example.com".to_string())
454 .build()
455 .expect("invalid params");
456 let resolver = crate::config::endpoint::DefaultResolver::new();
457 let endpoint = resolver.resolve_endpoint(¶ms);
458 let error = endpoint.expect_err("expected error: Invalid Configuration: FIPS and custom endpoint are not supported [For custom endpoint with fips enabled and dualstack disabled]");
459 assert_eq!(format!("{}", error), "Invalid Configuration: FIPS and custom endpoint are not supported")
460 }
461
462 #[test]
464 fn test_24() {
465 let params = crate::config::endpoint::Params::builder()
466 .region("us-east-1".to_string())
467 .use_fips(false)
468 .use_dual_stack(true)
469 .endpoint("https://example.com".to_string())
470 .build()
471 .expect("invalid params");
472 let resolver = crate::config::endpoint::DefaultResolver::new();
473 let endpoint = resolver.resolve_endpoint(¶ms);
474 let error = endpoint.expect_err("expected error: Invalid Configuration: Dualstack and custom endpoint are not supported [For custom endpoint with fips disabled and dualstack enabled]");
475 assert_eq!(
476 format!("{}", error),
477 "Invalid Configuration: Dualstack and custom endpoint are not supported"
478 )
479 }
480
481 #[test]
483 fn test_25() {
484 let params = crate::config::endpoint::Params::builder().build().expect("invalid params");
485 let resolver = crate::config::endpoint::DefaultResolver::new();
486 let endpoint = resolver.resolve_endpoint(¶ms);
487 let error = endpoint.expect_err("expected error: Invalid Configuration: Missing Region [Missing region]");
488 assert_eq!(format!("{}", error), "Invalid Configuration: Missing Region")
489 }
490}
491
492pub trait ResolveEndpoint: ::std::marker::Send + ::std::marker::Sync + ::std::fmt::Debug {
494 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a>;
496
497 fn into_shared_resolver(self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver
501 where
502 Self: Sized + 'static,
503 {
504 ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver::new(DowncastParams(self))
505 }
506}
507
508#[derive(Debug)]
509struct DowncastParams<T>(T);
510impl<T> ::aws_smithy_runtime_api::client::endpoint::ResolveEndpoint for DowncastParams<T>
511where
512 T: ResolveEndpoint,
513{
514 fn resolve_endpoint<'a>(
515 &'a self,
516 params: &'a ::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams,
517 ) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
518 let ep = match params.get::<crate::config::endpoint::Params>() {
519 Some(params) => self.0.resolve_endpoint(params),
520 None => ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(Err("params of expected type was not present".into())),
521 };
522 ep
523 }
524}
525
526#[derive(Debug, Default)]
528pub struct DefaultResolver {
529 partition_resolver: crate::endpoint_lib::partition::PartitionResolver,
530}
531
532impl DefaultResolver {
533 pub fn new() -> Self {
535 Self {
536 partition_resolver: crate::endpoint_lib::DEFAULT_PARTITION_RESOLVER.clone(),
537 }
538 }
539
540 fn resolve_endpoint(
541 &self,
542 params: &crate::config::endpoint::Params,
543 ) -> ::std::result::Result<::aws_smithy_types::endpoint::Endpoint, ::aws_smithy_runtime_api::box_error::BoxError> {
544 let mut diagnostic_collector = crate::endpoint_lib::diagnostic::DiagnosticCollector::new();
545 Ok(
546 crate::config::endpoint::internals::resolve_endpoint(params, &mut diagnostic_collector, &self.partition_resolver)
547 .map_err(|err| err.with_source(diagnostic_collector.take_last_error()))?,
548 )
549 }
550}
551
552impl crate::config::endpoint::ResolveEndpoint for DefaultResolver {
553 fn resolve_endpoint(&self, params: &crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'_> {
554 ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(self.resolve_endpoint(params))
555 }
556}
557
558#[non_exhaustive]
559#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
560pub struct Params {
562 pub(crate) region: ::std::option::Option<::std::string::String>,
564 pub(crate) use_dual_stack: bool,
566 pub(crate) use_fips: bool,
568 pub(crate) endpoint: ::std::option::Option<::std::string::String>,
570}
571impl Params {
572 pub fn builder() -> crate::config::endpoint::ParamsBuilder {
574 crate::config::endpoint::ParamsBuilder::default()
575 }
576 pub fn region(&self) -> ::std::option::Option<&str> {
578 self.region.as_deref()
579 }
580 pub fn use_dual_stack(&self) -> ::std::option::Option<bool> {
582 Some(self.use_dual_stack)
583 }
584 pub fn use_fips(&self) -> ::std::option::Option<bool> {
586 Some(self.use_fips)
587 }
588 pub fn endpoint(&self) -> ::std::option::Option<&str> {
590 self.endpoint.as_deref()
591 }
592}
593
594#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
596pub struct ParamsBuilder {
597 region: ::std::option::Option<::std::string::String>,
598 use_dual_stack: ::std::option::Option<bool>,
599 use_fips: ::std::option::Option<bool>,
600 endpoint: ::std::option::Option<::std::string::String>,
601}
602impl ParamsBuilder {
603 pub fn build(self) -> ::std::result::Result<crate::config::endpoint::Params, crate::config::endpoint::InvalidParams> {
605 Ok(
606 #[allow(clippy::unnecessary_lazy_evaluations)]
607 crate::config::endpoint::Params {
608 region: self.region,
609 use_dual_stack: self
610 .use_dual_stack
611 .or_else(|| Some(false))
612 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_dual_stack"))?,
613 use_fips: self
614 .use_fips
615 .or_else(|| Some(false))
616 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_fips"))?,
617 endpoint: self.endpoint,
618 },
619 )
620 }
621 pub fn region(mut self, value: impl Into<::std::string::String>) -> Self {
625 self.region = Some(value.into());
626 self
627 }
628
629 pub fn set_region(mut self, param: Option<::std::string::String>) -> Self {
633 self.region = param;
634 self
635 }
636 pub fn use_dual_stack(mut self, value: impl Into<bool>) -> Self {
641 self.use_dual_stack = Some(value.into());
642 self
643 }
644
645 pub fn set_use_dual_stack(mut self, param: Option<bool>) -> Self {
650 self.use_dual_stack = param;
651 self
652 }
653 pub fn use_fips(mut self, value: impl Into<bool>) -> Self {
658 self.use_fips = Some(value.into());
659 self
660 }
661
662 pub fn set_use_fips(mut self, param: Option<bool>) -> Self {
667 self.use_fips = param;
668 self
669 }
670 pub fn endpoint(mut self, value: impl Into<::std::string::String>) -> Self {
674 self.endpoint = Some(value.into());
675 self
676 }
677
678 pub fn set_endpoint(mut self, param: Option<::std::string::String>) -> Self {
682 self.endpoint = param;
683 self
684 }
685}
686
687#[derive(Debug)]
689pub struct InvalidParams {
690 field: std::borrow::Cow<'static, str>,
691}
692
693impl InvalidParams {
694 #[allow(dead_code)]
695 fn missing(field: &'static str) -> Self {
696 Self { field: field.into() }
697 }
698}
699
700impl std::fmt::Display for InvalidParams {
701 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
702 write!(f, "a required field was missing: `{}`", self.field)
703 }
704}
705
706impl std::error::Error for InvalidParams {}
707
708mod internals;