Client Test

Client Test

rev. dfb5149b65b7bcc09edd15b8e071ad43b5ac5943 (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-client-test/naming_test_structs/rust-client-codegen/src/types/_some_union.rs

@@ -1,1 +51,91 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* UnionGenerator.kt:67 */
    2      3   
#[allow(missing_docs)] // documentation missing in model
           4  +
/* RustType.kt:516 */
    3      5   
#[non_exhaustive]
           6  +
/* RustType.kt:516 */
    4      7   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
    5         -
pub enum SomeUnion {
           8  +
pub /* UnionGenerator.kt:85 */ enum SomeUnion {
           9  +
    /* UnionGenerator.kt:90 */
    6     10   
    #[allow(missing_docs)] // documentation missing in model
          11  +
    /* UnionGenerator.kt:190 */
    7     12   
    Option(crate::types::Option),
          13  +
    /* UnionGenerator.kt:90 */
    8     14   
    #[allow(missing_docs)] // documentation missing in model
          15  +
    /* UnionGenerator.kt:190 */
    9     16   
    Result(crate::types::Result),
   10         -
    /// The `Unknown` variant represents cases where new union variant was received. Consider upgrading the SDK to the latest available version.
          17  +
    /// /* UnionGenerator.kt:96 */The `Unknown` variant represents cases where new union variant was received. Consider upgrading the SDK to the latest available version.
          18  +
    /* UnionGenerator.kt:97 */
   11     19   
    /// An unknown enum variant
          20  +
    /* UnionGenerator.kt:98 */
   12     21   
    ///
          22  +
    /* UnionGenerator.kt:99 */
   13     23   
    /// _Note: If you encounter this error, consider upgrading your SDK to the latest version._
          24  +
    /* UnionGenerator.kt:100 */
   14     25   
    /// The `Unknown` variant represents cases where the server sent a value that wasn't recognized
          26  +
    /* UnionGenerator.kt:101 */
   15     27   
    /// by the client. This can happen when the server adds new functionality, but the client has not been updated.
          28  +
    /* UnionGenerator.kt:102 */
   16     29   
    /// To investigate this, consider turning on debug logging to print the raw HTTP response.
          30  +
    /* RustType.kt:516 */
   17     31   
    #[non_exhaustive]
          32  +
    /* UnionGenerator.kt:105 */
   18     33   
    Unknown,
          34  +
    /* UnionGenerator.kt:85 */
   19     35   
}
          36  +
/* UnionGenerator.kt:111 */
   20     37   
impl SomeUnion {
          38  +
    /* UnionGenerator.kt:217 */
   21     39   
    /// Tries to convert the enum instance into [`Option`](crate::types::SomeUnion::Option), extracting the inner [`Option`](crate::types::Option).
          40  +
    /* UnionGenerator.kt:222 */
   22     41   
    /// Returns `Err(&Self)` if it can't be converted.
          42  +
    /* UnionGenerator.kt:223 */
   23     43   
    pub fn as_option(&self) -> ::std::result::Result<&crate::types::Option, &Self> {
          44  +
        /* UnionGenerator.kt:227 */
   24     45   
        if let SomeUnion::Option(val) = &self {
   25     46   
            ::std::result::Result::Ok(val)
   26     47   
        } else {
   27     48   
            ::std::result::Result::Err(self)
   28     49   
        }
          50  +
        /* UnionGenerator.kt:223 */
   29     51   
    }
          52  +
    /* UnionGenerator.kt:121 */
   30     53   
    /// Returns true if this is a [`Option`](crate::types::SomeUnion::Option).
          54  +
    /* UnionGenerator.kt:122 */
   31     55   
    pub fn is_option(&self) -> bool {
          56  +
        /* UnionGenerator.kt:123 */
   32     57   
        self.as_option().is_ok()
          58  +
        /* UnionGenerator.kt:122 */
   33     59   
    }
          60  +
    /* UnionGenerator.kt:217 */
   34     61   
    /// Tries to convert the enum instance into [`Result`](crate::types::SomeUnion::Result), extracting the inner [`Result`](crate::types::Result).
          62  +
    /* UnionGenerator.kt:222 */
   35     63   
    /// Returns `Err(&Self)` if it can't be converted.
          64  +
    /* UnionGenerator.kt:223 */
   36     65   
    pub fn as_result(&self) -> ::std::result::Result<&crate::types::Result, &Self> {
          66  +
        /* UnionGenerator.kt:227 */
   37     67   
        if let SomeUnion::Result(val) = &self {
   38     68   
            ::std::result::Result::Ok(val)
   39     69   
        } else {
   40     70   
            ::std::result::Result::Err(self)
   41     71   
        }
          72  +
        /* UnionGenerator.kt:223 */
   42     73   
    }
          74  +
    /* UnionGenerator.kt:121 */
   43     75   
    /// Returns true if this is a [`Result`](crate::types::SomeUnion::Result).
          76  +
    /* UnionGenerator.kt:122 */
   44     77   
    pub fn is_result(&self) -> bool {
          78  +
        /* UnionGenerator.kt:123 */
   45     79   
        self.as_result().is_ok()
          80  +
        /* UnionGenerator.kt:122 */
   46     81   
    }
          82  +
    /* UnionGenerator.kt:127 */
   47     83   
    /// Returns true if the enum instance is the `Unknown` variant.
          84  +
    /* UnionGenerator.kt:128 */
   48     85   
    pub fn is_unknown(&self) -> bool {
          86  +
        /* UnionGenerator.kt:129 */
   49     87   
        matches!(self, Self::Unknown)
          88  +
        /* UnionGenerator.kt:128 */
   50     89   
    }
          90  +
    /* UnionGenerator.kt:111 */
   51     91   
}

tmp-codegen-diff/codegen-client-test/naming_test_structs/rust-client-codegen/src/types/_something_else.rs

@@ -1,1 +151,272 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* StructureGenerator.kt:197 */
    2      3   
#[allow(missing_docs)] // documentation missing in model
           4  +
/* RustType.kt:516 */
    3      5   
#[non_exhaustive]
           6  +
/* RustType.kt:516 */
    4      7   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
    5         -
pub struct SomethingElse {
           8  +
pub /* StructureGenerator.kt:201 */ struct SomethingElse {
           9  +
    /* StructureGenerator.kt:231 */
    6     10   
    #[allow(missing_docs)] // documentation missing in model
    7     11   
    pub result: ::std::option::Option<crate::types::Result>,
          12  +
    /* StructureGenerator.kt:231 */
    8     13   
    #[allow(missing_docs)] // documentation missing in model
    9     14   
    pub result_list: ::std::option::Option<::std::vec::Vec<crate::types::Result>>,
          15  +
    /* StructureGenerator.kt:231 */
   10     16   
    #[allow(missing_docs)] // documentation missing in model
   11     17   
    pub option: ::std::option::Option<crate::types::Option>,
          18  +
    /* StructureGenerator.kt:231 */
   12     19   
    #[allow(missing_docs)] // documentation missing in model
   13     20   
    pub option_list: ::std::option::Option<::std::vec::Vec<crate::types::Result>>,
          21  +
    /* StructureGenerator.kt:231 */
   14     22   
    #[allow(missing_docs)] // documentation missing in model
   15     23   
    pub some_union: ::std::option::Option<crate::types::SomeUnion>,
          24  +
    /* StructureGenerator.kt:201 */
   16     25   
}
          26  +
/* StructureGenerator.kt:135 */
   17     27   
impl SomethingElse {
          28  +
    /* StructureGenerator.kt:231 */
   18     29   
    #[allow(missing_docs)] // documentation missing in model
          30  +
                           /* StructureGenerator.kt:166 */
   19     31   
    pub fn result(&self) -> ::std::option::Option<&crate::types::Result> {
          32  +
        /* StructureGenerator.kt:170 */
   20     33   
        self.result.as_ref()
          34  +
        /* StructureGenerator.kt:166 */
   21     35   
    }
          36  +
    /* StructureGenerator.kt:231 */
   22     37   
    #[allow(missing_docs)] // documentation missing in model
   23         -
    ///
   24         -
    /// If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.result_list.is_none()`.
          38  +
    /// /* StructureGenerator.kt:162 */
          39  +
    /// /* StructureGenerator.kt:163 */If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.result_list.is_none()`.
          40  +
    /* StructureGenerator.kt:166 */
   25     41   
    pub fn result_list(&self) -> &[crate::types::Result] {
   26         -
        self.result_list.as_deref().unwrap_or_default()
          42  +
        /* StructureGenerator.kt:169 */
          43  +
        self.result_list
          44  +
            .as_deref()
          45  +
            /* StructureGenerator.kt:175 */
          46  +
            .unwrap_or_default()
          47  +
        /* StructureGenerator.kt:166 */
   27     48   
    }
          49  +
    /* StructureGenerator.kt:231 */
   28     50   
    #[allow(missing_docs)] // documentation missing in model
          51  +
                           /* StructureGenerator.kt:166 */
   29     52   
    pub fn option(&self) -> ::std::option::Option<&crate::types::Option> {
          53  +
        /* StructureGenerator.kt:170 */
   30     54   
        self.option.as_ref()
          55  +
        /* StructureGenerator.kt:166 */
   31     56   
    }
          57  +
    /* StructureGenerator.kt:231 */
   32     58   
    #[allow(missing_docs)] // documentation missing in model
   33         -
    ///
   34         -
    /// If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.option_list.is_none()`.
          59  +
    /// /* StructureGenerator.kt:162 */
          60  +
    /// /* StructureGenerator.kt:163 */If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use `.option_list.is_none()`.
          61  +
    /* StructureGenerator.kt:166 */
   35     62   
    pub fn option_list(&self) -> &[crate::types::Result] {
   36         -
        self.option_list.as_deref().unwrap_or_default()
          63  +
        /* StructureGenerator.kt:169 */
          64  +
        self.option_list
          65  +
            .as_deref()
          66  +
            /* StructureGenerator.kt:175 */
          67  +
            .unwrap_or_default()
          68  +
        /* StructureGenerator.kt:166 */
   37     69   
    }
          70  +
    /* StructureGenerator.kt:231 */
   38     71   
    #[allow(missing_docs)] // documentation missing in model
          72  +
                           /* StructureGenerator.kt:166 */
   39     73   
    pub fn some_union(&self) -> ::std::option::Option<&crate::types::SomeUnion> {
          74  +
        /* StructureGenerator.kt:170 */
   40     75   
        self.some_union.as_ref()
          76  +
        /* StructureGenerator.kt:166 */
   41     77   
    }
          78  +
    /* StructureGenerator.kt:135 */
   42     79   
}
          80  +
/* ClientCodegenVisitor.kt:237 */
   43     81   
impl SomethingElse {
   44         -
    /// Creates a new builder-style object to manufacture [`SomethingElse`](crate::types::SomethingElse).
          82  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`SomethingElse`](crate::types::SomethingElse).
          83  +
    /* BuilderGenerator.kt:175 */
   45     84   
    pub fn builder() -> crate::types::builders::SomethingElseBuilder {
          85  +
        /* BuilderGenerator.kt:176 */
   46     86   
        crate::types::builders::SomethingElseBuilder::default()
          87  +
        /* BuilderGenerator.kt:175 */
   47     88   
    }
          89  +
    /* ClientCodegenVisitor.kt:237 */
   48     90   
}
   49     91   
   50         -
/// A builder for [`SomethingElse`](crate::types::SomethingElse).
          92  +
/// /* BuilderGenerator.kt:342 */A builder for [`SomethingElse`](crate::types::SomethingElse).
          93  +
/* RustType.kt:516 */
   51     94   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          95  +
/* RustType.kt:516 */
   52     96   
#[non_exhaustive]
          97  +
/* BuilderGenerator.kt:345 */
   53     98   
pub struct SomethingElseBuilder {
   54         -
    pub(crate) result: ::std::option::Option<crate::types::Result>,
   55         -
    pub(crate) result_list: ::std::option::Option<::std::vec::Vec<crate::types::Result>>,
   56         -
    pub(crate) option: ::std::option::Option<crate::types::Option>,
   57         -
    pub(crate) option_list: ::std::option::Option<::std::vec::Vec<crate::types::Result>>,
   58         -
    pub(crate) some_union: ::std::option::Option<crate::types::SomeUnion>,
          99  +
    /* BuilderGenerator.kt:275 */ pub(crate) result: ::std::option::Option<crate::types::Result>,
         100  +
    /* BuilderGenerator.kt:275 */ pub(crate) result_list: ::std::option::Option<::std::vec::Vec<crate::types::Result>>,
         101  +
    /* BuilderGenerator.kt:275 */ pub(crate) option: ::std::option::Option<crate::types::Option>,
         102  +
    /* BuilderGenerator.kt:275 */ pub(crate) option_list: ::std::option::Option<::std::vec::Vec<crate::types::Result>>,
         103  +
    /* BuilderGenerator.kt:275 */ pub(crate) some_union: ::std::option::Option<crate::types::SomeUnion>,
         104  +
    /* BuilderGenerator.kt:345 */
   59    105   
}
         106  +
/* BuilderGenerator.kt:355 */
   60    107   
impl SomethingElseBuilder {
         108  +
    /* BuilderGenerator.kt:286 */
   61    109   
    #[allow(missing_docs)] // documentation missing in model
         110  +
                           /* BuilderGenerator.kt:291 */
   62    111   
    pub fn result(mut self, input: crate::types::Result) -> Self {
         112  +
        /* BuilderGenerator.kt:292 */
   63    113   
        self.result = ::std::option::Option::Some(input);
         114  +
        /* BuilderGenerator.kt:293 */
   64    115   
        self
         116  +
        /* BuilderGenerator.kt:291 */
   65    117   
    }
         118  +
    /* BuilderGenerator.kt:312 */
   66    119   
    #[allow(missing_docs)] // documentation missing in model
         120  +
                           /* BuilderGenerator.kt:314 */
   67    121   
    pub fn set_result(mut self, input: ::std::option::Option<crate::types::Result>) -> Self {
         122  +
        /* BuilderGenerator.kt:315 */
   68    123   
        self.result = input;
   69    124   
        self
         125  +
        /* BuilderGenerator.kt:314 */
   70    126   
    }
         127  +
    /* BuilderGenerator.kt:334 */
   71    128   
    #[allow(missing_docs)] // documentation missing in model
         129  +
                           /* BuilderGenerator.kt:336 */
   72    130   
    pub fn get_result(&self) -> &::std::option::Option<crate::types::Result> {
         131  +
        /* BuilderGenerator.kt:337 */
   73    132   
        &self.result
         133  +
        /* BuilderGenerator.kt:336 */
   74    134   
    }
   75         -
    /// Appends an item to `result_list`.
         135  +
    /// /* BuilderGenerator.kt:410 */Appends an item to `result_list`.
         136  +
    /* BuilderGenerator.kt:411 */
   76    137   
    ///
   77         -
    /// To override the contents of this collection use [`set_result_list`](Self::set_result_list).
         138  +
    /// /* BuilderGenerator.kt:412 */To override the contents of this collection use [`set_result_list`](Self::set_result_list).
         139  +
    /* BuilderGenerator.kt:413 */
   78    140   
    ///
         141  +
    /* BuilderGenerator.kt:418 */
   79    142   
    pub fn result_list(mut self, input: crate::types::Result) -> Self {
         143  +
        /* BuilderGenerator.kt:419 */
   80    144   
        let mut v = self.result_list.unwrap_or_default();
   81    145   
        v.push(input);
   82    146   
        self.result_list = ::std::option::Option::Some(v);
   83    147   
        self
         148  +
        /* BuilderGenerator.kt:418 */
   84    149   
    }
         150  +
    /* BuilderGenerator.kt:312 */
   85    151   
    #[allow(missing_docs)] // documentation missing in model
         152  +
                           /* BuilderGenerator.kt:314 */
   86    153   
    pub fn set_result_list(mut self, input: ::std::option::Option<::std::vec::Vec<crate::types::Result>>) -> Self {
         154  +
        /* BuilderGenerator.kt:315 */
   87    155   
        self.result_list = input;
   88    156   
        self
         157  +
        /* BuilderGenerator.kt:314 */
   89    158   
    }
         159  +
    /* BuilderGenerator.kt:334 */
   90    160   
    #[allow(missing_docs)] // documentation missing in model
         161  +
                           /* BuilderGenerator.kt:336 */
   91    162   
    pub fn get_result_list(&self) -> &::std::option::Option<::std::vec::Vec<crate::types::Result>> {
         163  +
        /* BuilderGenerator.kt:337 */
   92    164   
        &self.result_list
         165  +
        /* BuilderGenerator.kt:336 */
   93    166   
    }
         167  +
    /* BuilderGenerator.kt:286 */
   94    168   
    #[allow(missing_docs)] // documentation missing in model
         169  +
                           /* BuilderGenerator.kt:291 */
   95    170   
    pub fn option(mut self, input: crate::types::Option) -> Self {
         171  +
        /* BuilderGenerator.kt:292 */
   96    172   
        self.option = ::std::option::Option::Some(input);
         173  +
        /* BuilderGenerator.kt:293 */
   97    174   
        self
         175  +
        /* BuilderGenerator.kt:291 */
   98    176   
    }
         177  +
    /* BuilderGenerator.kt:312 */
   99    178   
    #[allow(missing_docs)] // documentation missing in model
         179  +
                           /* BuilderGenerator.kt:314 */
  100    180   
    pub fn set_option(mut self, input: ::std::option::Option<crate::types::Option>) -> Self {
         181  +
        /* BuilderGenerator.kt:315 */
  101    182   
        self.option = input;
  102    183   
        self
         184  +
        /* BuilderGenerator.kt:314 */
  103    185   
    }
         186  +
    /* BuilderGenerator.kt:334 */
  104    187   
    #[allow(missing_docs)] // documentation missing in model
         188  +
                           /* BuilderGenerator.kt:336 */
  105    189   
    pub fn get_option(&self) -> &::std::option::Option<crate::types::Option> {
         190  +
        /* BuilderGenerator.kt:337 */
  106    191   
        &self.option
         192  +
        /* BuilderGenerator.kt:336 */
  107    193   
    }
  108         -
    /// Appends an item to `option_list`.
         194  +
    /// /* BuilderGenerator.kt:410 */Appends an item to `option_list`.
         195  +
    /* BuilderGenerator.kt:411 */
  109    196   
    ///
  110         -
    /// To override the contents of this collection use [`set_option_list`](Self::set_option_list).
         197  +
    /// /* BuilderGenerator.kt:412 */To override the contents of this collection use [`set_option_list`](Self::set_option_list).
         198  +
    /* BuilderGenerator.kt:413 */
  111    199   
    ///
         200  +
    /* BuilderGenerator.kt:418 */
  112    201   
    pub fn option_list(mut self, input: crate::types::Result) -> Self {
         202  +
        /* BuilderGenerator.kt:419 */
  113    203   
        let mut v = self.option_list.unwrap_or_default();
  114    204   
        v.push(input);
  115    205   
        self.option_list = ::std::option::Option::Some(v);
  116    206   
        self
         207  +
        /* BuilderGenerator.kt:418 */
  117    208   
    }
         209  +
    /* BuilderGenerator.kt:312 */
  118    210   
    #[allow(missing_docs)] // documentation missing in model
         211  +
                           /* BuilderGenerator.kt:314 */
  119    212   
    pub fn set_option_list(mut self, input: ::std::option::Option<::std::vec::Vec<crate::types::Result>>) -> Self {
         213  +
        /* BuilderGenerator.kt:315 */
  120    214   
        self.option_list = input;
  121    215   
        self
         216  +
        /* BuilderGenerator.kt:314 */
  122    217   
    }
         218  +
    /* BuilderGenerator.kt:334 */
  123    219   
    #[allow(missing_docs)] // documentation missing in model
         220  +
                           /* BuilderGenerator.kt:336 */
  124    221   
    pub fn get_option_list(&self) -> &::std::option::Option<::std::vec::Vec<crate::types::Result>> {
         222  +
        /* BuilderGenerator.kt:337 */
  125    223   
        &self.option_list
         224  +
        /* BuilderGenerator.kt:336 */
  126    225   
    }
         226  +
    /* BuilderGenerator.kt:286 */
  127    227   
    #[allow(missing_docs)] // documentation missing in model
         228  +
                           /* BuilderGenerator.kt:291 */
  128    229   
    pub fn some_union(mut self, input: crate::types::SomeUnion) -> Self {
         230  +
        /* BuilderGenerator.kt:292 */
  129    231   
        self.some_union = ::std::option::Option::Some(input);
         232  +
        /* BuilderGenerator.kt:293 */
  130    233   
        self
         234  +
        /* BuilderGenerator.kt:291 */
  131    235   
    }
         236  +
    /* BuilderGenerator.kt:312 */
  132    237   
    #[allow(missing_docs)] // documentation missing in model
         238  +
                           /* BuilderGenerator.kt:314 */
  133    239   
    pub fn set_some_union(mut self, input: ::std::option::Option<crate::types::SomeUnion>) -> Self {
         240  +
        /* BuilderGenerator.kt:315 */
  134    241   
        self.some_union = input;
  135    242   
        self
         243  +
        /* BuilderGenerator.kt:314 */
  136    244   
    }
         245  +
    /* BuilderGenerator.kt:334 */
  137    246   
    #[allow(missing_docs)] // documentation missing in model
         247  +
                           /* BuilderGenerator.kt:336 */
  138    248   
    pub fn get_some_union(&self) -> &::std::option::Option<crate::types::SomeUnion> {
         249  +
        /* BuilderGenerator.kt:337 */
  139    250   
        &self.some_union
         251  +
        /* BuilderGenerator.kt:336 */
  140    252   
    }
  141         -
    /// Consumes the builder and constructs a [`SomethingElse`](crate::types::SomethingElse).
         253  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`SomethingElse`](crate::types::SomethingElse).
         254  +
    /* BuilderGenerator.kt:253 */
  142    255   
    pub fn build(self) -> crate::types::SomethingElse {
         256  +
        /* BuilderGenerator.kt:477 */
  143    257   
        crate::types::SomethingElse {
  144         -
            result: self.result,
         258  +
            /* BuilderGenerator.kt:481 */ result: self.result,
         259  +
            /* BuilderGenerator.kt:481 */
  145    260   
            result_list: self.result_list,
         261  +
            /* BuilderGenerator.kt:481 */
  146    262   
            option: self.option,
         263  +
            /* BuilderGenerator.kt:481 */
  147    264   
            option_list: self.option_list,
         265  +
            /* BuilderGenerator.kt:481 */
  148    266   
            some_union: self.some_union,
         267  +
            /* BuilderGenerator.kt:477 */
  149    268   
        }
         269  +
        /* BuilderGenerator.kt:253 */
  150    270   
    }
         271  +
    /* BuilderGenerator.kt:355 */
  151    272   
}

tmp-codegen-diff/codegen-client-test/naming_test_structs/rust-client-codegen/src/types/builders.rs

@@ -1,1 +6,9 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* CodegenDelegator.kt:255 */
    2      3   
pub use crate::types::_something_else::SomethingElseBuilder;
    3      4   
           5  +
/* CodegenDelegator.kt:255 */
    4      6   
pub use crate::types::_option::OptionBuilder;
    5      7   
           8  +
/* CodegenDelegator.kt:255 */
    6      9   
pub use crate::types::_result::ResultBuilder;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/client.rs

@@ -1,1 +31,32 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* FluentClientGenerator.kt:105 */
    2      3   
#[derive(Debug)]
    3      4   
pub(crate) struct Handle {
    4      5   
    pub(crate) conf: crate::Config,
    5      6   
    #[allow(dead_code)] // unused when a service does not provide any operations
    6      7   
    pub(crate) runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
    7      8   
}
    8      9   
    9     10   
///
   10     11   
/// An ergonomic client for Pokémon Service.
   11     12   
///
@@ -59,60 +122,127 @@
   79     80   
    fn validate_config(handle: &Handle) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
   80     81   
        let mut cfg = ::aws_smithy_types::config_bag::ConfigBag::base();
   81     82   
        handle
   82     83   
            .runtime_plugins
   83     84   
            .apply_client_configuration(&mut cfg)?
   84     85   
            .validate_base_client_config(&cfg)?;
   85     86   
        Ok(())
   86     87   
    }
   87     88   
}
   88     89   
          90  +
/* RustModule.kt:172 */
   89     91   
mod capture_pokemon;
   90     92   
          93  +
/* RustModule.kt:172 */
   91     94   
mod check_health;
   92     95   
   93         -
/// Operation customization and supporting types.
          96  +
/// /* ClientRustModule.kt:161 */Operation customization and supporting types.
   94     97   
///
   95         -
/// The underlying HTTP requests made during an operation can be customized
          98  +
/// /* ClientRustModule.kt:170 */The underlying HTTP requests made during an operation can be customized
   96     99   
/// by calling the `customize()` method on the builder returned from a client
   97    100   
/// operation call. For example, this can be used to add an additional HTTP header:
   98    101   
///
   99    102   
/// ```ignore
  100    103   
/// # async fn wrapper() -> ::std::result::Result<(), pokemon_service_awsjson_client::Error> {
  101    104   
/// # let client: pokemon_service_awsjson_client::Client = unimplemented!();
  102    105   
/// use ::http::header::{HeaderName, HeaderValue};
  103    106   
///
  104    107   
/// let result = client.capture_pokemon()
  105    108   
///     .customize()
  106    109   
///     .mutate_request(|req| {
  107    110   
///         // Add `x-example-header` with value
  108    111   
///         req.headers_mut()
  109    112   
///             .insert(
  110    113   
///                 HeaderName::from_static("x-example-header"),
  111    114   
///                 HeaderValue::from_static("1"),
  112    115   
///             );
  113    116   
///     })
  114    117   
///     .send()
  115    118   
///     .await;
  116    119   
/// # }
  117    120   
/// ```
  118    121   
pub mod customize;
  119    122   
         123  +
/* RustModule.kt:172 */
  120    124   
mod do_nothing;
  121    125   
         126  +
/* RustModule.kt:172 */
  122    127   
mod get_server_statistics;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/client/capture_pokemon.rs

@@ -1,1 +13,17 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* FluentClientGenerator.kt:187 */
    2      3   
impl super::Client {
           4  +
    /* FluentClientGenerator.kt:221 */
    3      5   
    /// Constructs a fluent builder for the [`CapturePokemon`](crate::operation::capture_pokemon::builders::CapturePokemonFluentBuilder) operation.
    4      6   
    ///
    5      7   
    /// - The fluent builder is configurable:
    6      8   
    ///   - [`events(EventStreamSender<AttemptCapturingPokemonEvent, AttemptCapturingPokemonEventError>)`](crate::operation::capture_pokemon::builders::CapturePokemonFluentBuilder::events) / [`set_events(EventStreamSender<AttemptCapturingPokemonEvent, AttemptCapturingPokemonEventError>)`](crate::operation::capture_pokemon::builders::CapturePokemonFluentBuilder::set_events):<br>required: **false**<br>(undocumented)<br>
    7      9   
    /// - On success, responds with [`CapturePokemonOutput`](crate::operation::capture_pokemon::CapturePokemonOutput) with field(s):
    8     10   
    ///   - [`events(EventReceiver<CapturePokemonEvents, CapturePokemonEventsError>)`](crate::operation::capture_pokemon::CapturePokemonOutput::events): (undocumented)
    9     11   
    /// - On failure, responds with [`SdkError<CapturePokemonError>`](crate::operation::capture_pokemon::CapturePokemonError)
          12  +
    /* FluentClientGenerator.kt:234 */
   10     13   
    pub fn capture_pokemon(&self) -> crate::operation::capture_pokemon::builders::CapturePokemonFluentBuilder {
   11     14   
        crate::operation::capture_pokemon::builders::CapturePokemonFluentBuilder::new(self.handle.clone())
   12     15   
    }
          16  +
    /* FluentClientGenerator.kt:187 */
   13     17   
}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/client/check_health.rs

@@ -1,1 +11,15 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* FluentClientGenerator.kt:187 */
    2      3   
impl super::Client {
           4  +
    /* FluentClientGenerator.kt:221 */
    3      5   
    /// Constructs a fluent builder for the [`CheckHealth`](crate::operation::check_health::builders::CheckHealthFluentBuilder) operation.
    4      6   
    ///
    5      7   
    /// - The fluent builder takes no input, just [`send`](crate::operation::check_health::builders::CheckHealthFluentBuilder::send) it.
    6      8   
    /// - On success, responds with [`CheckHealthOutput`](crate::operation::check_health::CheckHealthOutput)
    7      9   
    /// - On failure, responds with [`SdkError<CheckHealthError>`](crate::operation::check_health::CheckHealthError)
          10  +
    /* FluentClientGenerator.kt:234 */
    8     11   
    pub fn check_health(&self) -> crate::operation::check_health::builders::CheckHealthFluentBuilder {
    9     12   
        crate::operation::check_health::builders::CheckHealthFluentBuilder::new(self.handle.clone())
   10     13   
    }
          14  +
    /* FluentClientGenerator.kt:187 */
   11     15   
}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/client/customize.rs

@@ -1,1 +32,33 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2      2   
           3  +
/* CustomizableOperationGenerator.kt:72 */
    3      4   
/// `CustomizableOperation` allows for configuring a single operation invocation before it is sent.
    4      5   
pub struct CustomizableOperation<T, E, B> {
    5      6   
    customizable_send: B,
    6      7   
    config_override: ::std::option::Option<crate::config::Builder>,
    7      8   
    interceptors: Vec<::aws_smithy_runtime_api::client::interceptors::SharedInterceptor>,
    8      9   
    runtime_plugins: Vec<::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin>,
    9     10   
    _output: ::std::marker::PhantomData<T>,
   10     11   
    _error: ::std::marker::PhantomData<E>,
   11     12   
}
   12     13

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/client/customize/internal.rs

@@ -1,1 +12,13 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* CustomizableOperationGenerator.kt:204 */
    2      3   
pub type BoxFuture<T> = ::std::pin::Pin<::std::boxed::Box<dyn ::std::future::Future<Output = T> + ::std::marker::Send>>;
    3      4   
    4      5   
pub type SendResult<T, E> =
    5      6   
    ::std::result::Result<T, ::aws_smithy_runtime_api::client::result::SdkError<E, ::aws_smithy_runtime_api::client::orchestrator::HttpResponse>>;
    6      7   
    7      8   
pub trait CustomizableSend<T, E>: ::std::marker::Send + ::std::marker::Sync {
    8      9   
    // Takes an owned `self` as the implementation will internally call methods that take `self`.
    9     10   
    // If it took `&self`, that would make this trait object safe, but some implementing types do not
   10     11   
    // derive `Clone`, unable to yield `self` from `&self`.
   11     12   
    fn send(self, config_override: crate::config::Builder) -> BoxFuture<SendResult<T, E>>;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/client/do_nothing.rs

@@ -1,1 +11,15 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* FluentClientGenerator.kt:187 */
    2      3   
impl super::Client {
           4  +
    /* FluentClientGenerator.kt:221 */
    3      5   
    /// Constructs a fluent builder for the [`DoNothing`](crate::operation::do_nothing::builders::DoNothingFluentBuilder) operation.
    4      6   
    ///
    5      7   
    /// - The fluent builder takes no input, just [`send`](crate::operation::do_nothing::builders::DoNothingFluentBuilder::send) it.
    6      8   
    /// - On success, responds with [`DoNothingOutput`](crate::operation::do_nothing::DoNothingOutput)
    7      9   
    /// - On failure, responds with [`SdkError<DoNothingError>`](crate::operation::do_nothing::DoNothingError)
          10  +
    /* FluentClientGenerator.kt:234 */
    8     11   
    pub fn do_nothing(&self) -> crate::operation::do_nothing::builders::DoNothingFluentBuilder {
    9     12   
        crate::operation::do_nothing::builders::DoNothingFluentBuilder::new(self.handle.clone())
   10     13   
    }
          14  +
    /* FluentClientGenerator.kt:187 */
   11     15   
}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/client/get_server_statistics.rs

@@ -1,1 +12,16 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* FluentClientGenerator.kt:187 */
    2      3   
impl super::Client {
           4  +
    /* FluentClientGenerator.kt:221 */
    3      5   
    /// Constructs a fluent builder for the [`GetServerStatistics`](crate::operation::get_server_statistics::builders::GetServerStatisticsFluentBuilder) operation.
    4      6   
    ///
    5      7   
    /// - The fluent builder takes no input, just [`send`](crate::operation::get_server_statistics::builders::GetServerStatisticsFluentBuilder::send) it.
    6      8   
    /// - On success, responds with [`GetServerStatisticsOutput`](crate::operation::get_server_statistics::GetServerStatisticsOutput) with field(s):
    7      9   
    ///   - [`calls_count(i64)`](crate::operation::get_server_statistics::GetServerStatisticsOutput::calls_count): The number of calls executed by the server.
    8     10   
    /// - On failure, responds with [`SdkError<GetServerStatisticsError>`](crate::operation::get_server_statistics::GetServerStatisticsError)
          11  +
    /* FluentClientGenerator.kt:234 */
    9     12   
    pub fn get_server_statistics(&self) -> crate::operation::get_server_statistics::builders::GetServerStatisticsFluentBuilder {
   10     13   
        crate::operation::get_server_statistics::builders::GetServerStatisticsFluentBuilder::new(self.handle.clone())
   11     14   
    }
          15  +
    /* FluentClientGenerator.kt:187 */
   12     16   
}

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config.rs

@@ -1,1 +171,209 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
    2         -
    3         -
/// Configuration for a pokemon_service_awsjson_client service client.
           2  +
/* ServiceConfigGenerator.kt:409 */
           3  +
/// /* ServiceConfigGenerator.kt:409 */Configuration for a pokemon_service_awsjson_client service client.
    4      4   
///
           5  +
/* RustType.kt:516 */
    5      6   
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
           7  +
/* ServiceConfigGenerator.kt:414 */
    6      8   
pub struct Config {
    7         -
    // Both `config` and `cloneable` are the same config, but the cloneable one
           9  +
    /* ServiceConfigGenerator.kt:415 */// Both `config` and `cloneable` are the same config, but the cloneable one
    8     10   
    // is kept around so that it is possible to convert back into a builder. This can be
    9     11   
    // optimized in the future.
   10     12   
    pub(crate) config: crate::config::FrozenLayer,
   11     13   
    cloneable: ::aws_smithy_types::config_bag::CloneableLayer,
   12     14   
    pub(crate) runtime_components: crate::config::RuntimeComponentsBuilder,
   13     15   
    pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
   14     16   
    pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
          17  +
    /* ServiceConfigGenerator.kt:414 */
   15     18   
}
          19  +
/* ServiceConfigGenerator.kt:433 */
   16     20   
impl Config {
   17         -
    ///
          21  +
    /// /* ServiceConfigGenerator.kt:434 */
   18     22   
    /// Constructs a config builder.
   19     23   
    /// <div class="warning">
   20     24   
    /// Note that a config created from this builder will not have the same safe defaults as one created by
   21     25   
    /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
   22     26   
    /// </div>
   23     27   
    ///
          28  +
    /* ServiceConfigGenerator.kt:435 */
   24     29   
    pub fn builder() -> Builder {
   25     30   
        Builder::default()
   26     31   
    }
          32  +
    /* ServiceConfigGenerator.kt:440 */
   27     33   
    /// Converts this config back into a builder so that it can be tweaked.
   28     34   
    pub fn to_builder(&self) -> Builder {
   29     35   
        Builder {
   30     36   
            config: self.cloneable.clone(),
   31     37   
            runtime_components: self.runtime_components.clone(),
   32     38   
            runtime_plugins: self.runtime_plugins.clone(),
   33     39   
            behavior_version: self.behavior_version,
   34     40   
        }
   35     41   
    }
          42  +
    /* StalledStreamProtectionConfigCustomization.kt:57 */
   36     43   
    /// Return a reference to the stalled stream protection configuration contained in this config, if any.
   37     44   
    pub fn stalled_stream_protection(&self) -> ::std::option::Option<&crate::config::StalledStreamProtectionConfig> {
   38     45   
        self.config.load::<crate::config::StalledStreamProtectionConfig>()
   39     46   
    }
          47  +
    /* HttpConnectorConfigDecorator.kt:52 */
   40     48   
    /// Return the [`SharedHttpClient`](crate::config::SharedHttpClient) to use when making requests, if any.
   41     49   
    pub fn http_client(&self) -> Option<crate::config::SharedHttpClient> {
   42     50   
        self.runtime_components.http_client()
   43     51   
    }
          52  +
    /* EndpointConfigCustomization.kt:47 */
   44     53   
    /// Returns the endpoint resolver.
   45     54   
    pub fn endpoint_resolver(&self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver {
   46     55   
        self.runtime_components.endpoint_resolver().expect("resolver defaulted if not set")
   47     56   
    }
          57  +
    /* ResiliencyConfigCustomization.kt:51 */
   48     58   
    /// Return a reference to the retry configuration contained in this config, if any.
   49     59   
    pub fn retry_config(&self) -> ::std::option::Option<&::aws_smithy_types::retry::RetryConfig> {
   50     60   
        self.config.load::<::aws_smithy_types::retry::RetryConfig>()
   51     61   
    }
   52     62   
   53     63   
    /// Return a cloned shared async sleep implementation from this config, if any.
   54     64   
    pub fn sleep_impl(&self) -> ::std::option::Option<crate::config::SharedAsyncSleep> {
   55     65   
        self.runtime_components.sleep_impl()
   56     66   
    }
   57     67   
   58     68   
    /// Return a reference to the timeout configuration contained in this config, if any.
   59     69   
    pub fn timeout_config(&self) -> ::std::option::Option<&::aws_smithy_types::timeout::TimeoutConfig> {
   60     70   
        self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>()
   61     71   
    }
   62     72   
   63     73   
    /// Returns a reference to the retry partition contained in this config, if any.
   64     74   
    ///
   65     75   
    /// WARNING: This method is unstable and may be removed at any time. Do not rely on this
   66     76   
    /// method for anything!
   67     77   
    pub fn retry_partition(&self) -> ::std::option::Option<&::aws_smithy_runtime::client::retries::RetryPartition> {
   68     78   
        self.config.load::<::aws_smithy_runtime::client::retries::RetryPartition>()
   69     79   
    }
          80  +
    /* IdentityCacheDecorator.kt:96 */
   70     81   
    /// Returns the configured identity cache for auth.
   71     82   
    pub fn identity_cache(&self) -> ::std::option::Option<crate::config::SharedIdentityCache> {
   72     83   
        self.runtime_components.identity_cache()
   73     84   
    }
          85  +
    /* InterceptorConfigCustomization.kt:30 */
   74     86   
    /// Returns interceptors currently registered by the user.
   75     87   
    pub fn interceptors(&self) -> impl Iterator<Item = crate::config::SharedInterceptor> + '_ {
   76     88   
        self.runtime_components.interceptors()
   77     89   
    }
          90  +
    /* TimeSourceCustomization.kt:34 */
   78     91   
    /// Return time source used for this service.
          92  +
    /* TimeSourceCustomization.kt:35 */
   79     93   
    pub fn time_source(&self) -> ::std::option::Option<::aws_smithy_async::time::SharedTimeSource> {
          94  +
        /* TimeSourceCustomization.kt:39 */
   80     95   
        self.runtime_components.time_source()
          96  +
        /* TimeSourceCustomization.kt:35 */
   81     97   
    }
          98  +
    /* RetryClassifierConfigCustomization.kt:39 */
   82     99   
    /// Returns retry classifiers currently registered by the user.
   83    100   
    pub fn retry_classifiers(&self) -> impl Iterator<Item = ::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier> + '_ {
   84    101   
        self.runtime_components.retry_classifiers()
   85    102   
    }
         103  +
    /* ServiceConfigGenerator.kt:433 */
   86    104   
}
   87         -
/// Builder for creating a `Config`.
         105  +
/// /* ServiceConfigGenerator.kt:458 */Builder for creating a `Config`.
         106  +
/* RustType.kt:516 */
   88    107   
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
         108  +
/* ServiceConfigGenerator.kt:460 */
   89    109   
pub struct Builder {
   90         -
    pub(crate) config: ::aws_smithy_types::config_bag::CloneableLayer,
         110  +
    /* ServiceConfigGenerator.kt:461 */ pub(crate) config: ::aws_smithy_types::config_bag::CloneableLayer,
   91    111   
    pub(crate) runtime_components: crate::config::RuntimeComponentsBuilder,
   92    112   
    pub(crate) runtime_plugins: ::std::vec::Vec<crate::config::SharedRuntimePlugin>,
   93    113   
    pub(crate) behavior_version: ::std::option::Option<crate::config::BehaviorVersion>,
         114  +
    /* ServiceConfigGenerator.kt:460 */
   94    115   
}
         116  +
/* ServiceConfigGenerator.kt:476 */
   95    117   
impl ::std::default::Default for Builder {
         118  +
    /* ServiceConfigGenerator.kt:477 */
   96    119   
    fn default() -> Self {
   97    120   
        Self {
   98    121   
            config: ::std::default::Default::default(),
   99    122   
            runtime_components: crate::config::RuntimeComponentsBuilder::new("service config"),
  100    123   
            runtime_plugins: ::std::default::Default::default(),
  101    124   
            behavior_version: ::std::default::Default::default(),
  102    125   
        }
  103    126   
    }
         127  +
    /* ServiceConfigGenerator.kt:476 */
  104    128   
}
         129  +
/* ServiceConfigGenerator.kt:492 */
  105    130   
impl Builder {
  106         -
    ///
         131  +
    /// /* ServiceConfigGenerator.kt:493 */
  107    132   
    /// Constructs a config builder.
  108    133   
    /// <div class="warning">
  109    134   
    /// Note that a config created from this builder will not have the same safe defaults as one created by
  110    135   
    /// the <a href="https://crates.io/crates/aws-config" target="_blank">aws-config</a> crate.
  111    136   
    /// </div>
  112    137   
    ///
         138  +
    /* ServiceConfigGenerator.kt:494 */
  113    139   
    pub fn new() -> Self {
  114    140   
        Self::default()
  115    141   
    }
  116         -
    /// Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
  117         -
    /// but not those in runtime components.
         142  +
    /// /* ServiceConfigGenerator.kt:327 */Constructs a config builder from the given `config_bag`, setting only fields stored in the config bag,
         143  +
    /// /* ServiceConfigGenerator.kt:328 */but not those in runtime components.
         144  +
    /* RustType.kt:516 */
  118    145   
    #[allow(unused)]
         146  +
    /* ServiceConfigGenerator.kt:330 */
  119    147   
    pub(crate) fn from_config_bag(config_bag: &::aws_smithy_types::config_bag::ConfigBag) -> Self {
         148  +
        /* ServiceConfigGenerator.kt:334 */
  120    149   
        let mut builder = Self::new();
         150  +
        /* StalledStreamProtectionConfigCustomization.kt:102 */
  121    151   
        builder.set_stalled_stream_protection(config_bag.load::<crate::config::StalledStreamProtectionConfig>().cloned());
         152  +
        /* ResiliencyConfigCustomization.kt:294 */
  122    153   
        builder.set_retry_config(config_bag.load::<::aws_smithy_types::retry::RetryConfig>().cloned());
         154  +
        /* ResiliencyConfigCustomization.kt:298 */
  123    155   
        builder.set_timeout_config(config_bag.load::<::aws_smithy_types::timeout::TimeoutConfig>().cloned());
         156  +
        /* ResiliencyConfigCustomization.kt:302 */
  124    157   
        builder.set_retry_partition(config_bag.load::<::aws_smithy_runtime::client::retries::RetryPartition>().cloned());
         158  +
        /* ServiceConfigGenerator.kt:338 */
  125    159   
        builder
         160  +
        /* ServiceConfigGenerator.kt:330 */
  126    161   
    }
         162  +
    /* StalledStreamProtectionConfigCustomization.kt:69 */
  127    163   
    /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
  128    164   
    /// to configure protection for stalled streams.
  129    165   
    pub fn stalled_stream_protection(mut self, stalled_stream_protection_config: crate::config::StalledStreamProtectionConfig) -> Self {
  130    166   
        self.set_stalled_stream_protection(::std::option::Option::Some(stalled_stream_protection_config));
  131    167   
        self
  132    168   
    }
         169  +
    /* StalledStreamProtectionConfigCustomization.kt:84 */
  133    170   
    /// Set the [`StalledStreamProtectionConfig`](crate::config::StalledStreamProtectionConfig)
  134    171   
    /// to configure protection for stalled streams.
  135    172   
    pub fn set_stalled_stream_protection(
  136    173   
        &mut self,
  137    174   
        stalled_stream_protection_config: ::std::option::Option<crate::config::StalledStreamProtectionConfig>,
  138    175   
    ) -> &mut Self {
  139    176   
        self.config.store_or_unset(stalled_stream_protection_config);
  140    177   
        self
  141    178   
    }
         179  +
    /* HttpConnectorConfigDecorator.kt:65 */
  142    180   
    /// Sets the HTTP client to use when making requests.
  143    181   
    ///
  144    182   
    /// # Examples
  145    183   
    /// ```no_run
  146    184   
    /// # #[cfg(test)]
  147    185   
    /// # mod tests {
  148    186   
    /// # #[test]
  149    187   
    /// # fn example() {
  150    188   
    /// use std::time::Duration;
  151    189   
    /// use pokemon_service_awsjson_client::config::Config;
@@ -179,217 +461,511 @@
  199    237   
    /// let mut builder = pokemon_service_awsjson_client::Config::builder();
  200    238   
    /// override_http_client(&mut builder);
  201    239   
    /// let config = builder.build();
  202    240   
    /// # }
  203    241   
    /// # }
  204    242   
    /// ```
  205    243   
    pub fn set_http_client(&mut self, http_client: Option<crate::config::SharedHttpClient>) -> &mut Self {
  206    244   
        self.runtime_components.set_http_client(http_client);
  207    245   
        self
  208    246   
    }
         247  +
    /* EndpointConfigCustomization.kt:73 */
  209    248   
    /// Set the endpoint URL to use when making requests.
  210    249   
    ///
  211    250   
    /// Note: setting an endpoint URL will replace any endpoint resolver that has been set.
  212    251   
    ///
  213    252   
    /// # Panics
  214    253   
    /// Panics if an invalid URL is given.
  215    254   
    pub fn endpoint_url(mut self, endpoint_url: impl ::std::convert::Into<::std::string::String>) -> Self {
  216    255   
        self.set_endpoint_url(::std::option::Option::Some(endpoint_url.into()));
  217    256   
        self
  218    257   
    }
  219    258   
  220    259   
    /// Set the endpoint URL to use when making requests.
  221    260   
    ///
  222    261   
    /// Note: setting an endpoint URL will replace any endpoint resolver that has been set.
  223    262   
    ///
  224    263   
    /// # Panics
  225    264   
    /// Panics if an invalid URL is given.
  226    265   
    pub fn set_endpoint_url(&mut self, endpoint_url: ::std::option::Option<::std::string::String>) -> &mut Self {
  227    266   
        #[allow(deprecated)]
  228    267   
        self.set_endpoint_resolver(endpoint_url.map(|url| {
  229    268   
            ::aws_smithy_runtime_api::shared::IntoShared::into_shared(
  230    269   
                ::aws_smithy_runtime::client::orchestrator::endpoints::StaticUriEndpointResolver::uri(url),
  231    270   
            )
  232    271   
        }));
  233    272   
        self
  234    273   
    }
         274  +
    /* EndpointConfigCustomization.kt:105 */
  235    275   
    /// Sets the endpoint resolver to use when making requests.
  236    276   
    ///
  237    277   
    /// This service does not define a default endpoint resolver.
  238    278   
    ///
  239    279   
    /// Note: setting an endpoint resolver will replace any endpoint URL that has been set.
  240    280   
    /// This method accepts an endpoint resolver [specific to this service](crate::config::endpoint::ResolveEndpoint). If you want to
  241    281   
    /// provide a shared endpoint resolver, use [`Self::set_endpoint_resolver`].
  242    282   
    ///
  243    283   
    /// # Examples
  244    284   
    /// Create a custom endpoint resolver that resolves a different endpoing per-stage, e.g. staging vs. production.
  245    285   
    /// ```no_run
  246    286   
    /// use pokemon_service_awsjson_client::config::endpoint::{ResolveEndpoint, EndpointFuture, Params, Endpoint};
  247    287   
    /// #[derive(Debug)]
  248    288   
    /// struct StageResolver { stage: String }
  249    289   
    /// impl ResolveEndpoint for StageResolver {
  250    290   
    ///     fn resolve_endpoint(&self, params: &Params) -> EndpointFuture<'_> {
  251    291   
    ///         let stage = &self.stage;
  252    292   
    ///         EndpointFuture::ready(Ok(Endpoint::builder().url(format!("{stage}.myservice.com")).build()))
  253    293   
    ///     }
  254    294   
    /// }
  255    295   
    /// let resolver = StageResolver { stage: std::env::var("STAGE").unwrap() };
  256    296   
    /// let config = pokemon_service_awsjson_client::Config::builder().endpoint_resolver(resolver).build();
  257    297   
    /// let client = pokemon_service_awsjson_client::Client::from_conf(config);
  258    298   
    /// ```
  259    299   
    pub fn endpoint_resolver(mut self, endpoint_resolver: impl crate::config::endpoint::ResolveEndpoint + 'static) -> Self {
  260    300   
        self.set_endpoint_resolver(::std::option::Option::Some(endpoint_resolver.into_shared_resolver()));
  261    301   
        self
  262    302   
    }
  263    303   
  264    304   
    /// Sets the endpoint resolver to use when making requests.
  265    305   
    ///
  266    306   
    /// This service does not define a default endpoint resolver.
         307  +
    /* EndpointConfigCustomization.kt:143 */
  267    308   
    pub fn set_endpoint_resolver(
  268    309   
        &mut self,
  269    310   
        endpoint_resolver: ::std::option::Option<::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver>,
  270    311   
    ) -> &mut Self {
  271    312   
        self.runtime_components.set_endpoint_resolver(endpoint_resolver);
  272    313   
        self
  273    314   
    }
         315  +
    /* ResiliencyConfigCustomization.kt:81 */
  274    316   
    /// Set the retry_config for the builder
  275    317   
    ///
  276    318   
    /// # Examples
  277    319   
    /// ```no_run
  278    320   
    /// use pokemon_service_awsjson_client::config::Config;
  279    321   
    /// use pokemon_service_awsjson_client::config::retry::RetryConfig;
  280    322   
    ///
  281    323   
    /// let retry_config = RetryConfig::standard().with_max_attempts(5);
  282    324   
    /// let config = Config::builder().retry_config(retry_config).build();
  283    325   
    /// ```
  284    326   
    pub fn retry_config(mut self, retry_config: ::aws_smithy_types::retry::RetryConfig) -> Self {
  285    327   
        self.set_retry_config(Some(retry_config));
  286    328   
        self
  287    329   
    }
  288    330   
  289    331   
    /// Set the retry_config for the builder
  290    332   
    ///
  291    333   
    /// # Examples
  292    334   
    /// ```no_run
  293    335   
    /// use pokemon_service_awsjson_client::config::{Builder, Config};
  294    336   
    /// use pokemon_service_awsjson_client::config::retry::RetryConfig;
  295    337   
    ///
  296    338   
    /// fn disable_retries(builder: &mut Builder) {
  297    339   
    ///     let retry_config = RetryConfig::standard().with_max_attempts(1);
  298    340   
    ///     builder.set_retry_config(Some(retry_config));
  299    341   
    /// }
  300    342   
    ///
  301    343   
    /// let mut builder = Config::builder();
  302    344   
    /// disable_retries(&mut builder);
  303    345   
    /// let config = builder.build();
  304    346   
    /// ```
         347  +
    /* ResiliencyConfigCustomization.kt:118 */
  305    348   
    pub fn set_retry_config(&mut self, retry_config: ::std::option::Option<::aws_smithy_types::retry::RetryConfig>) -> &mut Self {
  306    349   
        retry_config.map(|r| self.config.store_put(r));
  307    350   
        self
  308    351   
    }
         352  +
    /* ResiliencyConfigCustomization.kt:128 */
  309    353   
    /// Set the sleep_impl for the builder
  310    354   
    ///
  311    355   
    /// # Examples
  312    356   
    ///
  313    357   
    /// ```no_run
  314    358   
    /// use pokemon_service_awsjson_client::config::{AsyncSleep, Config, SharedAsyncSleep, Sleep};
  315    359   
    ///
  316    360   
    /// #[derive(Debug)]
  317    361   
    /// pub struct ForeverSleep;
  318    362   
    ///
  319    363   
    /// impl AsyncSleep for ForeverSleep {
  320    364   
    ///     fn sleep(&self, duration: std::time::Duration) -> Sleep {
  321    365   
    ///         Sleep::new(std::future::pending())
  322    366   
    ///     }
  323    367   
    /// }
  324    368   
    ///
  325    369   
    /// let sleep_impl = SharedAsyncSleep::new(ForeverSleep);
  326    370   
    /// let config = Config::builder().sleep_impl(sleep_impl).build();
  327    371   
    /// ```
  328    372   
    pub fn sleep_impl(mut self, sleep_impl: impl crate::config::AsyncSleep + 'static) -> Self {
  329    373   
        self.set_sleep_impl(Some(::aws_smithy_runtime_api::shared::IntoShared::into_shared(sleep_impl)));
  330    374   
        self
  331    375   
    }
  332    376   
  333    377   
    /// Set the sleep_impl for the builder
  334    378   
    ///
  335    379   
    /// # Examples
  336    380   
    ///
  337    381   
    /// ```no_run
  338    382   
    /// use pokemon_service_awsjson_client::config::{AsyncSleep, Builder, Config, SharedAsyncSleep, Sleep};
  339    383   
    ///
  340    384   
    /// #[derive(Debug)]
  341    385   
    /// pub struct ForeverSleep;
  342    386   
    ///
  343    387   
    /// impl AsyncSleep for ForeverSleep {
  344    388   
    ///     fn sleep(&self, duration: std::time::Duration) -> Sleep {
  345    389   
    ///         Sleep::new(std::future::pending())
  346    390   
    ///     }
  347    391   
    /// }
  348    392   
    ///
  349    393   
    /// fn set_never_ending_sleep_impl(builder: &mut Builder) {
  350    394   
    ///     let sleep_impl = SharedAsyncSleep::new(ForeverSleep);
  351    395   
    ///     builder.set_sleep_impl(Some(sleep_impl));
  352    396   
    /// }
  353    397   
    ///
  354    398   
    /// let mut builder = Config::builder();
  355    399   
    /// set_never_ending_sleep_impl(&mut builder);
  356    400   
    /// let config = builder.build();
  357    401   
    /// ```
         402  +
    /* ResiliencyConfigCustomization.kt:184 */
  358    403   
    pub fn set_sleep_impl(&mut self, sleep_impl: ::std::option::Option<crate::config::SharedAsyncSleep>) -> &mut Self {
  359    404   
        self.runtime_components.set_sleep_impl(sleep_impl);
  360    405   
        self
  361    406   
    }
         407  +
    /* ResiliencyConfigCustomization.kt:194 */
  362    408   
    /// Set the timeout_config for the builder
  363    409   
    ///
  364    410   
    /// # Examples
  365    411   
    ///
  366    412   
    /// ```no_run
  367    413   
    /// # use std::time::Duration;
  368    414   
    /// use pokemon_service_awsjson_client::config::Config;
  369    415   
    /// use pokemon_service_awsjson_client::config::timeout::TimeoutConfig;
  370    416   
    ///
  371    417   
    /// let timeout_config = TimeoutConfig::builder()
  372    418   
    ///     .operation_attempt_timeout(Duration::from_secs(1))
  373    419   
    ///     .build();
  374    420   
    /// let config = Config::builder().timeout_config(timeout_config).build();
  375    421   
    /// ```
  376    422   
    pub fn timeout_config(mut self, timeout_config: ::aws_smithy_types::timeout::TimeoutConfig) -> Self {
  377    423   
        self.set_timeout_config(Some(timeout_config));
  378    424   
        self
  379    425   
    }
  380    426   
  381    427   
    /// Set the timeout_config for the builder.
  382    428   
    ///
  383    429   
    /// Setting this to `None` has no effect if another source of configuration has set timeouts. If you
  384    430   
    /// are attempting to disable timeouts, use [`TimeoutConfig::disabled`](::aws_smithy_types::timeout::TimeoutConfig::disabled)
  385    431   
    ///
  386    432   
    ///
  387    433   
    /// # Examples
  388    434   
    ///
  389    435   
    /// ```no_run
  390    436   
    /// # use std::time::Duration;
  391    437   
    /// use pokemon_service_awsjson_client::config::{Builder, Config};
  392    438   
    /// use pokemon_service_awsjson_client::config::timeout::TimeoutConfig;
  393    439   
    ///
  394    440   
    /// fn set_request_timeout(builder: &mut Builder) {
  395    441   
    ///     let timeout_config = TimeoutConfig::builder()
  396    442   
    ///         .operation_attempt_timeout(Duration::from_secs(1))
  397    443   
    ///         .build();
  398    444   
    ///     builder.set_timeout_config(Some(timeout_config));
  399    445   
    /// }
  400    446   
    ///
  401    447   
    /// let mut builder = Config::builder();
  402    448   
    /// set_request_timeout(&mut builder);
  403    449   
    /// let config = builder.build();
  404    450   
    /// ```
         451  +
    /* ResiliencyConfigCustomization.kt:248 */
  405    452   
    pub fn set_timeout_config(&mut self, timeout_config: ::std::option::Option<::aws_smithy_types::timeout::TimeoutConfig>) -> &mut Self {
  406    453   
        // passing None has no impact.
  407    454   
        let Some(mut timeout_config) = timeout_config else { return self };
  408    455   
  409    456   
        if let Some(base) = self.config.load::<::aws_smithy_types::timeout::TimeoutConfig>() {
  410    457   
            timeout_config.take_defaults_from(base);
  411    458   
        }
  412    459   
        self.config.store_put(timeout_config);
  413    460   
        self
  414    461   
    }
         462  +
    /* ResiliencyConfigCustomization.kt:266 */
  415    463   
    /// Set the partition for retry-related state. When clients share a retry partition, they will
  416    464   
    /// also share things like token buckets and client rate limiters. By default, all clients
  417    465   
    /// for the same service will share a partition.
  418    466   
    pub fn retry_partition(mut self, retry_partition: ::aws_smithy_runtime::client::retries::RetryPartition) -> Self {
  419    467   
        self.set_retry_partition(Some(retry_partition));
  420    468   
        self
  421    469   
    }
         470  +
    /* ResiliencyConfigCustomization.kt:279 */
  422    471   
    /// Set the partition for retry-related state. When clients share a retry partition, they will
  423    472   
    /// also share things like token buckets and client rate limiters. By default, all clients
  424    473   
    /// for the same service will share a partition.
  425    474   
    pub fn set_retry_partition(
  426    475   
        &mut self,
  427    476   
        retry_partition: ::std::option::Option<::aws_smithy_runtime::client::retries::RetryPartition>,
  428    477   
    ) -> &mut Self {
  429    478   
        retry_partition.map(|r| self.config.store_put(r));
  430    479   
        self
  431    480   
    }
         481  +
    /* IdentityCacheDecorator.kt:77 */
  432    482   
    /// Set the identity cache for auth.
  433    483   
    ///
  434    484   
    /// The identity cache defaults to a lazy caching implementation that will resolve
  435    485   
    /// an identity when it is requested, and place it in the cache thereafter. Subsequent
  436    486   
    /// requests will take the value from the cache while it is still valid. Once it expires,
  437    487   
    /// the next request will result in refreshing the identity.
  438    488   
    ///
  439    489   
    /// This configuration allows you to disable or change the default caching mechanism.
  440    490   
    /// To use a custom caching mechanism, implement the [`ResolveCachedIdentity`](crate::config::ResolveCachedIdentity)
  441    491   
    /// trait and pass that implementation into this function.
@@ -493,543 +552,603 @@
  513    563   
    ///     )
  514    564   
    ///     // ...
  515    565   
    ///     .build();
  516    566   
    /// let client = pokemon_service_awsjson_client::Client::from_conf(config);
  517    567   
    /// ```
  518    568   
  519    569   
    pub fn set_identity_cache(&mut self, identity_cache: impl crate::config::ResolveCachedIdentity + 'static) -> &mut Self {
  520    570   
        self.runtime_components.set_identity_cache(::std::option::Option::Some(identity_cache));
  521    571   
        self
  522    572   
    }
         573  +
    /* InterceptorConfigCustomization.kt:41 */
  523    574   
    /// Add an [interceptor](crate::config::Intercept) that runs at specific stages of the request execution pipeline.
  524    575   
    ///
  525    576   
    /// Interceptors targeted at a certain stage are executed according to the pre-defined priority.
  526    577   
    /// The SDK provides a default set of interceptors. An interceptor configured by this method
  527    578   
    /// will run after those default interceptors.
  528    579   
    ///
  529    580   
    /// # Examples
  530    581   
    /// ```no_run
  531    582   
    /// # #[cfg(test)]
  532    583   
    /// # mod tests {
@@ -599,650 +670,724 @@
  619    670   
    pub fn push_interceptor(&mut self, interceptor: crate::config::SharedInterceptor) -> &mut Self {
  620    671   
        self.runtime_components.push_interceptor(interceptor);
  621    672   
        self
  622    673   
    }
  623    674   
  624    675   
    /// Set [`SharedInterceptor`](crate::config::SharedInterceptor)s for the builder.
  625    676   
    pub fn set_interceptors(&mut self, interceptors: impl IntoIterator<Item = crate::config::SharedInterceptor>) -> &mut Self {
  626    677   
        self.runtime_components.set_interceptors(interceptors.into_iter());
  627    678   
        self
  628    679   
    }
         680  +
    /* TimeSourceCustomization.kt:47 */
  629    681   
    /// Sets the time source used for this service
  630    682   
    pub fn time_source(mut self, time_source: impl ::aws_smithy_async::time::TimeSource + 'static) -> Self {
  631    683   
        self.set_time_source(::std::option::Option::Some(::aws_smithy_runtime_api::shared::IntoShared::into_shared(
  632    684   
            time_source,
  633    685   
        )));
  634    686   
        self
  635    687   
    }
         688  +
    /* TimeSourceCustomization.kt:61 */
  636    689   
    /// Sets the time source used for this service
  637    690   
    pub fn set_time_source(&mut self, time_source: ::std::option::Option<::aws_smithy_async::time::SharedTimeSource>) -> &mut Self {
  638    691   
        self.runtime_components.set_time_source(time_source);
  639    692   
        self
  640    693   
    }
         694  +
    /* RetryClassifierConfigCustomization.kt:50 */
  641    695   
    /// Add type implementing [`ClassifyRetry`](::aws_smithy_runtime_api::client::retries::classifiers::ClassifyRetry) that will be used by the
  642    696   
    /// [`RetryStrategy`](::aws_smithy_runtime_api::client::retries::RetryStrategy) to determine what responses should be retried.
  643    697   
    ///
  644    698   
    /// A retry classifier configured by this method will run according to its [priority](::aws_smithy_runtime_api::client::retries::classifiers::RetryClassifierPriority).
  645    699   
    ///
  646    700   
    /// # Examples
  647    701   
    /// ```no_run
  648    702   
    /// # #[cfg(test)]
  649    703   
    /// # mod tests {
  650    704   
    /// # #[test]
@@ -805,859 +864,919 @@
  825    879   
  826    880   
    /// Set [`SharedRetryClassifier`](::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier)s for the builder, replacing any that
  827    881   
    /// were previously set.
  828    882   
    pub fn set_retry_classifiers(
  829    883   
        &mut self,
  830    884   
        retry_classifiers: impl IntoIterator<Item = ::aws_smithy_runtime_api::client::retries::classifiers::SharedRetryClassifier>,
  831    885   
    ) -> &mut Self {
  832    886   
        self.runtime_components.set_retry_classifiers(retry_classifiers.into_iter());
  833    887   
        self
  834    888   
    }
         889  +
    /* ServiceConfigGenerator.kt:375 */
  835    890   
    /// Sets the [`behavior major version`](crate::config::BehaviorVersion).
  836    891   
    ///
  837    892   
    /// Over time, new best-practice behaviors are introduced. However, these behaviors might not be backwards
  838    893   
    /// compatible. For example, a change which introduces new default timeouts or a new retry-mode for
  839    894   
    /// all operations might be the ideal behavior but could break existing applications.
  840    895   
    ///
  841    896   
    /// # Examples
  842    897   
    ///
  843    898   
    /// Set the behavior major version to `latest`. This is equivalent to enabling the `behavior-version-latest` cargo feature.
  844    899   
    /// ```no_run
@@ -882,937 +1139,1238 @@
  902    957   
        self
  903    958   
    }
  904    959   
  905    960   
    /// Convenience method to set the latest behavior major version
  906    961   
    ///
  907    962   
    /// This is equivalent to enabling the `behavior-version-latest` Cargo feature
  908    963   
    pub fn behavior_version_latest(mut self) -> Self {
  909    964   
        self.set_behavior_version(Some(crate::config::BehaviorVersion::latest()));
  910    965   
        self
  911    966   
    }
  912         -
    /// Adds a runtime plugin to the config.
         967  +
    /// /* ServiceConfigGenerator.kt:509 */Adds a runtime plugin to the config.
         968  +
    /* ServiceConfigGenerator.kt:513 */
  913    969   
    pub fn runtime_plugin(mut self, plugin: impl crate::config::RuntimePlugin + 'static) -> Self {
  914    970   
        self.push_runtime_plugin(crate::config::SharedRuntimePlugin::new(plugin));
  915    971   
        self
  916    972   
    }
  917         -
    /// Adds a runtime plugin to the config.
         973  +
    /// /* ServiceConfigGenerator.kt:522 */Adds a runtime plugin to the config.
         974  +
    /* ServiceConfigGenerator.kt:526 */
  918    975   
    pub fn push_runtime_plugin(&mut self, plugin: crate::config::SharedRuntimePlugin) -> &mut Self {
  919    976   
        self.runtime_plugins.push(plugin);
  920    977   
        self
  921    978   
    }
         979  +
    /* RustType.kt:516 */
  922    980   
    #[cfg(any(feature = "test-util", test))]
         981  +
    /* RustType.kt:516 */
  923    982   
    #[allow(unused_mut)]
  924         -
    /// Apply test defaults to the builder
         983  +
    /// /* ServiceConfigGenerator.kt:541 */Apply test defaults to the builder
         984  +
    /* ServiceConfigGenerator.kt:542 */
  925    985   
    pub fn apply_test_defaults(&mut self) -> &mut Self {
         986  +
        /* TimeSourceCustomization.kt:88 */
  926    987   
        self.set_time_source(::std::option::Option::Some(::aws_smithy_async::time::SharedTimeSource::new(
  927    988   
            ::aws_smithy_async::time::StaticTimeSource::new(::std::time::UNIX_EPOCH + ::std::time::Duration::from_secs(1234567890)),
  928    989   
        )));
         990  +
        /* ServiceConfigGenerator.kt:544 */
  929    991   
        self.behavior_version = ::std::option::Option::Some(crate::config::BehaviorVersion::latest());
         992  +
        /* ServiceConfigGenerator.kt:545 */
  930    993   
        self
         994  +
        /* ServiceConfigGenerator.kt:542 */
  931    995   
    }
         996  +
    /* RustType.kt:516 */
  932    997   
    #[cfg(any(feature = "test-util", test))]
         998  +
    /* RustType.kt:516 */
  933    999   
    #[allow(unused_mut)]
  934         -
    /// Apply test defaults to the builder
        1000  +
    /// /* ServiceConfigGenerator.kt:550 */Apply test defaults to the builder
        1001  +
    /* ServiceConfigGenerator.kt:551 */
  935   1002   
    pub fn with_test_defaults(mut self) -> Self {
        1003  +
        /* ServiceConfigGenerator.kt:552 */
  936   1004   
        self.apply_test_defaults();
  937   1005   
        self
        1006  +
        /* ServiceConfigGenerator.kt:551 */
  938   1007   
    }
  939         -
    /// Builds a [`Config`].
        1008  +
    /// /* ServiceConfigGenerator.kt:555 */Builds a [`Config`].
        1009  +
    /* ServiceConfigGenerator.kt:556 */
  940   1010   
    #[allow(unused_mut)]
        1011  +
    /* ServiceConfigGenerator.kt:557 */
  941   1012   
    pub fn build(mut self) -> Config {
        1013  +
        /* ServiceConfigGenerator.kt:558 */
  942   1014   
        let mut layer = self.config;
        1015  +
        /* TimeSourceCustomization.kt:77 */
  943   1016   
        if self.runtime_components.time_source().is_none() {
  944   1017   
            self.runtime_components
  945   1018   
                .set_time_source(::std::option::Option::Some(::std::default::Default::default()));
  946   1019   
        }
        1020  +
        /* ServiceConfigGenerator.kt:567 */
  947   1021   
        Config {
        1022  +
            /* ServiceConfigGenerator.kt:568 */
  948   1023   
            config: crate::config::Layer::from(layer.clone())
  949   1024   
                .with_name("pokemon_service_awsjson_client::config::Config")
  950   1025   
                .freeze(),
  951   1026   
            cloneable: layer,
  952   1027   
            runtime_components: self.runtime_components,
  953   1028   
            runtime_plugins: self.runtime_plugins,
  954   1029   
            behavior_version: self.behavior_version,
        1030  +
            /* ServiceConfigGenerator.kt:567 */
  955   1031   
        }
        1032  +
        /* ServiceConfigGenerator.kt:557 */
  956   1033   
    }
        1034  +
    /* ServiceConfigGenerator.kt:492 */
  957   1035   
}
        1036  +
/* ServiceRuntimePluginGenerator.kt:116 */
  958   1037   
#[derive(::std::fmt::Debug)]
  959   1038   
pub(crate) struct ServiceRuntimePlugin {
  960   1039   
    config: ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer>,
  961   1040   
    runtime_components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
  962   1041   
}
  963   1042   
  964   1043   
impl ServiceRuntimePlugin {
  965   1044   
    pub fn new(_service_config: crate::config::Config) -> Self {
  966   1045   
        let config = {
  967   1046   
            let mut cfg = ::aws_smithy_types::config_bag::Layer::new("PokemonService");
  968   1047   
            cfg.store_put(::aws_smithy_runtime::client::orchestrator::AuthSchemeAndEndpointOrchestrationV2);
  969   1048   
            ::std::option::Option::Some(cfg.freeze())
  970   1049   
        };
  971   1050   
        let mut runtime_components = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("ServiceRuntimePlugin");
  972   1051   
        runtime_components.push_interceptor(::aws_smithy_runtime::client::http::connection_poisoning::ConnectionPoisoningInterceptor::new());
  973   1052   
        runtime_components.push_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::HttpStatusCodeClassifier::default());
  974   1053   
        runtime_components.push_interceptor(crate::sdk_feature_tracker::retry_mode::RetryModeFeatureTrackerInterceptor::new());
  975   1054   
        Self { config, runtime_components }
  976   1055   
    }
  977   1056   
}
  978   1057   
  979   1058   
impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ServiceRuntimePlugin {
  980   1059   
    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
  981   1060   
        self.config.clone()
  982   1061   
    }
  983   1062   
  984   1063   
    fn order(&self) -> ::aws_smithy_runtime_api::client::runtime_plugin::Order {
  985   1064   
        ::aws_smithy_runtime_api::client::runtime_plugin::Order::Defaults
  986   1065   
    }
  987   1066   
  988   1067   
    fn runtime_components(
  989   1068   
        &self,
  990   1069   
        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
  991   1070   
    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
  992   1071   
        ::std::borrow::Cow::Borrowed(&self.runtime_components)
  993   1072   
    }
  994   1073   
}
  995   1074   
  996   1075   
/// Cross-operation shared-state singletons
  997   1076   
        1077  +
/* ConfigOverrideRuntimePluginGenerator.kt:42 */
  998   1078   
/// A plugin that enables configuration for a single operation invocation
  999   1079   
///
 1000   1080   
/// The `config` method will return a `FrozenLayer` by storing values from `config_override`.
 1001   1081   
/// In the case of default values requested, they will be obtained from `client_config`.
 1002   1082   
#[derive(Debug)]
 1003   1083   
pub(crate) struct ConfigOverrideRuntimePlugin {
 1004   1084   
    pub(crate) config: ::aws_smithy_types::config_bag::FrozenLayer,
 1005   1085   
    pub(crate) components: ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
 1006   1086   
}
 1007   1087   
 1008   1088   
impl ConfigOverrideRuntimePlugin {
 1009   1089   
    #[allow(dead_code)] // unused when a service does not provide any operations
 1010   1090   
    pub(crate) fn new(
 1011   1091   
        config_override: Builder,
 1012   1092   
        initial_config: ::aws_smithy_types::config_bag::FrozenLayer,
 1013   1093   
        initial_components: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
 1014   1094   
    ) -> Self {
 1015   1095   
        let mut layer = config_override.config;
 1016   1096   
        let mut components = config_override.runtime_components;
 1017   1097   
        #[allow(unused_mut)]
 1018   1098   
        let mut resolver =
 1019   1099   
            ::aws_smithy_runtime::client::config_override::Resolver::overrid(initial_config, initial_components, &mut layer, &mut components);
 1020   1100   
 1021   1101   
        let _ = resolver;
 1022   1102   
        Self {
 1023   1103   
            config: ::aws_smithy_types::config_bag::Layer::from(layer)
 1024   1104   
                .with_name("pokemon_service_awsjson_client::config::ConfigOverrideRuntimePlugin")
 1025   1105   
                .freeze(),
 1026   1106   
            components,
 1027   1107   
        }
 1028   1108   
    }
 1029   1109   
}
 1030   1110   
 1031   1111   
impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for ConfigOverrideRuntimePlugin {
 1032   1112   
    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
 1033   1113   
        Some(self.config.clone())
 1034   1114   
    }
 1035   1115   
 1036   1116   
    fn runtime_components(
 1037   1117   
        &self,
 1038   1118   
        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
 1039   1119   
    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
 1040   1120   
        ::std::borrow::Cow::Borrowed(&self.components)
 1041   1121   
    }
 1042   1122   
}
 1043   1123   
        1124  +
/* ClientRuntimeTypesReExportGenerator.kt:24 */
 1044   1125   
pub use ::aws_smithy_runtime::client::identity::IdentityCache;
 1045   1126   
pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponents;
 1046   1127   
pub use ::aws_smithy_types::config_bag::ConfigBag;
 1047   1128   
        1129  +
/* ResiliencyConfigCustomization.kt:318 */
 1048   1130   
pub use ::aws_smithy_async::rt::sleep::Sleep;
 1049   1131   
        1132  +
/* FluentClientGenerator.kt:261 */
 1050   1133   
pub(crate) fn base_client_runtime_plugins(mut config: crate::Config) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
 1051   1134   
    let mut configured_plugins = ::std::vec::Vec::new();
 1052   1135   
    ::std::mem::swap(&mut config.runtime_plugins, &mut configured_plugins);
 1053   1136   
    #[cfg(feature = "behavior-version-latest")]
 1054   1137   
    {
 1055   1138   
        if config.behavior_version.is_none() {
 1056   1139   
            config.behavior_version = Some(::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion::latest());
 1057   1140   
        }
 1058   1141   
    }
 1059   1142   
 1060   1143   
    let default_retry_partition = "pokemonservice";
 1061   1144   
 1062   1145   
    let scope = "pokemon-service-awsjson-client";
 1063   1146   
 1064   1147   
    let mut plugins = ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins::new()
 1065   1148   
                        // defaults
 1066   1149   
                        .with_client_plugins(::aws_smithy_runtime::client::defaults::default_plugins(
 1067   1150   
                            ::aws_smithy_runtime::client::defaults::DefaultPluginParams::new()
 1068   1151   
                                .with_retry_partition_name(default_retry_partition)
 1069   1152   
                                .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."))
 1070   1153   
                        ))
 1071   1154   
                        // user config
 1072   1155   
                        .with_client_plugin(
 1073   1156   
                            ::aws_smithy_runtime_api::client::runtime_plugin::StaticRuntimePlugin::new()
 1074   1157   
                                .with_config(config.config.clone())
 1075   1158   
                                .with_runtime_components(config.runtime_components.clone())
 1076   1159   
                        )
 1077   1160   
                        // codegen config
 1078   1161   
                        .with_client_plugin(crate::config::ServiceRuntimePlugin::new(config.clone()))
 1079   1162   
                        .with_client_plugin(::aws_smithy_runtime::client::auth::no_auth::NoAuthRuntimePlugin::new())
 1080   1163   
                        .with_client_plugin(
 1081   1164   
                            ::aws_smithy_runtime::client::metrics::MetricsRuntimePlugin::builder()
 1082   1165   
                                .with_scope(scope)
 1083   1166   
                                .with_time_source(config.runtime_components.time_source().unwrap_or_default())
 1084   1167   
                                .build()
 1085   1168   
                                .expect("All required fields have been set")
 1086   1169   
                        );
 1087   1170   
 1088   1171   
    for plugin in configured_plugins {
 1089   1172   
        plugins = plugins.with_client_plugin(plugin);
 1090   1173   
    }
 1091   1174   
    plugins
 1092   1175   
}
 1093   1176   
        1177  +
/* ClientReExports.kt:17 */
 1094   1178   
pub use ::aws_smithy_types::config_bag::FrozenLayer;
 1095   1179   
        1180  +
/* ClientReExports.kt:17 */
 1096   1181   
pub use ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder;
 1097   1182   
        1183  +
/* ClientReExports.kt:17 */
 1098   1184   
pub use ::aws_smithy_runtime_api::client::runtime_plugin::SharedRuntimePlugin;
 1099   1185   
        1186  +
/* ClientReExports.kt:17 */
 1100   1187   
pub use ::aws_smithy_runtime_api::client::behavior_version::BehaviorVersion;
 1101   1188   
        1189  +
/* ClientReExports.kt:17 */
 1102   1190   
pub use ::aws_smithy_runtime_api::client::stalled_stream_protection::StalledStreamProtectionConfig;
 1103   1191   
        1192  +
/* ClientReExports.kt:17 */
 1104   1193   
pub use ::aws_smithy_runtime_api::client::http::SharedHttpClient;
 1105   1194   
        1195  +
/* ClientReExports.kt:17 */
 1106   1196   
pub use ::aws_smithy_async::rt::sleep::SharedAsyncSleep;
 1107   1197   
        1198  +
/* ClientReExports.kt:17 */
 1108   1199   
pub use ::aws_smithy_runtime_api::client::identity::SharedIdentityCache;
 1109   1200   
        1201  +
/* ClientReExports.kt:17 */
 1110   1202   
pub use ::aws_smithy_runtime_api::client::interceptors::SharedInterceptor;
 1111   1203   
        1204  +
/* ClientReExports.kt:17 */
 1112   1205   
pub use ::aws_smithy_runtime_api::client::http::HttpClient;
 1113   1206   
        1207  +
/* ClientReExports.kt:17 */
 1114   1208   
pub use ::aws_smithy_runtime_api::shared::IntoShared;
 1115   1209   
        1210  +
/* ClientReExports.kt:17 */
 1116   1211   
pub use ::aws_smithy_async::rt::sleep::AsyncSleep;
 1117   1212   
        1213  +
/* ClientReExports.kt:17 */
 1118   1214   
pub use ::aws_smithy_runtime_api::client::identity::ResolveCachedIdentity;
 1119   1215   
        1216  +
/* ClientReExports.kt:17 */
 1120   1217   
pub use ::aws_smithy_runtime_api::client::interceptors::Intercept;
 1121   1218   
        1219  +
/* ClientReExports.kt:17 */
 1122   1220   
pub use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
 1123   1221   
        1222  +
/* ClientReExports.kt:17 */
 1124   1223   
pub use ::aws_smithy_types::config_bag::Layer;
 1125   1224   
 1126         -
/// Types needed to configure endpoint resolution.
        1225  +
/// /* ClientRustModule.kt:121 */Types needed to configure endpoint resolution.
 1127   1226   
pub mod endpoint;
 1128   1227   
 1129         -
/// HTTP request and response types.
        1228  +
/// /* ClientRustModule.kt:121 */HTTP request and response types.
 1130   1229   
pub mod http;
 1131   1230   
 1132         -
/// Types needed to implement [`Intercept`](crate::config::Intercept).
        1231  +
/// /* ClientRustModule.kt:121 */Types needed to implement [`Intercept`](crate::config::Intercept).
 1133   1232   
pub mod interceptors;
 1134   1233   
 1135         -
/// Retry configuration.
        1234  +
/// /* ClientRustModule.kt:121 */Retry configuration.
 1136   1235   
pub mod retry;
 1137   1236   
 1138         -
/// Timeout configuration.
        1237  +
/// /* ClientRustModule.kt:121 */Timeout configuration.
 1139   1238   
pub mod timeout;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/endpoint.rs

@@ -1,1 +86,107 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* ClientRuntimeTypesReExportGenerator.kt:38 */
    2      3   
pub use ::aws_smithy_runtime_api::client::endpoint::EndpointFuture;
    3      4   
pub use ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver;
    4      5   
pub use ::aws_smithy_types::endpoint::Endpoint;
    5      6   
           7  +
/* RustType.kt:516 */
    6      8   
#[cfg(test)]
    7         -
mod test {}
           9  +
/* EndpointsDecorator.kt:175 */
          10  +
mod test {
    8     11   
          12  +
    /* EndpointsDecorator.kt:175 */
          13  +
}
          14  +
          15  +
/* EndpointResolverGenerator.kt:416 */
    9     16   
/// Endpoint resolver trait specific to Pokémon Service
   10     17   
pub trait ResolveEndpoint: ::std::marker::Send + ::std::marker::Sync + ::std::fmt::Debug {
   11     18   
    /// Resolve an endpoint with the given parameters
   12     19   
    fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a>;
   13     20   
   14     21   
    /// Convert this service-specific resolver into a `SharedEndpointResolver`
   15     22   
    ///
   16     23   
    /// The resulting resolver will downcast `EndpointResolverParams` into `crate::config::endpoint::Params`.
   17     24   
    fn into_shared_resolver(self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver
   18     25   
    where
   19     26   
        Self: Sized + 'static,
   20     27   
    {
   21     28   
        ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver::new(DowncastParams(self))
   22     29   
    }
   23     30   
}
   24     31   
   25     32   
#[derive(Debug)]
   26     33   
struct DowncastParams<T>(T);
   27     34   
impl<T> ::aws_smithy_runtime_api::client::endpoint::ResolveEndpoint for DowncastParams<T>
   28     35   
where
   29     36   
    T: ResolveEndpoint,
   30     37   
{
   31     38   
    fn resolve_endpoint<'a>(
   32     39   
        &'a self,
   33     40   
        params: &'a ::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams,
   34     41   
    ) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
   35     42   
        let ep = match params.get::<crate::config::endpoint::Params>() {
   36     43   
            Some(params) => self.0.resolve_endpoint(params),
   37     44   
            None => ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(Err("params of expected type was not present".into())),
   38     45   
        };
   39     46   
        ep
   40     47   
    }
   41     48   
}
   42     49   
          50  +
/* RustType.kt:516 */
   43     51   
#[non_exhaustive]
          52  +
/* RustType.kt:516 */
   44     53   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
   45         -
/// Configuration parameters for resolving the correct endpoint
   46         -
pub struct Params {}
          54  +
/// /* EndpointParamsGenerator.kt:178 */Configuration parameters for resolving the correct endpoint
          55  +
/* EndpointParamsGenerator.kt:179 */
          56  +
pub struct Params {/* EndpointParamsGenerator.kt:179 */}
          57  +
/* EndpointParamsGenerator.kt:188 */
   47     58   
impl Params {
          59  +
    /* EndpointParamsGenerator.kt:189 */
   48     60   
    /// Create a builder for [`Params`]
   49     61   
    pub fn builder() -> crate::config::endpoint::ParamsBuilder {
   50     62   
        crate::config::endpoint::ParamsBuilder::default()
   51     63   
    }
          64  +
    /* EndpointParamsGenerator.kt:188 */
   52     65   
}
   53     66   
   54         -
/// Builder for [`Params`]
          67  +
/// /* EndpointParamsGenerator.kt:234 */Builder for [`Params`]
          68  +
/* RustType.kt:516 */
   55     69   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
   56         -
pub struct ParamsBuilder {}
          70  +
/* EndpointParamsGenerator.kt:238 */
          71  +
pub struct ParamsBuilder {/* EndpointParamsGenerator.kt:238 */}
          72  +
/* EndpointParamsGenerator.kt:246 */
   57     73   
impl ParamsBuilder {
   58         -
    /// Consume this builder, creating [`Params`].
          74  +
    /// /* EndpointParamsGenerator.kt:247 */Consume this builder, creating [`Params`].
          75  +
    /* EndpointParamsGenerator.kt:248 */
   59     76   
    pub fn build(self) -> ::std::result::Result<crate::config::endpoint::Params, crate::config::endpoint::InvalidParams> {
          77  +
        /* EndpointParamsGenerator.kt:272 */
   60     78   
        Ok(
   61     79   
            #[allow(clippy::unnecessary_lazy_evaluations)]
   62     80   
            crate::config::endpoint::Params {},
   63     81   
        )
          82  +
        /* EndpointParamsGenerator.kt:248 */
   64     83   
    }
          84  +
    /* EndpointParamsGenerator.kt:246 */
   65     85   
}
   66     86   
          87  +
/* EndpointParamsGenerator.kt:139 */
   67     88   
/// An error that occurred during endpoint resolution
   68     89   
#[derive(Debug)]
   69     90   
pub struct InvalidParams {
   70     91   
    field: std::borrow::Cow<'static, str>,
   71     92   
}
   72     93   
   73     94   
impl InvalidParams {
   74     95   
    #[allow(dead_code)]
   75     96   
    fn missing(field: &'static str) -> Self {
   76     97   
        Self { field: field.into() }

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/http.rs

@@ -1,1 +3,4 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* ClientRuntimeTypesReExportGenerator.kt:60 */
    2      3   
pub use ::aws_smithy_runtime_api::client::orchestrator::HttpRequest;
    3      4   
pub use ::aws_smithy_runtime_api::client::orchestrator::HttpResponse;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/interceptors.rs

@@ -1,1 +11,12 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* ClientRuntimeTypesReExportGenerator.kt:70 */
    2      3   
pub use ::aws_smithy_runtime_api::client::interceptors::context::AfterDeserializationInterceptorContextRef;
    3      4   
pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeDeserializationInterceptorContextMut;
    4      5   
pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeDeserializationInterceptorContextRef;
    5      6   
pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextMut;
    6      7   
pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef;
    7      8   
pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeTransmitInterceptorContextMut;
    8      9   
pub use ::aws_smithy_runtime_api::client::interceptors::context::BeforeTransmitInterceptorContextRef;
    9     10   
pub use ::aws_smithy_runtime_api::client::interceptors::context::FinalizerInterceptorContextMut;
   10     11   
pub use ::aws_smithy_runtime_api::client::interceptors::context::FinalizerInterceptorContextRef;
   11     12   
pub use ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext;

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/retry.rs

@@ -1,1 +7,9 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* ClientRuntimeTypesReExportGenerator.kt:48 */
    2      3   
pub use ::aws_smithy_runtime_api::client::retries::classifiers::ClassifyRetry;
    3      4   
pub use ::aws_smithy_runtime_api::client::retries::classifiers::RetryAction;
    4      5   
pub use ::aws_smithy_runtime_api::client::retries::ShouldAttempt;
    5      6   
    6         -
pub use ::aws_smithy_runtime::client::retries::RetryPartition;
           7  +
/* ResiliencyConfigCustomization.kt:324 */
           8  +
/* ResiliencyConfigCustomization.kt:329 */ pub use ::aws_smithy_runtime::client::retries::RetryPartition;
    7      9   
pub use ::aws_smithy_types::retry::{ReconnectMode, RetryConfig, RetryConfigBuilder, RetryMode};

tmp-codegen-diff/codegen-client-test/pokemon-service-awsjson-client/rust-client-codegen/src/config/timeout.rs

@@ -1,1 +2,3 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* ResiliencyConfigCustomization.kt:335 */
    2      3   
pub use ::aws_smithy_types::timeout::{TimeoutConfig, TimeoutConfigBuilder};