Client Test

Client Test

rev. dfb5149b65b7bcc09edd15b8e071ad43b5ac5943 (ignoring whitespace)

Files changed:

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/describe_time_to_live/_describe_time_to_live_input.rs

@@ -1,1 +51,90 @@
    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 DescribeTimeToLiveInput {
    6         -
    /// <p>The name of the table to be described.</p>
           8  +
pub /* StructureGenerator.kt:201 */ struct DescribeTimeToLiveInput {
           9  +
    /// /* StructureGenerator.kt:231 */<p>The name of the table to be described.</p>
    7     10   
    pub table_name: ::std::option::Option<::std::string::String>,
          11  +
    /* StructureGenerator.kt:201 */
    8     12   
}
          13  +
/* StructureGenerator.kt:135 */
    9     14   
impl DescribeTimeToLiveInput {
   10         -
    /// <p>The name of the table to be described.</p>
          15  +
    /// /* StructureGenerator.kt:231 */<p>The name of the table to be described.</p>
          16  +
    /* StructureGenerator.kt:166 */
   11     17   
    pub fn table_name(&self) -> ::std::option::Option<&str> {
          18  +
        /* StructureGenerator.kt:169 */
   12     19   
        self.table_name.as_deref()
          20  +
        /* StructureGenerator.kt:166 */
   13     21   
    }
          22  +
    /* StructureGenerator.kt:135 */
   14     23   
}
          24  +
/* ClientCodegenVisitor.kt:237 */
   15     25   
impl DescribeTimeToLiveInput {
   16         -
    /// Creates a new builder-style object to manufacture [`DescribeTimeToLiveInput`](crate::operation::describe_time_to_live::DescribeTimeToLiveInput).
          26  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DescribeTimeToLiveInput`](crate::operation::describe_time_to_live::DescribeTimeToLiveInput).
          27  +
    /* BuilderGenerator.kt:175 */
   17     28   
    pub fn builder() -> crate::operation::describe_time_to_live::builders::DescribeTimeToLiveInputBuilder {
          29  +
        /* BuilderGenerator.kt:176 */
   18     30   
        crate::operation::describe_time_to_live::builders::DescribeTimeToLiveInputBuilder::default()
          31  +
        /* BuilderGenerator.kt:175 */
   19     32   
    }
          33  +
    /* ClientCodegenVisitor.kt:237 */
   20     34   
}
   21     35   
   22         -
/// A builder for [`DescribeTimeToLiveInput`](crate::operation::describe_time_to_live::DescribeTimeToLiveInput).
          36  +
/// /* BuilderGenerator.kt:342 */A builder for [`DescribeTimeToLiveInput`](crate::operation::describe_time_to_live::DescribeTimeToLiveInput).
          37  +
/* RustType.kt:516 */
   23     38   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          39  +
/* RustType.kt:516 */
   24     40   
#[non_exhaustive]
          41  +
/* BuilderGenerator.kt:345 */
   25     42   
pub struct DescribeTimeToLiveInputBuilder {
   26         -
    pub(crate) table_name: ::std::option::Option<::std::string::String>,
          43  +
    /* BuilderGenerator.kt:275 */ pub(crate) table_name: ::std::option::Option<::std::string::String>,
          44  +
    /* BuilderGenerator.kt:345 */
   27     45   
}
          46  +
/* BuilderGenerator.kt:355 */
   28     47   
impl DescribeTimeToLiveInputBuilder {
   29         -
    /// <p>The name of the table to be described.</p>
   30         -
    /// This field is required.
          48  +
    /// /* BuilderGenerator.kt:286 */<p>The name of the table to be described.</p>
          49  +
    /// /* BuilderGenerator.kt:288 */This field is required.
          50  +
    /* BuilderGenerator.kt:291 */
   31     51   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          52  +
        /* BuilderGenerator.kt:292 */
   32     53   
        self.table_name = ::std::option::Option::Some(input.into());
          54  +
        /* BuilderGenerator.kt:293 */
   33     55   
        self
          56  +
        /* BuilderGenerator.kt:291 */
   34     57   
    }
   35         -
    /// <p>The name of the table to be described.</p>
          58  +
    /// /* BuilderGenerator.kt:312 */<p>The name of the table to be described.</p>
          59  +
    /* BuilderGenerator.kt:314 */
   36     60   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          61  +
        /* BuilderGenerator.kt:315 */
   37     62   
        self.table_name = input;
   38     63   
        self
          64  +
        /* BuilderGenerator.kt:314 */
   39     65   
    }
   40         -
    /// <p>The name of the table to be described.</p>
          66  +
    /// /* BuilderGenerator.kt:334 */<p>The name of the table to be described.</p>
          67  +
    /* BuilderGenerator.kt:336 */
   41     68   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
          69  +
        /* BuilderGenerator.kt:337 */
   42     70   
        &self.table_name
          71  +
        /* BuilderGenerator.kt:336 */
   43     72   
    }
   44         -
    /// Consumes the builder and constructs a [`DescribeTimeToLiveInput`](crate::operation::describe_time_to_live::DescribeTimeToLiveInput).
          73  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DescribeTimeToLiveInput`](crate::operation::describe_time_to_live::DescribeTimeToLiveInput).
          74  +
    /* BuilderGenerator.kt:253 */
   45     75   
    pub fn build(
   46     76   
        self,
   47     77   
    ) -> ::std::result::Result<crate::operation::describe_time_to_live::DescribeTimeToLiveInput, ::aws_smithy_types::error::operation::BuildError>
   48     78   
    {
   49         -
        ::std::result::Result::Ok(crate::operation::describe_time_to_live::DescribeTimeToLiveInput { table_name: self.table_name })
          79  +
        /* BuilderGenerator.kt:254 */
          80  +
        ::std::result::Result::Ok(
          81  +
            /* BuilderGenerator.kt:477 */
          82  +
            crate::operation::describe_time_to_live::DescribeTimeToLiveInput {
          83  +
                /* BuilderGenerator.kt:481 */ table_name: self.table_name,
          84  +
                /* BuilderGenerator.kt:477 */
          85  +
            }, /* BuilderGenerator.kt:254 */
          86  +
        )
          87  +
        /* BuilderGenerator.kt:253 */
   50     88   
    }
          89  +
    /* BuilderGenerator.kt:355 */
   51     90   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/describe_time_to_live/_describe_time_to_live_output.rs

@@ -1,1 +49,84 @@
    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 DescribeTimeToLiveOutput {
    6         -
    /// <p></p>
           8  +
pub /* StructureGenerator.kt:201 */ struct DescribeTimeToLiveOutput {
           9  +
    /// /* StructureGenerator.kt:231 */<p></p>
    7     10   
    pub time_to_live_description: ::std::option::Option<crate::types::TimeToLiveDescription>,
          11  +
    /* StructureGenerator.kt:201 */
    8     12   
}
          13  +
/* StructureGenerator.kt:135 */
    9     14   
impl DescribeTimeToLiveOutput {
   10         -
    /// <p></p>
          15  +
    /// /* StructureGenerator.kt:231 */<p></p>
          16  +
    /* StructureGenerator.kt:166 */
   11     17   
    pub fn time_to_live_description(&self) -> ::std::option::Option<&crate::types::TimeToLiveDescription> {
          18  +
        /* StructureGenerator.kt:170 */
   12     19   
        self.time_to_live_description.as_ref()
          20  +
        /* StructureGenerator.kt:166 */
   13     21   
    }
          22  +
    /* StructureGenerator.kt:135 */
   14     23   
}
          24  +
/* ClientCodegenVisitor.kt:237 */
   15     25   
impl DescribeTimeToLiveOutput {
   16         -
    /// Creates a new builder-style object to manufacture [`DescribeTimeToLiveOutput`](crate::operation::describe_time_to_live::DescribeTimeToLiveOutput).
          26  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DescribeTimeToLiveOutput`](crate::operation::describe_time_to_live::DescribeTimeToLiveOutput).
          27  +
    /* BuilderGenerator.kt:175 */
   17     28   
    pub fn builder() -> crate::operation::describe_time_to_live::builders::DescribeTimeToLiveOutputBuilder {
          29  +
        /* BuilderGenerator.kt:176 */
   18     30   
        crate::operation::describe_time_to_live::builders::DescribeTimeToLiveOutputBuilder::default()
          31  +
        /* BuilderGenerator.kt:175 */
   19     32   
    }
          33  +
    /* ClientCodegenVisitor.kt:237 */
   20     34   
}
   21     35   
   22         -
/// A builder for [`DescribeTimeToLiveOutput`](crate::operation::describe_time_to_live::DescribeTimeToLiveOutput).
          36  +
/// /* BuilderGenerator.kt:342 */A builder for [`DescribeTimeToLiveOutput`](crate::operation::describe_time_to_live::DescribeTimeToLiveOutput).
          37  +
/* RustType.kt:516 */
   23     38   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          39  +
/* RustType.kt:516 */
   24     40   
#[non_exhaustive]
          41  +
/* BuilderGenerator.kt:345 */
   25     42   
pub struct DescribeTimeToLiveOutputBuilder {
          43  +
    /* BuilderGenerator.kt:275 */
   26     44   
    pub(crate) time_to_live_description: ::std::option::Option<crate::types::TimeToLiveDescription>,
          45  +
    /* BuilderGenerator.kt:345 */
   27     46   
}
          47  +
/* BuilderGenerator.kt:355 */
   28     48   
impl DescribeTimeToLiveOutputBuilder {
   29         -
    /// <p></p>
          49  +
    /// /* BuilderGenerator.kt:286 */<p></p>
          50  +
    /* BuilderGenerator.kt:291 */
   30     51   
    pub fn time_to_live_description(mut self, input: crate::types::TimeToLiveDescription) -> Self {
          52  +
        /* BuilderGenerator.kt:292 */
   31     53   
        self.time_to_live_description = ::std::option::Option::Some(input);
          54  +
        /* BuilderGenerator.kt:293 */
   32     55   
        self
          56  +
        /* BuilderGenerator.kt:291 */
   33     57   
    }
   34         -
    /// <p></p>
          58  +
    /// /* BuilderGenerator.kt:312 */<p></p>
          59  +
    /* BuilderGenerator.kt:314 */
   35     60   
    pub fn set_time_to_live_description(mut self, input: ::std::option::Option<crate::types::TimeToLiveDescription>) -> Self {
          61  +
        /* BuilderGenerator.kt:315 */
   36     62   
        self.time_to_live_description = input;
   37     63   
        self
          64  +
        /* BuilderGenerator.kt:314 */
   38     65   
    }
   39         -
    /// <p></p>
          66  +
    /// /* BuilderGenerator.kt:334 */<p></p>
          67  +
    /* BuilderGenerator.kt:336 */
   40     68   
    pub fn get_time_to_live_description(&self) -> &::std::option::Option<crate::types::TimeToLiveDescription> {
          69  +
        /* BuilderGenerator.kt:337 */
   41     70   
        &self.time_to_live_description
          71  +
        /* BuilderGenerator.kt:336 */
   42     72   
    }
   43         -
    /// Consumes the builder and constructs a [`DescribeTimeToLiveOutput`](crate::operation::describe_time_to_live::DescribeTimeToLiveOutput).
          73  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DescribeTimeToLiveOutput`](crate::operation::describe_time_to_live::DescribeTimeToLiveOutput).
          74  +
    /* BuilderGenerator.kt:253 */
   44     75   
    pub fn build(self) -> crate::operation::describe_time_to_live::DescribeTimeToLiveOutput {
          76  +
        /* BuilderGenerator.kt:477 */
   45     77   
        crate::operation::describe_time_to_live::DescribeTimeToLiveOutput {
   46         -
            time_to_live_description: self.time_to_live_description,
          78  +
            /* BuilderGenerator.kt:481 */ time_to_live_description: self.time_to_live_description,
          79  +
            /* BuilderGenerator.kt:477 */
   47     80   
        }
          81  +
        /* BuilderGenerator.kt:253 */
   48     82   
    }
          83  +
    /* BuilderGenerator.kt:355 */
   49     84   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/describe_time_to_live/builders.rs

@@ -1,1 +125,140 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* CodegenDelegator.kt:255 */
    2      3   
pub use crate::operation::describe_time_to_live::_describe_time_to_live_output::DescribeTimeToLiveOutputBuilder;
    3      4   
           5  +
/* CodegenDelegator.kt:255 */
    4      6   
pub use crate::operation::describe_time_to_live::_describe_time_to_live_input::DescribeTimeToLiveInputBuilder;
    5      7   
           8  +
/* FluentBuilderGenerator.kt:408 */
    6      9   
impl crate::operation::describe_time_to_live::builders::DescribeTimeToLiveInputBuilder {
    7     10   
    /// Sends a request with this input using the given client.
    8     11   
    pub async fn send_with(
    9     12   
        self,
   10     13   
        client: &crate::Client,
   11     14   
    ) -> ::std::result::Result<
   12     15   
        crate::operation::describe_time_to_live::DescribeTimeToLiveOutput,
   13     16   
        ::aws_smithy_runtime_api::client::result::SdkError<
   14     17   
            crate::operation::describe_time_to_live::DescribeTimeToLiveError,
   15     18   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   16     19   
        >,
   17     20   
    > {
   18     21   
        let mut fluent_builder = client.describe_time_to_live();
   19     22   
        fluent_builder.inner = self;
   20     23   
        fluent_builder.send().await
   21     24   
    }
   22     25   
}
   23         -
/// Fluent builder constructing a request to `DescribeTimeToLive`.
          26  +
/// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `DescribeTimeToLive`.
   24     27   
///
   25         -
/// <p>Gives a description of the Time to Live (TTL) status on the specified table.</p>
          28  +
/// /* FluentBuilderGenerator.kt:130 */<p>Gives a description of the Time to Live (TTL) status on the specified table.</p>
          29  +
/* RustType.kt:516 */
   26     30   
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
          31  +
/* FluentBuilderGenerator.kt:270 */
   27     32   
pub struct DescribeTimeToLiveFluentBuilder {
   28     33   
    handle: ::std::sync::Arc<crate::client::Handle>,
   29     34   
    inner: crate::operation::describe_time_to_live::builders::DescribeTimeToLiveInputBuilder,
   30     35   
    config_override: ::std::option::Option<crate::config::Builder>,
   31     36   
}
          37  +
/* FluentBuilderGenerator.kt:381 */
   32     38   
impl
   33     39   
    crate::client::customize::internal::CustomizableSend<
   34     40   
        crate::operation::describe_time_to_live::DescribeTimeToLiveOutput,
   35     41   
        crate::operation::describe_time_to_live::DescribeTimeToLiveError,
   36     42   
    > for DescribeTimeToLiveFluentBuilder
   37     43   
{
   38     44   
    fn send(
   39     45   
        self,
   40     46   
        config_override: crate::config::Builder,
   41     47   
    ) -> crate::client::customize::internal::BoxFuture<
   42     48   
        crate::client::customize::internal::SendResult<
   43     49   
            crate::operation::describe_time_to_live::DescribeTimeToLiveOutput,
   44     50   
            crate::operation::describe_time_to_live::DescribeTimeToLiveError,
   45     51   
        >,
   46     52   
    > {
   47     53   
        ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
   48     54   
    }
   49     55   
}
          56  +
/* FluentBuilderGenerator.kt:282 */
   50     57   
impl DescribeTimeToLiveFluentBuilder {
          58  +
    /* FluentBuilderGenerator.kt:288 */
   51     59   
    /// Creates a new `DescribeTimeToLiveFluentBuilder`.
   52     60   
    pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
   53     61   
        Self {
   54     62   
            handle,
   55     63   
            inner: ::std::default::Default::default(),
   56     64   
            config_override: ::std::option::Option::None,
   57     65   
        }
   58     66   
    }
          67  +
    /* FluentBuilderGenerator.kt:301 */
   59     68   
    /// Access the DescribeTimeToLive as a reference.
   60     69   
    pub fn as_input(&self) -> &crate::operation::describe_time_to_live::builders::DescribeTimeToLiveInputBuilder {
   61     70   
        &self.inner
   62     71   
    }
          72  +
    /* FluentBuilderGenerator.kt:145 */
   63     73   
    /// Sends the request and returns the response.
   64     74   
    ///
   65     75   
    /// If an error occurs, an `SdkError` will be returned with additional details that
   66     76   
    /// can be matched against.
   67     77   
    ///
   68     78   
    /// By default, any retryable failures will be retried twice. Retry behavior
   69     79   
    /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
   70     80   
    /// set when configuring the client.
   71     81   
    pub async fn send(
   72     82   
        self,
   73     83   
    ) -> ::std::result::Result<
   74     84   
        crate::operation::describe_time_to_live::DescribeTimeToLiveOutput,
   75     85   
        ::aws_smithy_runtime_api::client::result::SdkError<
   76     86   
            crate::operation::describe_time_to_live::DescribeTimeToLiveError,
   77     87   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   78     88   
        >,
   79     89   
    > {
   80     90   
        let input = self
   81     91   
            .inner
   82     92   
            .build()
   83     93   
            .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
   84     94   
        let runtime_plugins = crate::operation::describe_time_to_live::DescribeTimeToLive::operation_runtime_plugins(
   85     95   
            self.handle.runtime_plugins.clone(),
   86     96   
            &self.handle.conf,
   87     97   
            self.config_override,
   88     98   
        );
   89     99   
        crate::operation::describe_time_to_live::DescribeTimeToLive::orchestrate(&runtime_plugins, input).await
   90    100   
    }
   91    101   
   92    102   
    /// Consumes this builder, creating a customizable operation that can be modified before being sent.
   93    103   
    pub fn customize(
   94    104   
        self,
   95    105   
    ) -> crate::client::customize::CustomizableOperation<
   96    106   
        crate::operation::describe_time_to_live::DescribeTimeToLiveOutput,
   97    107   
        crate::operation::describe_time_to_live::DescribeTimeToLiveError,
   98    108   
        Self,
   99    109   
    > {
  100    110   
        crate::client::customize::CustomizableOperation::new(self)
  101    111   
    }
         112  +
    /* FluentBuilderGenerator.kt:315 */
  102    113   
    pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
  103    114   
        self.set_config_override(::std::option::Option::Some(config_override.into()));
  104    115   
        self
  105    116   
    }
  106    117   
  107    118   
    pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
  108    119   
        self.config_override = config_override;
  109    120   
        self
  110    121   
    }
  111         -
    /// <p>The name of the table to be described.</p>
         122  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The name of the table to be described.</p>
         123  +
    /* FluentBuilderGenerator.kt:500 */
  112    124   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
  113    125   
        self.inner = self.inner.table_name(input.into());
  114    126   
        self
  115    127   
    }
  116         -
    /// <p>The name of the table to be described.</p>
         128  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The name of the table to be described.</p>
         129  +
    /* FluentBuilderGenerator.kt:500 */
  117    130   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
  118    131   
        self.inner = self.inner.set_table_name(input);
  119    132   
        self
  120    133   
    }
  121         -
    /// <p>The name of the table to be described.</p>
         134  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The name of the table to be described.</p>
         135  +
    /* FluentBuilderGenerator.kt:520 */
  122    136   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
  123    137   
        self.inner.get_table_name()
  124    138   
    }
         139  +
    /* FluentBuilderGenerator.kt:282 */
  125    140   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/disable_kinesis_streaming_destination.rs

@@ -1,1 +40,49 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* OperationGenerator.kt:77 */
    2      3   
/// Orchestration and serialization glue logic for `DisableKinesisStreamingDestination`.
           4  +
/* RustType.kt:516 */
    3      5   
#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
           6  +
/* RustType.kt:516 */
    4      7   
#[non_exhaustive]
           8  +
/* OperationGenerator.kt:84 */
    5      9   
pub struct DisableKinesisStreamingDestination;
          10  +
/* OperationGenerator.kt:85 */
    6     11   
impl DisableKinesisStreamingDestination {
    7         -
    /// Creates a new `DisableKinesisStreamingDestination`
          12  +
    /// /* OperationGenerator.kt:86 */Creates a new `DisableKinesisStreamingDestination`
          13  +
    /* OperationGenerator.kt:87 */
    8     14   
    pub fn new() -> Self {
          15  +
        /* OperationGenerator.kt:88 */
    9     16   
        Self
          17  +
        /* OperationGenerator.kt:87 */
   10     18   
    }
          19  +
    /* OperationGenerator.kt:138 */
   11     20   
    pub(crate) async fn orchestrate(
   12     21   
        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
   13     22   
        input: crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput,
   14     23   
    ) -> ::std::result::Result<
   15     24   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
   16     25   
        ::aws_smithy_runtime_api::client::result::SdkError<
   17     26   
            crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
   18     27   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   19     28   
        >,
   20     29   
    > {
@@ -63,72 +399,591 @@
   83     92   
                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
   84     93   
            }
   85     94   
            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
   86     95   
                config_override,
   87     96   
                client_config.config.clone(),
   88     97   
                &client_config.runtime_components,
   89     98   
            ));
   90     99   
        }
   91    100   
        runtime_plugins
   92    101   
    }
         102  +
    /* OperationGenerator.kt:85 */
   93    103   
}
         104  +
/* OperationRuntimePluginGenerator.kt:55 */
   94    105   
impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for DisableKinesisStreamingDestination {
   95    106   
    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
   96    107   
        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("DisableKinesisStreamingDestination");
   97    108   
   98    109   
        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
   99    110   
            DisableKinesisStreamingDestinationRequestSerializer,
  100    111   
        ));
  101    112   
        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
  102    113   
            DisableKinesisStreamingDestinationResponseDeserializer,
  103    114   
        ));
  104    115   
  105    116   
        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
  106    117   
            ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
  107    118   
        ));
  108    119   
  109    120   
        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
  110    121   
            "DisableKinesisStreamingDestination",
  111    122   
            "DynamoDB",
  112    123   
        ));
  113    124   
  114    125   
        ::std::option::Option::Some(cfg.freeze())
  115    126   
    }
  116    127   
  117    128   
    fn runtime_components(
  118    129   
        &self,
  119    130   
        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
  120    131   
    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
  121    132   
        #[allow(unused_mut)]
  122    133   
        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("DisableKinesisStreamingDestination")
  123    134   
            .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
  124    135   
            .with_interceptor(DisableKinesisStreamingDestinationEndpointParamsInterceptor)
  125    136   
            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
  126    137   
                crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
  127    138   
            >::new())
  128    139   
            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
  129    140   
                crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
  130    141   
            >::new());
  131    142   
  132    143   
        ::std::borrow::Cow::Owned(rcb)
  133    144   
    }
  134    145   
}
  135    146   
         147  +
/* ResponseDeserializerGenerator.kt:64 */
  136    148   
#[derive(Debug)]
  137    149   
struct DisableKinesisStreamingDestinationResponseDeserializer;
  138    150   
impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for DisableKinesisStreamingDestinationResponseDeserializer {
  139    151   
    fn deserialize_nonstreaming(
  140    152   
        &self,
  141    153   
        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
  142    154   
    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
  143    155   
        let (success, status) = (response.status().is_success(), response.status().as_u16());
  144    156   
        let headers = response.headers();
  145    157   
        let body = response.body().bytes().expect("body loaded");
  146    158   
        #[allow(unused_mut)]
  147    159   
        let mut force_error = false;
  148    160   
  149    161   
        let parse_result = if !success && status != 200 || force_error {
  150    162   
            crate::protocol_serde::shape_disable_kinesis_streaming_destination::de_disable_kinesis_streaming_destination_http_error(
  151    163   
                status, headers, body,
  152    164   
            )
  153    165   
        } else {
  154    166   
            crate::protocol_serde::shape_disable_kinesis_streaming_destination::de_disable_kinesis_streaming_destination_http_response(
  155    167   
                status, headers, body,
  156    168   
            )
  157    169   
        };
  158    170   
        crate::protocol_serde::type_erase_result(parse_result)
  159    171   
    }
  160    172   
}
         173  +
/* RequestSerializerGenerator.kt:67 */
  161    174   
#[derive(Debug)]
  162    175   
struct DisableKinesisStreamingDestinationRequestSerializer;
  163    176   
impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for DisableKinesisStreamingDestinationRequestSerializer {
  164    177   
    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
  165    178   
    fn serialize_input(
  166    179   
        &self,
  167    180   
        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
  168    181   
        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
  169    182   
    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
  170    183   
        let input = input
  171    184   
            .downcast::<crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput>()
  172    185   
            .expect("correct type");
  173    186   
        let _header_serialization_settings = _cfg
  174    187   
            .load::<crate::serialization_settings::HeaderSerializationSettings>()
  175    188   
            .cloned()
  176    189   
            .unwrap_or_default();
  177    190   
        let mut request_builder = {
  178    191   
            fn uri_base(
  179    192   
                _input: &crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput,
  180    193   
                output: &mut ::std::string::String,
  181    194   
            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
  182    195   
                use ::std::fmt::Write as _;
  183    196   
                ::std::write!(output, "/").expect("formatting should succeed");
  184    197   
                ::std::result::Result::Ok(())
  185    198   
            }
  186    199   
            #[allow(clippy::unnecessary_wraps)]
  187    200   
            fn update_http_builder(
  188    201   
                input: &crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput,
  189    202   
                builder: ::http::request::Builder,
  190    203   
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  191    204   
                let mut uri = ::std::string::String::new();
  192    205   
                uri_base(input, &mut uri)?;
  193    206   
                ::std::result::Result::Ok(builder.method("POST").uri(uri))
  194    207   
            }
  195    208   
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  196    209   
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
  197    210   
            builder = _header_serialization_settings.set_default_header(
  198    211   
                builder,
  199    212   
                ::http::header::HeaderName::from_static("x-amz-target"),
  200    213   
                "DynamoDB_20120810.DisableKinesisStreamingDestination",
  201    214   
            );
  202    215   
            builder
  203    216   
        };
  204    217   
        let body = ::aws_smithy_types::body::SdkBody::from(
  205    218   
            crate::protocol_serde::shape_disable_kinesis_streaming_destination::ser_disable_kinesis_streaming_destination_input(&input)?,
  206    219   
        );
  207    220   
        if let Some(content_length) = body.content_length() {
  208    221   
            let content_length = content_length.to_string();
  209    222   
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
  210    223   
        }
  211    224   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  212    225   
    }
  213    226   
}
         227  +
/* EndpointParamsInterceptorGenerator.kt:86 */
  214    228   
#[derive(Debug)]
  215    229   
struct DisableKinesisStreamingDestinationEndpointParamsInterceptor;
  216    230   
  217    231   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DisableKinesisStreamingDestinationEndpointParamsInterceptor {
  218    232   
    fn name(&self) -> &'static str {
  219    233   
        "DisableKinesisStreamingDestinationEndpointParamsInterceptor"
  220    234   
    }
  221    235   
  222    236   
    fn read_before_execution(
  223    237   
        &self,
  224    238   
        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
  225    239   
            '_,
  226    240   
            ::aws_smithy_runtime_api::client::interceptors::context::Input,
  227    241   
            ::aws_smithy_runtime_api::client::interceptors::context::Output,
  228    242   
            ::aws_smithy_runtime_api::client::interceptors::context::Error,
  229    243   
        >,
  230    244   
        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
  231    245   
    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
  232    246   
        let _input = context
  233    247   
            .input()
  234    248   
            .downcast_ref::<DisableKinesisStreamingDestinationInput>()
  235    249   
            .ok_or("failed to downcast to DisableKinesisStreamingDestinationInput")?;
  236    250   
  237    251   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  238    252   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  239    253   
        })?;
  240    254   
        cfg.interceptor_state()
  241    255   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  242    256   
        ::std::result::Result::Ok(())
  243    257   
    }
  244    258   
}
  245    259   
  246    260   
// The get_* functions below are generated from JMESPath expressions in the
  247    261   
// operationContextParams trait. They target the operation's input shape.
  248    262   
         263  +
/* OperationErrorGenerator.kt:79 */
  249    264   
/// Error type for the `DisableKinesisStreamingDestinationError` operation.
         265  +
/* RustType.kt:516 */
  250    266   
#[non_exhaustive]
         267  +
/* RustType.kt:516 */
  251    268   
#[derive(::std::fmt::Debug)]
  252         -
pub enum DisableKinesisStreamingDestinationError {
  253         -
    /// <p>An error occurred on the server side.</p>
         269  +
pub /* OperationErrorGenerator.kt:81 */ enum DisableKinesisStreamingDestinationError {
         270  +
    /// /* OperationErrorGenerator.kt:83 */<p>An error occurred on the server side.</p>
         271  +
    /* OperationErrorGenerator.kt:86 */
  254    272   
    InternalServerError(crate::types::error::InternalServerError),
         273  +
    /* OperationErrorGenerator.kt:83 */
  255    274   
    #[allow(missing_docs)] // documentation missing in model
         275  +
    /* OperationErrorGenerator.kt:86 */
  256    276   
    InvalidEndpointError(crate::types::error::InvalidEndpointError),
  257         -
    /// <p>There is no limit to the number of daily on-demand backups that can be taken.</p>
         277  +
    /// /* OperationErrorGenerator.kt:83 */<p>There is no limit to the number of daily on-demand backups that can be taken.</p>
  258    278   
    /// <p>Up to 50 simultaneous table operations are allowed per account. These operations include <code>CreateTable</code>, <code>UpdateTable</code>, <code>DeleteTable</code>,<code>UpdateTimeToLive</code>, <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>.</p>
  259    279   
    /// <p>The only exception is when you are creating a table with one or more secondary indexes. You can have up to 25 such requests running at a time; however, if the table or index specifications are complex, DynamoDB might temporarily reduce the number of concurrent operations.</p>
  260    280   
    /// <p>There is a soft account quota of 256 tables.</p>
         281  +
    /* OperationErrorGenerator.kt:86 */
  261    282   
    LimitExceededError(crate::types::error::LimitExceededError),
  262         -
    /// <p>The operation conflicts with the resource's availability. For example, you attempted to recreate an existing table, or tried to delete a table currently in the <code>CREATING</code> state.</p>
         283  +
    /// /* OperationErrorGenerator.kt:83 */<p>The operation conflicts with the resource's availability. For example, you attempted to recreate an existing table, or tried to delete a table currently in the <code>CREATING</code> state.</p>
         284  +
    /* OperationErrorGenerator.kt:86 */
  263    285   
    ResourceInUseError(crate::types::error::ResourceInUseError),
  264         -
    /// <p>The operation tried to access a nonexistent table or index. The resource might not be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
         286  +
    /// /* OperationErrorGenerator.kt:83 */<p>The operation tried to access a nonexistent table or index. The resource might not be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
         287  +
    /* OperationErrorGenerator.kt:86 */
  265    288   
    ResourceNotFoundError(crate::types::error::ResourceNotFoundError),
         289  +
    /* OperationErrorGenerator.kt:88 */
  266    290   
    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
  267    291   
    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
  268    292   
    variable wildcard pattern and check `.code()`:
  269    293   
     \
  270    294   
    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
  271    295   
     \
  272    296   
    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DisableKinesisStreamingDestinationError) for what information is available for the error.")]
  273    297   
    Unhandled(crate::error::sealed_unhandled::Unhandled),
         298  +
    /* OperationErrorGenerator.kt:81 */
  274    299   
}
         300  +
/* OperationErrorGenerator.kt:218 */
  275    301   
impl DisableKinesisStreamingDestinationError {
         302  +
    /* OperationErrorGenerator.kt:219 */
  276    303   
    /// Creates the `DisableKinesisStreamingDestinationError::Unhandled` variant from any error type.
  277    304   
    pub fn unhandled(
  278    305   
        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
  279    306   
    ) -> Self {
  280    307   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  281    308   
            source: err.into(),
  282    309   
            meta: ::std::default::Default::default(),
  283    310   
        })
  284    311   
    }
  285    312   
  286    313   
    /// Creates the `DisableKinesisStreamingDestinationError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
  287    314   
    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
  288    315   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  289    316   
            source: err.clone().into(),
  290    317   
            meta: err,
  291    318   
        })
  292    319   
    }
  293         -
    ///
         320  +
    /// /* OperationErrorGenerator.kt:236 */
  294    321   
    /// Returns error metadata, which includes the error code, message,
  295    322   
    /// request ID, and potentially additional information.
  296    323   
    ///
         324  +
    /* OperationErrorGenerator.kt:242 */
  297    325   
    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         326  +
        /* OperationErrorGenerator.kt:243 */
  298    327   
        match self {
         328  +
            /* OperationErrorGenerator.kt:246 */
  299    329   
            Self::InternalServerError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         330  +
            /* OperationErrorGenerator.kt:246 */
  300    331   
            Self::InvalidEndpointError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         332  +
            /* OperationErrorGenerator.kt:246 */
  301    333   
            Self::LimitExceededError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         334  +
            /* OperationErrorGenerator.kt:246 */
  302    335   
            Self::ResourceInUseError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         336  +
            /* OperationErrorGenerator.kt:246 */
  303    337   
            Self::ResourceNotFoundError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
  304         -
            Self::Unhandled(e) => &e.meta,
         338  +
            /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
         339  +
            /* OperationErrorGenerator.kt:243 */
  305    340   
        }
         341  +
        /* OperationErrorGenerator.kt:242 */
  306    342   
    }
         343  +
    /* OperationErrorGenerator.kt:257 */
  307    344   
    /// Returns `true` if the error kind is `DisableKinesisStreamingDestinationError::InternalServerError`.
         345  +
    /* OperationErrorGenerator.kt:258 */
  308    346   
    pub fn is_internal_server_error(&self) -> bool {
         347  +
        /* OperationErrorGenerator.kt:259 */
  309    348   
        matches!(self, Self::InternalServerError(_))
         349  +
        /* OperationErrorGenerator.kt:258 */
  310    350   
    }
         351  +
    /* OperationErrorGenerator.kt:257 */
  311    352   
    /// Returns `true` if the error kind is `DisableKinesisStreamingDestinationError::InvalidEndpointError`.
         353  +
    /* OperationErrorGenerator.kt:258 */
  312    354   
    pub fn is_invalid_endpoint_error(&self) -> bool {
         355  +
        /* OperationErrorGenerator.kt:259 */
  313    356   
        matches!(self, Self::InvalidEndpointError(_))
         357  +
        /* OperationErrorGenerator.kt:258 */
  314    358   
    }
         359  +
    /* OperationErrorGenerator.kt:257 */
  315    360   
    /// Returns `true` if the error kind is `DisableKinesisStreamingDestinationError::LimitExceededError`.
         361  +
    /* OperationErrorGenerator.kt:258 */
  316    362   
    pub fn is_limit_exceeded_error(&self) -> bool {
         363  +
        /* OperationErrorGenerator.kt:259 */
  317    364   
        matches!(self, Self::LimitExceededError(_))
         365  +
        /* OperationErrorGenerator.kt:258 */
  318    366   
    }
         367  +
    /* OperationErrorGenerator.kt:257 */
  319    368   
    /// Returns `true` if the error kind is `DisableKinesisStreamingDestinationError::ResourceInUseError`.
         369  +
    /* OperationErrorGenerator.kt:258 */
  320    370   
    pub fn is_resource_in_use_error(&self) -> bool {
         371  +
        /* OperationErrorGenerator.kt:259 */
  321    372   
        matches!(self, Self::ResourceInUseError(_))
         373  +
        /* OperationErrorGenerator.kt:258 */
  322    374   
    }
         375  +
    /* OperationErrorGenerator.kt:257 */
  323    376   
    /// Returns `true` if the error kind is `DisableKinesisStreamingDestinationError::ResourceNotFoundError`.
         377  +
    /* OperationErrorGenerator.kt:258 */
  324    378   
    pub fn is_resource_not_found_error(&self) -> bool {
         379  +
        /* OperationErrorGenerator.kt:259 */
  325    380   
        matches!(self, Self::ResourceNotFoundError(_))
         381  +
        /* OperationErrorGenerator.kt:258 */
  326    382   
    }
         383  +
    /* OperationErrorGenerator.kt:218 */
  327    384   
}
         385  +
/* OperationErrorGenerator.kt:269 */
  328    386   
impl ::std::error::Error for DisableKinesisStreamingDestinationError {
         387  +
    /* OperationErrorGenerator.kt:270 */
  329    388   
    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         389  +
        /* OperationErrorGenerator.kt:318 */
  330    390   
        match self {
  331         -
            Self::InternalServerError(_inner) => ::std::option::Option::Some(_inner),
  332         -
            Self::InvalidEndpointError(_inner) => ::std::option::Option::Some(_inner),
  333         -
            Self::LimitExceededError(_inner) => ::std::option::Option::Some(_inner),
  334         -
            Self::ResourceInUseError(_inner) => ::std::option::Option::Some(_inner),
  335         -
            Self::ResourceNotFoundError(_inner) => ::std::option::Option::Some(_inner),
  336         -
            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
         391  +
            /* OperationErrorGenerator.kt:321 */
         392  +
            Self::InternalServerError(_inner) =>
         393  +
            /* OperationErrorGenerator.kt:283 */
         394  +
            {
         395  +
                ::std::option::Option::Some(_inner)
         396  +
            }
         397  +
            ,
         398  +
            /* OperationErrorGenerator.kt:321 */
         399  +
            Self::InvalidEndpointError(_inner) =>
         400  +
            /* OperationErrorGenerator.kt:283 */
         401  +
            {
         402  +
                ::std::option::Option::Some(_inner)
         403  +
            }
         404  +
            ,
         405  +
            /* OperationErrorGenerator.kt:321 */
         406  +
            Self::LimitExceededError(_inner) =>
         407  +
            /* OperationErrorGenerator.kt:283 */
         408  +
            {
         409  +
                ::std::option::Option::Some(_inner)
         410  +
            }
         411  +
            ,
         412  +
            /* OperationErrorGenerator.kt:321 */
         413  +
            Self::ResourceInUseError(_inner) =>
         414  +
            /* OperationErrorGenerator.kt:283 */
         415  +
            {
         416  +
                ::std::option::Option::Some(_inner)
         417  +
            }
         418  +
            ,
         419  +
            /* OperationErrorGenerator.kt:321 */
         420  +
            Self::ResourceNotFoundError(_inner) =>
         421  +
            /* OperationErrorGenerator.kt:283 */
         422  +
            {
         423  +
                ::std::option::Option::Some(_inner)
         424  +
            }
         425  +
            ,
         426  +
            /* OperationErrorGenerator.kt:326 */
         427  +
            Self::Unhandled(_inner) => {
         428  +
                /* OperationErrorGenerator.kt:279 */
         429  +
                ::std::option::Option::Some(&*_inner.source)
         430  +
                /* OperationErrorGenerator.kt:326 */
         431  +
            } /* OperationErrorGenerator.kt:318 */
  337    432   
        }
         433  +
        /* OperationErrorGenerator.kt:270 */
  338    434   
    }
         435  +
    /* OperationErrorGenerator.kt:269 */
  339    436   
}
         437  +
/* OperationErrorGenerator.kt:133 */
  340    438   
impl ::std::fmt::Display for DisableKinesisStreamingDestinationError {
         439  +
    /* OperationErrorGenerator.kt:134 */
  341    440   
    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         441  +
        /* OperationErrorGenerator.kt:318 */
  342    442   
        match self {
  343         -
            Self::InternalServerError(_inner) => _inner.fmt(f),
  344         -
            Self::InvalidEndpointError(_inner) => _inner.fmt(f),
  345         -
            Self::LimitExceededError(_inner) => _inner.fmt(f),
  346         -
            Self::ResourceInUseError(_inner) => _inner.fmt(f),
  347         -
            Self::ResourceNotFoundError(_inner) => _inner.fmt(f),
         443  +
            /* OperationErrorGenerator.kt:321 */
         444  +
            Self::InternalServerError(_inner) =>
         445  +
            /* OperationErrorGenerator.kt:151 */
         446  +
            {
         447  +
                _inner.fmt(f)
         448  +
            }
         449  +
            ,
         450  +
            /* OperationErrorGenerator.kt:321 */
         451  +
            Self::InvalidEndpointError(_inner) =>
         452  +
            /* OperationErrorGenerator.kt:151 */
         453  +
            {
         454  +
                _inner.fmt(f)
         455  +
            }
         456  +
            ,
         457  +
            /* OperationErrorGenerator.kt:321 */
         458  +
            Self::LimitExceededError(_inner) =>
         459  +
            /* OperationErrorGenerator.kt:151 */
         460  +
            {
         461  +
                _inner.fmt(f)
         462  +
            }
         463  +
            ,
         464  +
            /* OperationErrorGenerator.kt:321 */
         465  +
            Self::ResourceInUseError(_inner) =>
         466  +
            /* OperationErrorGenerator.kt:151 */
         467  +
            {
         468  +
                _inner.fmt(f)
         469  +
            }
         470  +
            ,
         471  +
            /* OperationErrorGenerator.kt:321 */
         472  +
            Self::ResourceNotFoundError(_inner) =>
         473  +
            /* OperationErrorGenerator.kt:151 */
         474  +
            {
         475  +
                _inner.fmt(f)
         476  +
            }
         477  +
            ,
         478  +
            /* OperationErrorGenerator.kt:326 */
  348    479   
            Self::Unhandled(_inner) => {
         480  +
                /* OperationErrorGenerator.kt:139 */
  349    481   
                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
  350    482   
                    write!(f, "unhandled error ({code})")
  351    483   
                } else {
  352    484   
                    f.write_str("unhandled error")
  353    485   
                }
         486  +
                /* OperationErrorGenerator.kt:326 */
         487  +
            } /* OperationErrorGenerator.kt:318 */
  354    488   
        }
         489  +
        /* OperationErrorGenerator.kt:134 */
  355    490   
    }
  356         -
    }
         491  +
    /* OperationErrorGenerator.kt:133 */
  357    492   
}
         493  +
/* OperationErrorGenerator.kt:182 */
  358    494   
impl ::aws_smithy_types::retry::ProvideErrorKind for DisableKinesisStreamingDestinationError {
         495  +
    /* OperationErrorGenerator.kt:186 */
  359    496   
    fn code(&self) -> ::std::option::Option<&str> {
         497  +
        /* OperationErrorGenerator.kt:187 */
  360    498   
        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         499  +
        /* OperationErrorGenerator.kt:186 */
  361    500   
    }
         501  +
    /* OperationErrorGenerator.kt:190 */
  362    502   
    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         503  +
        /* OperationErrorGenerator.kt:197 */
  363    504   
        ::std::option::Option::None
         505  +
        /* OperationErrorGenerator.kt:190 */
  364    506   
    }
         507  +
    /* OperationErrorGenerator.kt:182 */
  365    508   
}
         509  +
/* OperationErrorGenerator.kt:163 */
  366    510   
impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for DisableKinesisStreamingDestinationError {
         511  +
    /* OperationErrorGenerator.kt:164 */
  367    512   
    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         513  +
        /* OperationErrorGenerator.kt:318 */
  368    514   
        match self {
  369         -
            Self::InternalServerError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  370         -
            Self::InvalidEndpointError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  371         -
            Self::LimitExceededError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  372         -
            Self::ResourceInUseError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  373         -
            Self::ResourceNotFoundError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  374         -
            Self::Unhandled(_inner) => &_inner.meta,
         515  +
            /* OperationErrorGenerator.kt:321 */
         516  +
            Self::InternalServerError(_inner) =>
         517  +
            /* OperationErrorGenerator.kt:169 */
         518  +
            {
         519  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         520  +
            }
         521  +
            ,
         522  +
            /* OperationErrorGenerator.kt:321 */
         523  +
            Self::InvalidEndpointError(_inner) =>
         524  +
            /* OperationErrorGenerator.kt:169 */
         525  +
            {
         526  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         527  +
            }
         528  +
            ,
         529  +
            /* OperationErrorGenerator.kt:321 */
         530  +
            Self::LimitExceededError(_inner) =>
         531  +
            /* OperationErrorGenerator.kt:169 */
         532  +
            {
         533  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         534  +
            }
         535  +
            ,
         536  +
            /* OperationErrorGenerator.kt:321 */
         537  +
            Self::ResourceInUseError(_inner) =>
         538  +
            /* OperationErrorGenerator.kt:169 */
         539  +
            {
         540  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         541  +
            }
         542  +
            ,
         543  +
            /* OperationErrorGenerator.kt:321 */
         544  +
            Self::ResourceNotFoundError(_inner) =>
         545  +
            /* OperationErrorGenerator.kt:169 */
         546  +
            {
         547  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         548  +
            }
         549  +
            ,
         550  +
            /* OperationErrorGenerator.kt:326 */
         551  +
            Self::Unhandled(_inner) => {
         552  +
                /* OperationErrorGenerator.kt:168 */
         553  +
                &_inner.meta
         554  +
                /* OperationErrorGenerator.kt:326 */
         555  +
            } /* OperationErrorGenerator.kt:318 */
  375    556   
        }
         557  +
        /* OperationErrorGenerator.kt:164 */
  376    558   
    }
         559  +
    /* OperationErrorGenerator.kt:163 */
  377    560   
}
         561  +
/* OperationErrorGenerator.kt:109 */
  378    562   
impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for DisableKinesisStreamingDestinationError {
         563  +
    /* OperationErrorGenerator.kt:110 */
  379    564   
    fn create_unhandled_error(
  380    565   
        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
  381    566   
        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
  382    567   
    ) -> Self {
         568  +
        /* OperationErrorGenerator.kt:121 */
  383    569   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  384    570   
            source,
  385    571   
            meta: meta.unwrap_or_default(),
  386    572   
        })
         573  +
        /* OperationErrorGenerator.kt:110 */
  387    574   
    }
         575  +
    /* OperationErrorGenerator.kt:109 */
  388    576   
}
  389    577   
         578  +
/* CodegenDelegator.kt:255 */
  390    579   
pub use crate::operation::disable_kinesis_streaming_destination::_disable_kinesis_streaming_destination_output::DisableKinesisStreamingDestinationOutput;
  391    580   
         581  +
/* CodegenDelegator.kt:255 */
  392    582   
pub use crate::operation::disable_kinesis_streaming_destination::_disable_kinesis_streaming_destination_input::DisableKinesisStreamingDestinationInput;
  393    583   
         584  +
/* RustModule.kt:172 */
  394    585   
mod _disable_kinesis_streaming_destination_input;
  395    586   
         587  +
/* RustModule.kt:172 */
  396    588   
mod _disable_kinesis_streaming_destination_output;
  397    589   
  398         -
/// Builders
         590  +
/// /* CodegenDelegator.kt:51 */Builders
  399    591   
pub mod builders;

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/disable_kinesis_streaming_destination/_disable_kinesis_streaming_destination_input.rs

@@ -1,1 +80,129 @@
    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 DisableKinesisStreamingDestinationInput {
    6         -
    /// <p>The name of the DynamoDB table.</p>
           8  +
pub /* StructureGenerator.kt:201 */ struct DisableKinesisStreamingDestinationInput {
           9  +
    /// /* StructureGenerator.kt:231 */<p>The name of the DynamoDB table.</p>
    7     10   
    pub table_name: ::std::option::Option<::std::string::String>,
    8         -
    /// <p>The ARN for a Kinesis data stream.</p>
          11  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for a Kinesis data stream.</p>
    9     12   
    pub stream_arn: ::std::option::Option<::std::string::String>,
          13  +
    /* StructureGenerator.kt:201 */
   10     14   
}
          15  +
/* StructureGenerator.kt:135 */
   11     16   
impl DisableKinesisStreamingDestinationInput {
   12         -
    /// <p>The name of the DynamoDB table.</p>
          17  +
    /// /* StructureGenerator.kt:231 */<p>The name of the DynamoDB table.</p>
          18  +
    /* StructureGenerator.kt:166 */
   13     19   
    pub fn table_name(&self) -> ::std::option::Option<&str> {
          20  +
        /* StructureGenerator.kt:169 */
   14     21   
        self.table_name.as_deref()
          22  +
        /* StructureGenerator.kt:166 */
   15     23   
    }
   16         -
    /// <p>The ARN for a Kinesis data stream.</p>
          24  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for a Kinesis data stream.</p>
          25  +
    /* StructureGenerator.kt:166 */
   17     26   
    pub fn stream_arn(&self) -> ::std::option::Option<&str> {
          27  +
        /* StructureGenerator.kt:169 */
   18     28   
        self.stream_arn.as_deref()
          29  +
        /* StructureGenerator.kt:166 */
   19     30   
    }
          31  +
    /* StructureGenerator.kt:135 */
   20     32   
}
          33  +
/* ClientCodegenVisitor.kt:237 */
   21     34   
impl DisableKinesisStreamingDestinationInput {
   22         -
    /// Creates a new builder-style object to manufacture [`DisableKinesisStreamingDestinationInput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput).
          35  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DisableKinesisStreamingDestinationInput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput).
          36  +
    /* BuilderGenerator.kt:175 */
   23     37   
    pub fn builder() -> crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationInputBuilder {
          38  +
        /* BuilderGenerator.kt:176 */
   24     39   
        crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationInputBuilder::default()
          40  +
        /* BuilderGenerator.kt:175 */
   25     41   
    }
          42  +
    /* ClientCodegenVisitor.kt:237 */
   26     43   
}
   27     44   
   28         -
/// A builder for [`DisableKinesisStreamingDestinationInput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput).
          45  +
/// /* BuilderGenerator.kt:342 */A builder for [`DisableKinesisStreamingDestinationInput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput).
          46  +
/* RustType.kt:516 */
   29     47   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          48  +
/* RustType.kt:516 */
   30     49   
#[non_exhaustive]
          50  +
/* BuilderGenerator.kt:345 */
   31     51   
pub struct DisableKinesisStreamingDestinationInputBuilder {
   32         -
    pub(crate) table_name: ::std::option::Option<::std::string::String>,
   33         -
    pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          52  +
    /* BuilderGenerator.kt:275 */ pub(crate) table_name: ::std::option::Option<::std::string::String>,
          53  +
    /* BuilderGenerator.kt:275 */ pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          54  +
    /* BuilderGenerator.kt:345 */
   34     55   
}
          56  +
/* BuilderGenerator.kt:355 */
   35     57   
impl DisableKinesisStreamingDestinationInputBuilder {
   36         -
    /// <p>The name of the DynamoDB table.</p>
   37         -
    /// This field is required.
          58  +
    /// /* BuilderGenerator.kt:286 */<p>The name of the DynamoDB table.</p>
          59  +
    /// /* BuilderGenerator.kt:288 */This field is required.
          60  +
    /* BuilderGenerator.kt:291 */
   38     61   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          62  +
        /* BuilderGenerator.kt:292 */
   39     63   
        self.table_name = ::std::option::Option::Some(input.into());
          64  +
        /* BuilderGenerator.kt:293 */
   40     65   
        self
          66  +
        /* BuilderGenerator.kt:291 */
   41     67   
    }
   42         -
    /// <p>The name of the DynamoDB table.</p>
          68  +
    /// /* BuilderGenerator.kt:312 */<p>The name of the DynamoDB table.</p>
          69  +
    /* BuilderGenerator.kt:314 */
   43     70   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          71  +
        /* BuilderGenerator.kt:315 */
   44     72   
        self.table_name = input;
   45     73   
        self
          74  +
        /* BuilderGenerator.kt:314 */
   46     75   
    }
   47         -
    /// <p>The name of the DynamoDB table.</p>
          76  +
    /// /* BuilderGenerator.kt:334 */<p>The name of the DynamoDB table.</p>
          77  +
    /* BuilderGenerator.kt:336 */
   48     78   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
          79  +
        /* BuilderGenerator.kt:337 */
   49     80   
        &self.table_name
          81  +
        /* BuilderGenerator.kt:336 */
   50     82   
    }
   51         -
    /// <p>The ARN for a Kinesis data stream.</p>
   52         -
    /// This field is required.
          83  +
    /// /* BuilderGenerator.kt:286 */<p>The ARN for a Kinesis data stream.</p>
          84  +
    /// /* BuilderGenerator.kt:288 */This field is required.
          85  +
    /* BuilderGenerator.kt:291 */
   53     86   
    pub fn stream_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          87  +
        /* BuilderGenerator.kt:292 */
   54     88   
        self.stream_arn = ::std::option::Option::Some(input.into());
          89  +
        /* BuilderGenerator.kt:293 */
   55     90   
        self
          91  +
        /* BuilderGenerator.kt:291 */
   56     92   
    }
   57         -
    /// <p>The ARN for a Kinesis data stream.</p>
          93  +
    /// /* BuilderGenerator.kt:312 */<p>The ARN for a Kinesis data stream.</p>
          94  +
    /* BuilderGenerator.kt:314 */
   58     95   
    pub fn set_stream_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          96  +
        /* BuilderGenerator.kt:315 */
   59     97   
        self.stream_arn = input;
   60     98   
        self
          99  +
        /* BuilderGenerator.kt:314 */
   61    100   
    }
   62         -
    /// <p>The ARN for a Kinesis data stream.</p>
         101  +
    /// /* BuilderGenerator.kt:334 */<p>The ARN for a Kinesis data stream.</p>
         102  +
    /* BuilderGenerator.kt:336 */
   63    103   
    pub fn get_stream_arn(&self) -> &::std::option::Option<::std::string::String> {
         104  +
        /* BuilderGenerator.kt:337 */
   64    105   
        &self.stream_arn
         106  +
        /* BuilderGenerator.kt:336 */
   65    107   
    }
   66         -
    /// Consumes the builder and constructs a [`DisableKinesisStreamingDestinationInput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput).
         108  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DisableKinesisStreamingDestinationInput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput).
         109  +
    /* BuilderGenerator.kt:253 */
   67    110   
    pub fn build(
   68    111   
        self,
   69    112   
    ) -> ::std::result::Result<
   70    113   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput,
   71    114   
        ::aws_smithy_types::error::operation::BuildError,
   72    115   
    > {
         116  +
        /* BuilderGenerator.kt:254 */
   73    117   
        ::std::result::Result::Ok(
         118  +
            /* BuilderGenerator.kt:477 */
   74    119   
            crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationInput {
   75         -
                table_name: self.table_name,
         120  +
                /* BuilderGenerator.kt:481 */ table_name: self.table_name,
         121  +
                /* BuilderGenerator.kt:481 */
   76    122   
                stream_arn: self.stream_arn,
   77         -
            },
         123  +
                /* BuilderGenerator.kt:477 */
         124  +
            }, /* BuilderGenerator.kt:254 */
   78    125   
        )
         126  +
        /* BuilderGenerator.kt:253 */
   79    127   
    }
         128  +
    /* BuilderGenerator.kt:355 */
   80    129   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/disable_kinesis_streaming_destination/_disable_kinesis_streaming_destination_output.rs

@@ -1,1 +93,156 @@
    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 DisableKinesisStreamingDestinationOutput {
    6         -
    /// <p>The name of the table being modified.</p>
           8  +
pub /* StructureGenerator.kt:201 */ struct DisableKinesisStreamingDestinationOutput {
           9  +
    /// /* StructureGenerator.kt:231 */<p>The name of the table being modified.</p>
    7     10   
    pub table_name: ::std::option::Option<::std::string::String>,
    8         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
          11  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for the specific Kinesis data stream.</p>
    9     12   
    pub stream_arn: ::std::option::Option<::std::string::String>,
   10         -
    /// <p>The current status of the replication.</p>
          13  +
    /// /* StructureGenerator.kt:231 */<p>The current status of the replication.</p>
   11     14   
    pub destination_status: ::std::option::Option<crate::types::DestinationStatus>,
          15  +
    /* StructureGenerator.kt:201 */
   12     16   
}
          17  +
/* StructureGenerator.kt:135 */
   13     18   
impl DisableKinesisStreamingDestinationOutput {
   14         -
    /// <p>The name of the table being modified.</p>
          19  +
    /// /* StructureGenerator.kt:231 */<p>The name of the table being modified.</p>
          20  +
    /* StructureGenerator.kt:166 */
   15     21   
    pub fn table_name(&self) -> ::std::option::Option<&str> {
          22  +
        /* StructureGenerator.kt:169 */
   16     23   
        self.table_name.as_deref()
          24  +
        /* StructureGenerator.kt:166 */
   17     25   
    }
   18         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
          26  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for the specific Kinesis data stream.</p>
          27  +
    /* StructureGenerator.kt:166 */
   19     28   
    pub fn stream_arn(&self) -> ::std::option::Option<&str> {
          29  +
        /* StructureGenerator.kt:169 */
   20     30   
        self.stream_arn.as_deref()
          31  +
        /* StructureGenerator.kt:166 */
   21     32   
    }
   22         -
    /// <p>The current status of the replication.</p>
          33  +
    /// /* StructureGenerator.kt:231 */<p>The current status of the replication.</p>
          34  +
    /* StructureGenerator.kt:166 */
   23     35   
    pub fn destination_status(&self) -> ::std::option::Option<&crate::types::DestinationStatus> {
          36  +
        /* StructureGenerator.kt:170 */
   24     37   
        self.destination_status.as_ref()
          38  +
        /* StructureGenerator.kt:166 */
   25     39   
    }
          40  +
    /* StructureGenerator.kt:135 */
   26     41   
}
          42  +
/* ClientCodegenVisitor.kt:237 */
   27     43   
impl DisableKinesisStreamingDestinationOutput {
   28         -
    /// Creates a new builder-style object to manufacture [`DisableKinesisStreamingDestinationOutput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput).
          44  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DisableKinesisStreamingDestinationOutput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput).
          45  +
    /* BuilderGenerator.kt:175 */
   29     46   
    pub fn builder() -> crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationOutputBuilder {
          47  +
        /* BuilderGenerator.kt:176 */
   30     48   
        crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationOutputBuilder::default()
          49  +
        /* BuilderGenerator.kt:175 */
   31     50   
    }
          51  +
    /* ClientCodegenVisitor.kt:237 */
   32     52   
}
   33     53   
   34         -
/// A builder for [`DisableKinesisStreamingDestinationOutput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput).
          54  +
/// /* BuilderGenerator.kt:342 */A builder for [`DisableKinesisStreamingDestinationOutput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput).
          55  +
/* RustType.kt:516 */
   35     56   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          57  +
/* RustType.kt:516 */
   36     58   
#[non_exhaustive]
          59  +
/* BuilderGenerator.kt:345 */
   37     60   
pub struct DisableKinesisStreamingDestinationOutputBuilder {
   38         -
    pub(crate) table_name: ::std::option::Option<::std::string::String>,
   39         -
    pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          61  +
    /* BuilderGenerator.kt:275 */ pub(crate) table_name: ::std::option::Option<::std::string::String>,
          62  +
    /* BuilderGenerator.kt:275 */ pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          63  +
    /* BuilderGenerator.kt:275 */
   40     64   
    pub(crate) destination_status: ::std::option::Option<crate::types::DestinationStatus>,
          65  +
    /* BuilderGenerator.kt:345 */
   41     66   
}
          67  +
/* BuilderGenerator.kt:355 */
   42     68   
impl DisableKinesisStreamingDestinationOutputBuilder {
   43         -
    /// <p>The name of the table being modified.</p>
          69  +
    /// /* BuilderGenerator.kt:286 */<p>The name of the table being modified.</p>
          70  +
    /* BuilderGenerator.kt:291 */
   44     71   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          72  +
        /* BuilderGenerator.kt:292 */
   45     73   
        self.table_name = ::std::option::Option::Some(input.into());
          74  +
        /* BuilderGenerator.kt:293 */
   46     75   
        self
          76  +
        /* BuilderGenerator.kt:291 */
   47     77   
    }
   48         -
    /// <p>The name of the table being modified.</p>
          78  +
    /// /* BuilderGenerator.kt:312 */<p>The name of the table being modified.</p>
          79  +
    /* BuilderGenerator.kt:314 */
   49     80   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          81  +
        /* BuilderGenerator.kt:315 */
   50     82   
        self.table_name = input;
   51     83   
        self
          84  +
        /* BuilderGenerator.kt:314 */
   52     85   
    }
   53         -
    /// <p>The name of the table being modified.</p>
          86  +
    /// /* BuilderGenerator.kt:334 */<p>The name of the table being modified.</p>
          87  +
    /* BuilderGenerator.kt:336 */
   54     88   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
          89  +
        /* BuilderGenerator.kt:337 */
   55     90   
        &self.table_name
          91  +
        /* BuilderGenerator.kt:336 */
   56     92   
    }
   57         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
          93  +
    /// /* BuilderGenerator.kt:286 */<p>The ARN for the specific Kinesis data stream.</p>
          94  +
    /* BuilderGenerator.kt:291 */
   58     95   
    pub fn stream_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          96  +
        /* BuilderGenerator.kt:292 */
   59     97   
        self.stream_arn = ::std::option::Option::Some(input.into());
          98  +
        /* BuilderGenerator.kt:293 */
   60     99   
        self
         100  +
        /* BuilderGenerator.kt:291 */
   61    101   
    }
   62         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
         102  +
    /// /* BuilderGenerator.kt:312 */<p>The ARN for the specific Kinesis data stream.</p>
         103  +
    /* BuilderGenerator.kt:314 */
   63    104   
    pub fn set_stream_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         105  +
        /* BuilderGenerator.kt:315 */
   64    106   
        self.stream_arn = input;
   65    107   
        self
         108  +
        /* BuilderGenerator.kt:314 */
   66    109   
    }
   67         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
         110  +
    /// /* BuilderGenerator.kt:334 */<p>The ARN for the specific Kinesis data stream.</p>
         111  +
    /* BuilderGenerator.kt:336 */
   68    112   
    pub fn get_stream_arn(&self) -> &::std::option::Option<::std::string::String> {
         113  +
        /* BuilderGenerator.kt:337 */
   69    114   
        &self.stream_arn
         115  +
        /* BuilderGenerator.kt:336 */
   70    116   
    }
   71         -
    /// <p>The current status of the replication.</p>
         117  +
    /// /* BuilderGenerator.kt:286 */<p>The current status of the replication.</p>
         118  +
    /* BuilderGenerator.kt:291 */
   72    119   
    pub fn destination_status(mut self, input: crate::types::DestinationStatus) -> Self {
         120  +
        /* BuilderGenerator.kt:292 */
   73    121   
        self.destination_status = ::std::option::Option::Some(input);
         122  +
        /* BuilderGenerator.kt:293 */
   74    123   
        self
         124  +
        /* BuilderGenerator.kt:291 */
   75    125   
    }
   76         -
    /// <p>The current status of the replication.</p>
         126  +
    /// /* BuilderGenerator.kt:312 */<p>The current status of the replication.</p>
         127  +
    /* BuilderGenerator.kt:314 */
   77    128   
    pub fn set_destination_status(mut self, input: ::std::option::Option<crate::types::DestinationStatus>) -> Self {
         129  +
        /* BuilderGenerator.kt:315 */
   78    130   
        self.destination_status = input;
   79    131   
        self
         132  +
        /* BuilderGenerator.kt:314 */
   80    133   
    }
   81         -
    /// <p>The current status of the replication.</p>
         134  +
    /// /* BuilderGenerator.kt:334 */<p>The current status of the replication.</p>
         135  +
    /* BuilderGenerator.kt:336 */
   82    136   
    pub fn get_destination_status(&self) -> &::std::option::Option<crate::types::DestinationStatus> {
         137  +
        /* BuilderGenerator.kt:337 */
   83    138   
        &self.destination_status
         139  +
        /* BuilderGenerator.kt:336 */
   84    140   
    }
   85         -
    /// Consumes the builder and constructs a [`DisableKinesisStreamingDestinationOutput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput).
         141  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DisableKinesisStreamingDestinationOutput`](crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput).
         142  +
    /* BuilderGenerator.kt:253 */
   86    143   
    pub fn build(self) -> crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput {
         144  +
        /* BuilderGenerator.kt:477 */
   87    145   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput {
   88         -
            table_name: self.table_name,
         146  +
            /* BuilderGenerator.kt:481 */ table_name: self.table_name,
         147  +
            /* BuilderGenerator.kt:481 */
   89    148   
            stream_arn: self.stream_arn,
         149  +
            /* BuilderGenerator.kt:481 */
   90    150   
            destination_status: self.destination_status,
         151  +
            /* BuilderGenerator.kt:477 */
   91    152   
        }
         153  +
        /* BuilderGenerator.kt:253 */
   92    154   
    }
         155  +
    /* BuilderGenerator.kt:355 */
   93    156   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/disable_kinesis_streaming_destination/builders.rs

@@ -1,1 +139,157 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* CodegenDelegator.kt:255 */
    2      3   
pub use crate::operation::disable_kinesis_streaming_destination::_disable_kinesis_streaming_destination_output::DisableKinesisStreamingDestinationOutputBuilder;
    3      4   
           5  +
/* CodegenDelegator.kt:255 */
    4      6   
pub use crate::operation::disable_kinesis_streaming_destination::_disable_kinesis_streaming_destination_input::DisableKinesisStreamingDestinationInputBuilder;
    5      7   
           8  +
/* FluentBuilderGenerator.kt:408 */
    6      9   
impl crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationInputBuilder {
    7     10   
    /// Sends a request with this input using the given client.
    8     11   
    pub async fn send_with(
    9     12   
        self,
   10     13   
        client: &crate::Client,
   11     14   
    ) -> ::std::result::Result<
   12     15   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
   13     16   
        ::aws_smithy_runtime_api::client::result::SdkError<
   14     17   
            crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
   15     18   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   16     19   
        >,
   17     20   
    > {
   18     21   
        let mut fluent_builder = client.disable_kinesis_streaming_destination();
   19     22   
        fluent_builder.inner = self;
   20     23   
        fluent_builder.send().await
   21     24   
    }
   22     25   
}
   23         -
/// Fluent builder constructing a request to `DisableKinesisStreamingDestination`.
          26  +
/// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `DisableKinesisStreamingDestination`.
   24     27   
///
   25         -
/// <p>Stops replication from the DynamoDB table to the Kinesis data stream. This is done without deleting either of the resources.</p>
          28  +
/// /* FluentBuilderGenerator.kt:130 */<p>Stops replication from the DynamoDB table to the Kinesis data stream. This is done without deleting either of the resources.</p>
          29  +
/* RustType.kt:516 */
   26     30   
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
          31  +
/* FluentBuilderGenerator.kt:270 */
   27     32   
pub struct DisableKinesisStreamingDestinationFluentBuilder {
   28     33   
    handle: ::std::sync::Arc<crate::client::Handle>,
   29     34   
    inner: crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationInputBuilder,
   30     35   
    config_override: ::std::option::Option<crate::config::Builder>,
   31     36   
}
          37  +
/* FluentBuilderGenerator.kt:381 */
   32     38   
impl
   33     39   
    crate::client::customize::internal::CustomizableSend<
   34     40   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
   35     41   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
   36     42   
    > for DisableKinesisStreamingDestinationFluentBuilder
   37     43   
{
   38     44   
    fn send(
   39     45   
        self,
   40     46   
        config_override: crate::config::Builder,
   41     47   
    ) -> crate::client::customize::internal::BoxFuture<
   42     48   
        crate::client::customize::internal::SendResult<
   43     49   
            crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
   44     50   
            crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
   45     51   
        >,
   46     52   
    > {
   47     53   
        ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
   48     54   
    }
   49     55   
}
          56  +
/* FluentBuilderGenerator.kt:282 */
   50     57   
impl DisableKinesisStreamingDestinationFluentBuilder {
          58  +
    /* FluentBuilderGenerator.kt:288 */
   51     59   
    /// Creates a new `DisableKinesisStreamingDestinationFluentBuilder`.
   52     60   
    pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
   53     61   
        Self {
   54     62   
            handle,
   55     63   
            inner: ::std::default::Default::default(),
   56     64   
            config_override: ::std::option::Option::None,
   57     65   
        }
   58     66   
    }
          67  +
    /* FluentBuilderGenerator.kt:301 */
   59     68   
    /// Access the DisableKinesisStreamingDestination as a reference.
   60     69   
    pub fn as_input(&self) -> &crate::operation::disable_kinesis_streaming_destination::builders::DisableKinesisStreamingDestinationInputBuilder {
   61     70   
        &self.inner
   62     71   
    }
          72  +
    /* FluentBuilderGenerator.kt:145 */
   63     73   
    /// Sends the request and returns the response.
   64     74   
    ///
   65     75   
    /// If an error occurs, an `SdkError` will be returned with additional details that
   66     76   
    /// can be matched against.
   67     77   
    ///
   68     78   
    /// By default, any retryable failures will be retried twice. Retry behavior
   69     79   
    /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
   70     80   
    /// set when configuring the client.
   71     81   
    pub async fn send(
   72     82   
        self,
   73     83   
    ) -> ::std::result::Result<
   74     84   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
   75     85   
        ::aws_smithy_runtime_api::client::result::SdkError<
   76     86   
            crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
   77     87   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   78     88   
        >,
   79     89   
    > {
   80     90   
        let input = self
   81     91   
            .inner
   82     92   
            .build()
   83     93   
            .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
   84     94   
        let runtime_plugins = crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestination::operation_runtime_plugins(
   85     95   
            self.handle.runtime_plugins.clone(),
   86     96   
            &self.handle.conf,
   87     97   
            self.config_override,
   88     98   
        );
   89     99   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestination::orchestrate(&runtime_plugins, input).await
   90    100   
    }
   91    101   
   92    102   
    /// Consumes this builder, creating a customizable operation that can be modified before being sent.
   93    103   
    pub fn customize(
   94    104   
        self,
   95    105   
    ) -> crate::client::customize::CustomizableOperation<
   96    106   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationOutput,
   97    107   
        crate::operation::disable_kinesis_streaming_destination::DisableKinesisStreamingDestinationError,
   98    108   
        Self,
   99    109   
    > {
  100    110   
        crate::client::customize::CustomizableOperation::new(self)
  101    111   
    }
         112  +
    /* FluentBuilderGenerator.kt:315 */
  102    113   
    pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
  103    114   
        self.set_config_override(::std::option::Option::Some(config_override.into()));
  104    115   
        self
  105    116   
    }
  106    117   
  107    118   
    pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
  108    119   
        self.config_override = config_override;
  109    120   
        self
  110    121   
    }
  111         -
    /// <p>The name of the DynamoDB table.</p>
         122  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The name of the DynamoDB table.</p>
         123  +
    /* FluentBuilderGenerator.kt:500 */
  112    124   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
  113    125   
        self.inner = self.inner.table_name(input.into());
  114    126   
        self
  115    127   
    }
  116         -
    /// <p>The name of the DynamoDB table.</p>
         128  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The name of the DynamoDB table.</p>
         129  +
    /* FluentBuilderGenerator.kt:500 */
  117    130   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
  118    131   
        self.inner = self.inner.set_table_name(input);
  119    132   
        self
  120    133   
    }
  121         -
    /// <p>The name of the DynamoDB table.</p>
         134  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The name of the DynamoDB table.</p>
         135  +
    /* FluentBuilderGenerator.kt:520 */
  122    136   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
  123    137   
        self.inner.get_table_name()
  124    138   
    }
  125         -
    /// <p>The ARN for a Kinesis data stream.</p>
         139  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The ARN for a Kinesis data stream.</p>
         140  +
    /* FluentBuilderGenerator.kt:500 */
  126    141   
    pub fn stream_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
  127    142   
        self.inner = self.inner.stream_arn(input.into());
  128    143   
        self
  129    144   
    }
  130         -
    /// <p>The ARN for a Kinesis data stream.</p>
         145  +
    /// /* FluentBuilderGenerator.kt:498 */<p>The ARN for a Kinesis data stream.</p>
         146  +
    /* FluentBuilderGenerator.kt:500 */
  131    147   
    pub fn set_stream_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
  132    148   
        self.inner = self.inner.set_stream_arn(input);
  133    149   
        self
  134    150   
    }
  135         -
    /// <p>The ARN for a Kinesis data stream.</p>
         151  +
    /// /* FluentBuilderGenerator.kt:518 */<p>The ARN for a Kinesis data stream.</p>
         152  +
    /* FluentBuilderGenerator.kt:520 */
  136    153   
    pub fn get_stream_arn(&self) -> &::std::option::Option<::std::string::String> {
  137    154   
        self.inner.get_stream_arn()
  138    155   
    }
         156  +
    /* FluentBuilderGenerator.kt:282 */
  139    157   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/enable_kinesis_streaming_destination.rs

@@ -1,1 +40,49 @@
    1      1   
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
           2  +
/* OperationGenerator.kt:77 */
    2      3   
/// Orchestration and serialization glue logic for `EnableKinesisStreamingDestination`.
           4  +
/* RustType.kt:516 */
    3      5   
#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
           6  +
/* RustType.kt:516 */
    4      7   
#[non_exhaustive]
           8  +
/* OperationGenerator.kt:84 */
    5      9   
pub struct EnableKinesisStreamingDestination;
          10  +
/* OperationGenerator.kt:85 */
    6     11   
impl EnableKinesisStreamingDestination {
    7         -
    /// Creates a new `EnableKinesisStreamingDestination`
          12  +
    /// /* OperationGenerator.kt:86 */Creates a new `EnableKinesisStreamingDestination`
          13  +
    /* OperationGenerator.kt:87 */
    8     14   
    pub fn new() -> Self {
          15  +
        /* OperationGenerator.kt:88 */
    9     16   
        Self
          17  +
        /* OperationGenerator.kt:87 */
   10     18   
    }
          19  +
    /* OperationGenerator.kt:138 */
   11     20   
    pub(crate) async fn orchestrate(
   12     21   
        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
   13     22   
        input: crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput,
   14     23   
    ) -> ::std::result::Result<
   15     24   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput,
   16     25   
        ::aws_smithy_runtime_api::client::result::SdkError<
   17     26   
            crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
   18     27   
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
   19     28   
        >,
   20     29   
    > {
@@ -63,72 +399,591 @@
   83     92   
                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
   84     93   
            }
   85     94   
            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
   86     95   
                config_override,
   87     96   
                client_config.config.clone(),
   88     97   
                &client_config.runtime_components,
   89     98   
            ));
   90     99   
        }
   91    100   
        runtime_plugins
   92    101   
    }
         102  +
    /* OperationGenerator.kt:85 */
   93    103   
}
         104  +
/* OperationRuntimePluginGenerator.kt:55 */
   94    105   
impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for EnableKinesisStreamingDestination {
   95    106   
    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
   96    107   
        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("EnableKinesisStreamingDestination");
   97    108   
   98    109   
        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
   99    110   
            EnableKinesisStreamingDestinationRequestSerializer,
  100    111   
        ));
  101    112   
        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
  102    113   
            EnableKinesisStreamingDestinationResponseDeserializer,
  103    114   
        ));
  104    115   
  105    116   
        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
  106    117   
            ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
  107    118   
        ));
  108    119   
  109    120   
        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
  110    121   
            "EnableKinesisStreamingDestination",
  111    122   
            "DynamoDB",
  112    123   
        ));
  113    124   
  114    125   
        ::std::option::Option::Some(cfg.freeze())
  115    126   
    }
  116    127   
  117    128   
    fn runtime_components(
  118    129   
        &self,
  119    130   
        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
  120    131   
    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
  121    132   
        #[allow(unused_mut)]
  122    133   
        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("EnableKinesisStreamingDestination")
  123    134   
            .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
  124    135   
            .with_interceptor(EnableKinesisStreamingDestinationEndpointParamsInterceptor)
  125    136   
            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
  126    137   
                crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
  127    138   
            >::new())
  128    139   
            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
  129    140   
                crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationError,
  130    141   
            >::new());
  131    142   
  132    143   
        ::std::borrow::Cow::Owned(rcb)
  133    144   
    }
  134    145   
}
  135    146   
         147  +
/* ResponseDeserializerGenerator.kt:64 */
  136    148   
#[derive(Debug)]
  137    149   
struct EnableKinesisStreamingDestinationResponseDeserializer;
  138    150   
impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for EnableKinesisStreamingDestinationResponseDeserializer {
  139    151   
    fn deserialize_nonstreaming(
  140    152   
        &self,
  141    153   
        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
  142    154   
    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
  143    155   
        let (success, status) = (response.status().is_success(), response.status().as_u16());
  144    156   
        let headers = response.headers();
  145    157   
        let body = response.body().bytes().expect("body loaded");
  146    158   
        #[allow(unused_mut)]
  147    159   
        let mut force_error = false;
  148    160   
  149    161   
        let parse_result = if !success && status != 200 || force_error {
  150    162   
            crate::protocol_serde::shape_enable_kinesis_streaming_destination::de_enable_kinesis_streaming_destination_http_error(
  151    163   
                status, headers, body,
  152    164   
            )
  153    165   
        } else {
  154    166   
            crate::protocol_serde::shape_enable_kinesis_streaming_destination::de_enable_kinesis_streaming_destination_http_response(
  155    167   
                status, headers, body,
  156    168   
            )
  157    169   
        };
  158    170   
        crate::protocol_serde::type_erase_result(parse_result)
  159    171   
    }
  160    172   
}
         173  +
/* RequestSerializerGenerator.kt:67 */
  161    174   
#[derive(Debug)]
  162    175   
struct EnableKinesisStreamingDestinationRequestSerializer;
  163    176   
impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for EnableKinesisStreamingDestinationRequestSerializer {
  164    177   
    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
  165    178   
    fn serialize_input(
  166    179   
        &self,
  167    180   
        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
  168    181   
        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
  169    182   
    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
  170    183   
        let input = input
  171    184   
            .downcast::<crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput>()
  172    185   
            .expect("correct type");
  173    186   
        let _header_serialization_settings = _cfg
  174    187   
            .load::<crate::serialization_settings::HeaderSerializationSettings>()
  175    188   
            .cloned()
  176    189   
            .unwrap_or_default();
  177    190   
        let mut request_builder = {
  178    191   
            fn uri_base(
  179    192   
                _input: &crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput,
  180    193   
                output: &mut ::std::string::String,
  181    194   
            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
  182    195   
                use ::std::fmt::Write as _;
  183    196   
                ::std::write!(output, "/").expect("formatting should succeed");
  184    197   
                ::std::result::Result::Ok(())
  185    198   
            }
  186    199   
            #[allow(clippy::unnecessary_wraps)]
  187    200   
            fn update_http_builder(
  188    201   
                input: &crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput,
  189    202   
                builder: ::http::request::Builder,
  190    203   
            ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
  191    204   
                let mut uri = ::std::string::String::new();
  192    205   
                uri_base(input, &mut uri)?;
  193    206   
                ::std::result::Result::Ok(builder.method("POST").uri(uri))
  194    207   
            }
  195    208   
            let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
  196    209   
            builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.0");
  197    210   
            builder = _header_serialization_settings.set_default_header(
  198    211   
                builder,
  199    212   
                ::http::header::HeaderName::from_static("x-amz-target"),
  200    213   
                "DynamoDB_20120810.EnableKinesisStreamingDestination",
  201    214   
            );
  202    215   
            builder
  203    216   
        };
  204    217   
        let body = ::aws_smithy_types::body::SdkBody::from(
  205    218   
            crate::protocol_serde::shape_enable_kinesis_streaming_destination::ser_enable_kinesis_streaming_destination_input(&input)?,
  206    219   
        );
  207    220   
        if let Some(content_length) = body.content_length() {
  208    221   
            let content_length = content_length.to_string();
  209    222   
            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
  210    223   
        }
  211    224   
        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
  212    225   
    }
  213    226   
}
         227  +
/* EndpointParamsInterceptorGenerator.kt:86 */
  214    228   
#[derive(Debug)]
  215    229   
struct EnableKinesisStreamingDestinationEndpointParamsInterceptor;
  216    230   
  217    231   
impl ::aws_smithy_runtime_api::client::interceptors::Intercept for EnableKinesisStreamingDestinationEndpointParamsInterceptor {
  218    232   
    fn name(&self) -> &'static str {
  219    233   
        "EnableKinesisStreamingDestinationEndpointParamsInterceptor"
  220    234   
    }
  221    235   
  222    236   
    fn read_before_execution(
  223    237   
        &self,
  224    238   
        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
  225    239   
            '_,
  226    240   
            ::aws_smithy_runtime_api::client::interceptors::context::Input,
  227    241   
            ::aws_smithy_runtime_api::client::interceptors::context::Output,
  228    242   
            ::aws_smithy_runtime_api::client::interceptors::context::Error,
  229    243   
        >,
  230    244   
        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
  231    245   
    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
  232    246   
        let _input = context
  233    247   
            .input()
  234    248   
            .downcast_ref::<EnableKinesisStreamingDestinationInput>()
  235    249   
            .ok_or("failed to downcast to EnableKinesisStreamingDestinationInput")?;
  236    250   
  237    251   
        let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
  238    252   
            ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
  239    253   
        })?;
  240    254   
        cfg.interceptor_state()
  241    255   
            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
  242    256   
        ::std::result::Result::Ok(())
  243    257   
    }
  244    258   
}
  245    259   
  246    260   
// The get_* functions below are generated from JMESPath expressions in the
  247    261   
// operationContextParams trait. They target the operation's input shape.
  248    262   
         263  +
/* OperationErrorGenerator.kt:79 */
  249    264   
/// Error type for the `EnableKinesisStreamingDestinationError` operation.
         265  +
/* RustType.kt:516 */
  250    266   
#[non_exhaustive]
         267  +
/* RustType.kt:516 */
  251    268   
#[derive(::std::fmt::Debug)]
  252         -
pub enum EnableKinesisStreamingDestinationError {
  253         -
    /// <p>An error occurred on the server side.</p>
         269  +
pub /* OperationErrorGenerator.kt:81 */ enum EnableKinesisStreamingDestinationError {
         270  +
    /// /* OperationErrorGenerator.kt:83 */<p>An error occurred on the server side.</p>
         271  +
    /* OperationErrorGenerator.kt:86 */
  254    272   
    InternalServerError(crate::types::error::InternalServerError),
         273  +
    /* OperationErrorGenerator.kt:83 */
  255    274   
    #[allow(missing_docs)] // documentation missing in model
         275  +
    /* OperationErrorGenerator.kt:86 */
  256    276   
    InvalidEndpointError(crate::types::error::InvalidEndpointError),
  257         -
    /// <p>There is no limit to the number of daily on-demand backups that can be taken.</p>
         277  +
    /// /* OperationErrorGenerator.kt:83 */<p>There is no limit to the number of daily on-demand backups that can be taken.</p>
  258    278   
    /// <p>Up to 50 simultaneous table operations are allowed per account. These operations include <code>CreateTable</code>, <code>UpdateTable</code>, <code>DeleteTable</code>,<code>UpdateTimeToLive</code>, <code>RestoreTableFromBackup</code>, and <code>RestoreTableToPointInTime</code>.</p>
  259    279   
    /// <p>The only exception is when you are creating a table with one or more secondary indexes. You can have up to 25 such requests running at a time; however, if the table or index specifications are complex, DynamoDB might temporarily reduce the number of concurrent operations.</p>
  260    280   
    /// <p>There is a soft account quota of 256 tables.</p>
         281  +
    /* OperationErrorGenerator.kt:86 */
  261    282   
    LimitExceededError(crate::types::error::LimitExceededError),
  262         -
    /// <p>The operation conflicts with the resource's availability. For example, you attempted to recreate an existing table, or tried to delete a table currently in the <code>CREATING</code> state.</p>
         283  +
    /// /* OperationErrorGenerator.kt:83 */<p>The operation conflicts with the resource's availability. For example, you attempted to recreate an existing table, or tried to delete a table currently in the <code>CREATING</code> state.</p>
         284  +
    /* OperationErrorGenerator.kt:86 */
  263    285   
    ResourceInUseError(crate::types::error::ResourceInUseError),
  264         -
    /// <p>The operation tried to access a nonexistent table or index. The resource might not be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
         286  +
    /// /* OperationErrorGenerator.kt:83 */<p>The operation tried to access a nonexistent table or index. The resource might not be specified correctly, or its status might not be <code>ACTIVE</code>.</p>
         287  +
    /* OperationErrorGenerator.kt:86 */
  265    288   
    ResourceNotFoundError(crate::types::error::ResourceNotFoundError),
         289  +
    /* OperationErrorGenerator.kt:88 */
  266    290   
    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
  267    291   
    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
  268    292   
    variable wildcard pattern and check `.code()`:
  269    293   
     \
  270    294   
    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
  271    295   
     \
  272    296   
    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-EnableKinesisStreamingDestinationError) for what information is available for the error.")]
  273    297   
    Unhandled(crate::error::sealed_unhandled::Unhandled),
         298  +
    /* OperationErrorGenerator.kt:81 */
  274    299   
}
         300  +
/* OperationErrorGenerator.kt:218 */
  275    301   
impl EnableKinesisStreamingDestinationError {
         302  +
    /* OperationErrorGenerator.kt:219 */
  276    303   
    /// Creates the `EnableKinesisStreamingDestinationError::Unhandled` variant from any error type.
  277    304   
    pub fn unhandled(
  278    305   
        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
  279    306   
    ) -> Self {
  280    307   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  281    308   
            source: err.into(),
  282    309   
            meta: ::std::default::Default::default(),
  283    310   
        })
  284    311   
    }
  285    312   
  286    313   
    /// Creates the `EnableKinesisStreamingDestinationError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
  287    314   
    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
  288    315   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  289    316   
            source: err.clone().into(),
  290    317   
            meta: err,
  291    318   
        })
  292    319   
    }
  293         -
    ///
         320  +
    /// /* OperationErrorGenerator.kt:236 */
  294    321   
    /// Returns error metadata, which includes the error code, message,
  295    322   
    /// request ID, and potentially additional information.
  296    323   
    ///
         324  +
    /* OperationErrorGenerator.kt:242 */
  297    325   
    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         326  +
        /* OperationErrorGenerator.kt:243 */
  298    327   
        match self {
         328  +
            /* OperationErrorGenerator.kt:246 */
  299    329   
            Self::InternalServerError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         330  +
            /* OperationErrorGenerator.kt:246 */
  300    331   
            Self::InvalidEndpointError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         332  +
            /* OperationErrorGenerator.kt:246 */
  301    333   
            Self::LimitExceededError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         334  +
            /* OperationErrorGenerator.kt:246 */
  302    335   
            Self::ResourceInUseError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
         336  +
            /* OperationErrorGenerator.kt:246 */
  303    337   
            Self::ResourceNotFoundError(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
  304         -
            Self::Unhandled(e) => &e.meta,
         338  +
            /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
         339  +
            /* OperationErrorGenerator.kt:243 */
  305    340   
        }
         341  +
        /* OperationErrorGenerator.kt:242 */
  306    342   
    }
         343  +
    /* OperationErrorGenerator.kt:257 */
  307    344   
    /// Returns `true` if the error kind is `EnableKinesisStreamingDestinationError::InternalServerError`.
         345  +
    /* OperationErrorGenerator.kt:258 */
  308    346   
    pub fn is_internal_server_error(&self) -> bool {
         347  +
        /* OperationErrorGenerator.kt:259 */
  309    348   
        matches!(self, Self::InternalServerError(_))
         349  +
        /* OperationErrorGenerator.kt:258 */
  310    350   
    }
         351  +
    /* OperationErrorGenerator.kt:257 */
  311    352   
    /// Returns `true` if the error kind is `EnableKinesisStreamingDestinationError::InvalidEndpointError`.
         353  +
    /* OperationErrorGenerator.kt:258 */
  312    354   
    pub fn is_invalid_endpoint_error(&self) -> bool {
         355  +
        /* OperationErrorGenerator.kt:259 */
  313    356   
        matches!(self, Self::InvalidEndpointError(_))
         357  +
        /* OperationErrorGenerator.kt:258 */
  314    358   
    }
         359  +
    /* OperationErrorGenerator.kt:257 */
  315    360   
    /// Returns `true` if the error kind is `EnableKinesisStreamingDestinationError::LimitExceededError`.
         361  +
    /* OperationErrorGenerator.kt:258 */
  316    362   
    pub fn is_limit_exceeded_error(&self) -> bool {
         363  +
        /* OperationErrorGenerator.kt:259 */
  317    364   
        matches!(self, Self::LimitExceededError(_))
         365  +
        /* OperationErrorGenerator.kt:258 */
  318    366   
    }
         367  +
    /* OperationErrorGenerator.kt:257 */
  319    368   
    /// Returns `true` if the error kind is `EnableKinesisStreamingDestinationError::ResourceInUseError`.
         369  +
    /* OperationErrorGenerator.kt:258 */
  320    370   
    pub fn is_resource_in_use_error(&self) -> bool {
         371  +
        /* OperationErrorGenerator.kt:259 */
  321    372   
        matches!(self, Self::ResourceInUseError(_))
         373  +
        /* OperationErrorGenerator.kt:258 */
  322    374   
    }
         375  +
    /* OperationErrorGenerator.kt:257 */
  323    376   
    /// Returns `true` if the error kind is `EnableKinesisStreamingDestinationError::ResourceNotFoundError`.
         377  +
    /* OperationErrorGenerator.kt:258 */
  324    378   
    pub fn is_resource_not_found_error(&self) -> bool {
         379  +
        /* OperationErrorGenerator.kt:259 */
  325    380   
        matches!(self, Self::ResourceNotFoundError(_))
         381  +
        /* OperationErrorGenerator.kt:258 */
  326    382   
    }
         383  +
    /* OperationErrorGenerator.kt:218 */
  327    384   
}
         385  +
/* OperationErrorGenerator.kt:269 */
  328    386   
impl ::std::error::Error for EnableKinesisStreamingDestinationError {
         387  +
    /* OperationErrorGenerator.kt:270 */
  329    388   
    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         389  +
        /* OperationErrorGenerator.kt:318 */
  330    390   
        match self {
  331         -
            Self::InternalServerError(_inner) => ::std::option::Option::Some(_inner),
  332         -
            Self::InvalidEndpointError(_inner) => ::std::option::Option::Some(_inner),
  333         -
            Self::LimitExceededError(_inner) => ::std::option::Option::Some(_inner),
  334         -
            Self::ResourceInUseError(_inner) => ::std::option::Option::Some(_inner),
  335         -
            Self::ResourceNotFoundError(_inner) => ::std::option::Option::Some(_inner),
  336         -
            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
         391  +
            /* OperationErrorGenerator.kt:321 */
         392  +
            Self::InternalServerError(_inner) =>
         393  +
            /* OperationErrorGenerator.kt:283 */
         394  +
            {
         395  +
                ::std::option::Option::Some(_inner)
         396  +
            }
         397  +
            ,
         398  +
            /* OperationErrorGenerator.kt:321 */
         399  +
            Self::InvalidEndpointError(_inner) =>
         400  +
            /* OperationErrorGenerator.kt:283 */
         401  +
            {
         402  +
                ::std::option::Option::Some(_inner)
         403  +
            }
         404  +
            ,
         405  +
            /* OperationErrorGenerator.kt:321 */
         406  +
            Self::LimitExceededError(_inner) =>
         407  +
            /* OperationErrorGenerator.kt:283 */
         408  +
            {
         409  +
                ::std::option::Option::Some(_inner)
         410  +
            }
         411  +
            ,
         412  +
            /* OperationErrorGenerator.kt:321 */
         413  +
            Self::ResourceInUseError(_inner) =>
         414  +
            /* OperationErrorGenerator.kt:283 */
         415  +
            {
         416  +
                ::std::option::Option::Some(_inner)
         417  +
            }
         418  +
            ,
         419  +
            /* OperationErrorGenerator.kt:321 */
         420  +
            Self::ResourceNotFoundError(_inner) =>
         421  +
            /* OperationErrorGenerator.kt:283 */
         422  +
            {
         423  +
                ::std::option::Option::Some(_inner)
         424  +
            }
         425  +
            ,
         426  +
            /* OperationErrorGenerator.kt:326 */
         427  +
            Self::Unhandled(_inner) => {
         428  +
                /* OperationErrorGenerator.kt:279 */
         429  +
                ::std::option::Option::Some(&*_inner.source)
         430  +
                /* OperationErrorGenerator.kt:326 */
         431  +
            } /* OperationErrorGenerator.kt:318 */
  337    432   
        }
         433  +
        /* OperationErrorGenerator.kt:270 */
  338    434   
    }
         435  +
    /* OperationErrorGenerator.kt:269 */
  339    436   
}
         437  +
/* OperationErrorGenerator.kt:133 */
  340    438   
impl ::std::fmt::Display for EnableKinesisStreamingDestinationError {
         439  +
    /* OperationErrorGenerator.kt:134 */
  341    440   
    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         441  +
        /* OperationErrorGenerator.kt:318 */
  342    442   
        match self {
  343         -
            Self::InternalServerError(_inner) => _inner.fmt(f),
  344         -
            Self::InvalidEndpointError(_inner) => _inner.fmt(f),
  345         -
            Self::LimitExceededError(_inner) => _inner.fmt(f),
  346         -
            Self::ResourceInUseError(_inner) => _inner.fmt(f),
  347         -
            Self::ResourceNotFoundError(_inner) => _inner.fmt(f),
         443  +
            /* OperationErrorGenerator.kt:321 */
         444  +
            Self::InternalServerError(_inner) =>
         445  +
            /* OperationErrorGenerator.kt:151 */
         446  +
            {
         447  +
                _inner.fmt(f)
         448  +
            }
         449  +
            ,
         450  +
            /* OperationErrorGenerator.kt:321 */
         451  +
            Self::InvalidEndpointError(_inner) =>
         452  +
            /* OperationErrorGenerator.kt:151 */
         453  +
            {
         454  +
                _inner.fmt(f)
         455  +
            }
         456  +
            ,
         457  +
            /* OperationErrorGenerator.kt:321 */
         458  +
            Self::LimitExceededError(_inner) =>
         459  +
            /* OperationErrorGenerator.kt:151 */
         460  +
            {
         461  +
                _inner.fmt(f)
         462  +
            }
         463  +
            ,
         464  +
            /* OperationErrorGenerator.kt:321 */
         465  +
            Self::ResourceInUseError(_inner) =>
         466  +
            /* OperationErrorGenerator.kt:151 */
         467  +
            {
         468  +
                _inner.fmt(f)
         469  +
            }
         470  +
            ,
         471  +
            /* OperationErrorGenerator.kt:321 */
         472  +
            Self::ResourceNotFoundError(_inner) =>
         473  +
            /* OperationErrorGenerator.kt:151 */
         474  +
            {
         475  +
                _inner.fmt(f)
         476  +
            }
         477  +
            ,
         478  +
            /* OperationErrorGenerator.kt:326 */
  348    479   
            Self::Unhandled(_inner) => {
         480  +
                /* OperationErrorGenerator.kt:139 */
  349    481   
                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
  350    482   
                    write!(f, "unhandled error ({code})")
  351    483   
                } else {
  352    484   
                    f.write_str("unhandled error")
  353    485   
                }
         486  +
                /* OperationErrorGenerator.kt:326 */
         487  +
            } /* OperationErrorGenerator.kt:318 */
  354    488   
        }
         489  +
        /* OperationErrorGenerator.kt:134 */
  355    490   
    }
  356         -
    }
         491  +
    /* OperationErrorGenerator.kt:133 */
  357    492   
}
         493  +
/* OperationErrorGenerator.kt:182 */
  358    494   
impl ::aws_smithy_types::retry::ProvideErrorKind for EnableKinesisStreamingDestinationError {
         495  +
    /* OperationErrorGenerator.kt:186 */
  359    496   
    fn code(&self) -> ::std::option::Option<&str> {
         497  +
        /* OperationErrorGenerator.kt:187 */
  360    498   
        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         499  +
        /* OperationErrorGenerator.kt:186 */
  361    500   
    }
         501  +
    /* OperationErrorGenerator.kt:190 */
  362    502   
    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         503  +
        /* OperationErrorGenerator.kt:197 */
  363    504   
        ::std::option::Option::None
         505  +
        /* OperationErrorGenerator.kt:190 */
  364    506   
    }
         507  +
    /* OperationErrorGenerator.kt:182 */
  365    508   
}
         509  +
/* OperationErrorGenerator.kt:163 */
  366    510   
impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for EnableKinesisStreamingDestinationError {
         511  +
    /* OperationErrorGenerator.kt:164 */
  367    512   
    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         513  +
        /* OperationErrorGenerator.kt:318 */
  368    514   
        match self {
  369         -
            Self::InternalServerError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  370         -
            Self::InvalidEndpointError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  371         -
            Self::LimitExceededError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  372         -
            Self::ResourceInUseError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  373         -
            Self::ResourceNotFoundError(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
  374         -
            Self::Unhandled(_inner) => &_inner.meta,
         515  +
            /* OperationErrorGenerator.kt:321 */
         516  +
            Self::InternalServerError(_inner) =>
         517  +
            /* OperationErrorGenerator.kt:169 */
         518  +
            {
         519  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         520  +
            }
         521  +
            ,
         522  +
            /* OperationErrorGenerator.kt:321 */
         523  +
            Self::InvalidEndpointError(_inner) =>
         524  +
            /* OperationErrorGenerator.kt:169 */
         525  +
            {
         526  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         527  +
            }
         528  +
            ,
         529  +
            /* OperationErrorGenerator.kt:321 */
         530  +
            Self::LimitExceededError(_inner) =>
         531  +
            /* OperationErrorGenerator.kt:169 */
         532  +
            {
         533  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         534  +
            }
         535  +
            ,
         536  +
            /* OperationErrorGenerator.kt:321 */
         537  +
            Self::ResourceInUseError(_inner) =>
         538  +
            /* OperationErrorGenerator.kt:169 */
         539  +
            {
         540  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         541  +
            }
         542  +
            ,
         543  +
            /* OperationErrorGenerator.kt:321 */
         544  +
            Self::ResourceNotFoundError(_inner) =>
         545  +
            /* OperationErrorGenerator.kt:169 */
         546  +
            {
         547  +
                ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner)
         548  +
            }
         549  +
            ,
         550  +
            /* OperationErrorGenerator.kt:326 */
         551  +
            Self::Unhandled(_inner) => {
         552  +
                /* OperationErrorGenerator.kt:168 */
         553  +
                &_inner.meta
         554  +
                /* OperationErrorGenerator.kt:326 */
         555  +
            } /* OperationErrorGenerator.kt:318 */
  375    556   
        }
         557  +
        /* OperationErrorGenerator.kt:164 */
  376    558   
    }
         559  +
    /* OperationErrorGenerator.kt:163 */
  377    560   
}
         561  +
/* OperationErrorGenerator.kt:109 */
  378    562   
impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for EnableKinesisStreamingDestinationError {
         563  +
    /* OperationErrorGenerator.kt:110 */
  379    564   
    fn create_unhandled_error(
  380    565   
        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
  381    566   
        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
  382    567   
    ) -> Self {
         568  +
        /* OperationErrorGenerator.kt:121 */
  383    569   
        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
  384    570   
            source,
  385    571   
            meta: meta.unwrap_or_default(),
  386    572   
        })
         573  +
        /* OperationErrorGenerator.kt:110 */
  387    574   
    }
         575  +
    /* OperationErrorGenerator.kt:109 */
  388    576   
}
  389    577   
         578  +
/* CodegenDelegator.kt:255 */
  390    579   
pub use crate::operation::enable_kinesis_streaming_destination::_enable_kinesis_streaming_destination_output::EnableKinesisStreamingDestinationOutput;
  391    580   
         581  +
/* CodegenDelegator.kt:255 */
  392    582   
pub use crate::operation::enable_kinesis_streaming_destination::_enable_kinesis_streaming_destination_input::EnableKinesisStreamingDestinationInput;
  393    583   
         584  +
/* RustModule.kt:172 */
  394    585   
mod _enable_kinesis_streaming_destination_input;
  395    586   
         587  +
/* RustModule.kt:172 */
  396    588   
mod _enable_kinesis_streaming_destination_output;
  397    589   
  398         -
/// Builders
         590  +
/// /* CodegenDelegator.kt:51 */Builders
  399    591   
pub mod builders;

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/enable_kinesis_streaming_destination/_enable_kinesis_streaming_destination_input.rs

@@ -1,1 +80,129 @@
    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 EnableKinesisStreamingDestinationInput {
    6         -
    /// <p>The name of the DynamoDB table.</p>
           8  +
pub /* StructureGenerator.kt:201 */ struct EnableKinesisStreamingDestinationInput {
           9  +
    /// /* StructureGenerator.kt:231 */<p>The name of the DynamoDB table.</p>
    7     10   
    pub table_name: ::std::option::Option<::std::string::String>,
    8         -
    /// <p>The ARN for a Kinesis data stream.</p>
          11  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for a Kinesis data stream.</p>
    9     12   
    pub stream_arn: ::std::option::Option<::std::string::String>,
          13  +
    /* StructureGenerator.kt:201 */
   10     14   
}
          15  +
/* StructureGenerator.kt:135 */
   11     16   
impl EnableKinesisStreamingDestinationInput {
   12         -
    /// <p>The name of the DynamoDB table.</p>
          17  +
    /// /* StructureGenerator.kt:231 */<p>The name of the DynamoDB table.</p>
          18  +
    /* StructureGenerator.kt:166 */
   13     19   
    pub fn table_name(&self) -> ::std::option::Option<&str> {
          20  +
        /* StructureGenerator.kt:169 */
   14     21   
        self.table_name.as_deref()
          22  +
        /* StructureGenerator.kt:166 */
   15     23   
    }
   16         -
    /// <p>The ARN for a Kinesis data stream.</p>
          24  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for a Kinesis data stream.</p>
          25  +
    /* StructureGenerator.kt:166 */
   17     26   
    pub fn stream_arn(&self) -> ::std::option::Option<&str> {
          27  +
        /* StructureGenerator.kt:169 */
   18     28   
        self.stream_arn.as_deref()
          29  +
        /* StructureGenerator.kt:166 */
   19     30   
    }
          31  +
    /* StructureGenerator.kt:135 */
   20     32   
}
          33  +
/* ClientCodegenVisitor.kt:237 */
   21     34   
impl EnableKinesisStreamingDestinationInput {
   22         -
    /// Creates a new builder-style object to manufacture [`EnableKinesisStreamingDestinationInput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput).
          35  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EnableKinesisStreamingDestinationInput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput).
          36  +
    /* BuilderGenerator.kt:175 */
   23     37   
    pub fn builder() -> crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationInputBuilder {
          38  +
        /* BuilderGenerator.kt:176 */
   24     39   
        crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationInputBuilder::default()
          40  +
        /* BuilderGenerator.kt:175 */
   25     41   
    }
          42  +
    /* ClientCodegenVisitor.kt:237 */
   26     43   
}
   27     44   
   28         -
/// A builder for [`EnableKinesisStreamingDestinationInput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput).
          45  +
/// /* BuilderGenerator.kt:342 */A builder for [`EnableKinesisStreamingDestinationInput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput).
          46  +
/* RustType.kt:516 */
   29     47   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          48  +
/* RustType.kt:516 */
   30     49   
#[non_exhaustive]
          50  +
/* BuilderGenerator.kt:345 */
   31     51   
pub struct EnableKinesisStreamingDestinationInputBuilder {
   32         -
    pub(crate) table_name: ::std::option::Option<::std::string::String>,
   33         -
    pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          52  +
    /* BuilderGenerator.kt:275 */ pub(crate) table_name: ::std::option::Option<::std::string::String>,
          53  +
    /* BuilderGenerator.kt:275 */ pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          54  +
    /* BuilderGenerator.kt:345 */
   34     55   
}
          56  +
/* BuilderGenerator.kt:355 */
   35     57   
impl EnableKinesisStreamingDestinationInputBuilder {
   36         -
    /// <p>The name of the DynamoDB table.</p>
   37         -
    /// This field is required.
          58  +
    /// /* BuilderGenerator.kt:286 */<p>The name of the DynamoDB table.</p>
          59  +
    /// /* BuilderGenerator.kt:288 */This field is required.
          60  +
    /* BuilderGenerator.kt:291 */
   38     61   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          62  +
        /* BuilderGenerator.kt:292 */
   39     63   
        self.table_name = ::std::option::Option::Some(input.into());
          64  +
        /* BuilderGenerator.kt:293 */
   40     65   
        self
          66  +
        /* BuilderGenerator.kt:291 */
   41     67   
    }
   42         -
    /// <p>The name of the DynamoDB table.</p>
          68  +
    /// /* BuilderGenerator.kt:312 */<p>The name of the DynamoDB table.</p>
          69  +
    /* BuilderGenerator.kt:314 */
   43     70   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          71  +
        /* BuilderGenerator.kt:315 */
   44     72   
        self.table_name = input;
   45     73   
        self
          74  +
        /* BuilderGenerator.kt:314 */
   46     75   
    }
   47         -
    /// <p>The name of the DynamoDB table.</p>
          76  +
    /// /* BuilderGenerator.kt:334 */<p>The name of the DynamoDB table.</p>
          77  +
    /* BuilderGenerator.kt:336 */
   48     78   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
          79  +
        /* BuilderGenerator.kt:337 */
   49     80   
        &self.table_name
          81  +
        /* BuilderGenerator.kt:336 */
   50     82   
    }
   51         -
    /// <p>The ARN for a Kinesis data stream.</p>
   52         -
    /// This field is required.
          83  +
    /// /* BuilderGenerator.kt:286 */<p>The ARN for a Kinesis data stream.</p>
          84  +
    /// /* BuilderGenerator.kt:288 */This field is required.
          85  +
    /* BuilderGenerator.kt:291 */
   53     86   
    pub fn stream_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          87  +
        /* BuilderGenerator.kt:292 */
   54     88   
        self.stream_arn = ::std::option::Option::Some(input.into());
          89  +
        /* BuilderGenerator.kt:293 */
   55     90   
        self
          91  +
        /* BuilderGenerator.kt:291 */
   56     92   
    }
   57         -
    /// <p>The ARN for a Kinesis data stream.</p>
          93  +
    /// /* BuilderGenerator.kt:312 */<p>The ARN for a Kinesis data stream.</p>
          94  +
    /* BuilderGenerator.kt:314 */
   58     95   
    pub fn set_stream_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          96  +
        /* BuilderGenerator.kt:315 */
   59     97   
        self.stream_arn = input;
   60     98   
        self
          99  +
        /* BuilderGenerator.kt:314 */
   61    100   
    }
   62         -
    /// <p>The ARN for a Kinesis data stream.</p>
         101  +
    /// /* BuilderGenerator.kt:334 */<p>The ARN for a Kinesis data stream.</p>
         102  +
    /* BuilderGenerator.kt:336 */
   63    103   
    pub fn get_stream_arn(&self) -> &::std::option::Option<::std::string::String> {
         104  +
        /* BuilderGenerator.kt:337 */
   64    105   
        &self.stream_arn
         106  +
        /* BuilderGenerator.kt:336 */
   65    107   
    }
   66         -
    /// Consumes the builder and constructs a [`EnableKinesisStreamingDestinationInput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput).
         108  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EnableKinesisStreamingDestinationInput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput).
         109  +
    /* BuilderGenerator.kt:253 */
   67    110   
    pub fn build(
   68    111   
        self,
   69    112   
    ) -> ::std::result::Result<
   70    113   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput,
   71    114   
        ::aws_smithy_types::error::operation::BuildError,
   72    115   
    > {
         116  +
        /* BuilderGenerator.kt:254 */
   73    117   
        ::std::result::Result::Ok(
         118  +
            /* BuilderGenerator.kt:477 */
   74    119   
            crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationInput {
   75         -
                table_name: self.table_name,
         120  +
                /* BuilderGenerator.kt:481 */ table_name: self.table_name,
         121  +
                /* BuilderGenerator.kt:481 */
   76    122   
                stream_arn: self.stream_arn,
   77         -
            },
         123  +
                /* BuilderGenerator.kt:477 */
         124  +
            }, /* BuilderGenerator.kt:254 */
   78    125   
        )
         126  +
        /* BuilderGenerator.kt:253 */
   79    127   
    }
         128  +
    /* BuilderGenerator.kt:355 */
   80    129   
}

tmp-codegen-diff/codegen-client-test/dynamo/rust-client-codegen/src/operation/enable_kinesis_streaming_destination/_enable_kinesis_streaming_destination_output.rs

@@ -1,1 +93,156 @@
    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 EnableKinesisStreamingDestinationOutput {
    6         -
    /// <p>The name of the table being modified.</p>
           8  +
pub /* StructureGenerator.kt:201 */ struct EnableKinesisStreamingDestinationOutput {
           9  +
    /// /* StructureGenerator.kt:231 */<p>The name of the table being modified.</p>
    7     10   
    pub table_name: ::std::option::Option<::std::string::String>,
    8         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
          11  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for the specific Kinesis data stream.</p>
    9     12   
    pub stream_arn: ::std::option::Option<::std::string::String>,
   10         -
    /// <p>The current status of the replication.</p>
          13  +
    /// /* StructureGenerator.kt:231 */<p>The current status of the replication.</p>
   11     14   
    pub destination_status: ::std::option::Option<crate::types::DestinationStatus>,
          15  +
    /* StructureGenerator.kt:201 */
   12     16   
}
          17  +
/* StructureGenerator.kt:135 */
   13     18   
impl EnableKinesisStreamingDestinationOutput {
   14         -
    /// <p>The name of the table being modified.</p>
          19  +
    /// /* StructureGenerator.kt:231 */<p>The name of the table being modified.</p>
          20  +
    /* StructureGenerator.kt:166 */
   15     21   
    pub fn table_name(&self) -> ::std::option::Option<&str> {
          22  +
        /* StructureGenerator.kt:169 */
   16     23   
        self.table_name.as_deref()
          24  +
        /* StructureGenerator.kt:166 */
   17     25   
    }
   18         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
          26  +
    /// /* StructureGenerator.kt:231 */<p>The ARN for the specific Kinesis data stream.</p>
          27  +
    /* StructureGenerator.kt:166 */
   19     28   
    pub fn stream_arn(&self) -> ::std::option::Option<&str> {
          29  +
        /* StructureGenerator.kt:169 */
   20     30   
        self.stream_arn.as_deref()
          31  +
        /* StructureGenerator.kt:166 */
   21     32   
    }
   22         -
    /// <p>The current status of the replication.</p>
          33  +
    /// /* StructureGenerator.kt:231 */<p>The current status of the replication.</p>
          34  +
    /* StructureGenerator.kt:166 */
   23     35   
    pub fn destination_status(&self) -> ::std::option::Option<&crate::types::DestinationStatus> {
          36  +
        /* StructureGenerator.kt:170 */
   24     37   
        self.destination_status.as_ref()
          38  +
        /* StructureGenerator.kt:166 */
   25     39   
    }
          40  +
    /* StructureGenerator.kt:135 */
   26     41   
}
          42  +
/* ClientCodegenVisitor.kt:237 */
   27     43   
impl EnableKinesisStreamingDestinationOutput {
   28         -
    /// Creates a new builder-style object to manufacture [`EnableKinesisStreamingDestinationOutput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput).
          44  +
    /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EnableKinesisStreamingDestinationOutput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput).
          45  +
    /* BuilderGenerator.kt:175 */
   29     46   
    pub fn builder() -> crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationOutputBuilder {
          47  +
        /* BuilderGenerator.kt:176 */
   30     48   
        crate::operation::enable_kinesis_streaming_destination::builders::EnableKinesisStreamingDestinationOutputBuilder::default()
          49  +
        /* BuilderGenerator.kt:175 */
   31     50   
    }
          51  +
    /* ClientCodegenVisitor.kt:237 */
   32     52   
}
   33     53   
   34         -
/// A builder for [`EnableKinesisStreamingDestinationOutput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput).
          54  +
/// /* BuilderGenerator.kt:342 */A builder for [`EnableKinesisStreamingDestinationOutput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput).
          55  +
/* RustType.kt:516 */
   35     56   
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
          57  +
/* RustType.kt:516 */
   36     58   
#[non_exhaustive]
          59  +
/* BuilderGenerator.kt:345 */
   37     60   
pub struct EnableKinesisStreamingDestinationOutputBuilder {
   38         -
    pub(crate) table_name: ::std::option::Option<::std::string::String>,
   39         -
    pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          61  +
    /* BuilderGenerator.kt:275 */ pub(crate) table_name: ::std::option::Option<::std::string::String>,
          62  +
    /* BuilderGenerator.kt:275 */ pub(crate) stream_arn: ::std::option::Option<::std::string::String>,
          63  +
    /* BuilderGenerator.kt:275 */
   40     64   
    pub(crate) destination_status: ::std::option::Option<crate::types::DestinationStatus>,
          65  +
    /* BuilderGenerator.kt:345 */
   41     66   
}
          67  +
/* BuilderGenerator.kt:355 */
   42     68   
impl EnableKinesisStreamingDestinationOutputBuilder {
   43         -
    /// <p>The name of the table being modified.</p>
          69  +
    /// /* BuilderGenerator.kt:286 */<p>The name of the table being modified.</p>
          70  +
    /* BuilderGenerator.kt:291 */
   44     71   
    pub fn table_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          72  +
        /* BuilderGenerator.kt:292 */
   45     73   
        self.table_name = ::std::option::Option::Some(input.into());
          74  +
        /* BuilderGenerator.kt:293 */
   46     75   
        self
          76  +
        /* BuilderGenerator.kt:291 */
   47     77   
    }
   48         -
    /// <p>The name of the table being modified.</p>
          78  +
    /// /* BuilderGenerator.kt:312 */<p>The name of the table being modified.</p>
          79  +
    /* BuilderGenerator.kt:314 */
   49     80   
    pub fn set_table_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
          81  +
        /* BuilderGenerator.kt:315 */
   50     82   
        self.table_name = input;
   51     83   
        self
          84  +
        /* BuilderGenerator.kt:314 */
   52     85   
    }
   53         -
    /// <p>The name of the table being modified.</p>
          86  +
    /// /* BuilderGenerator.kt:334 */<p>The name of the table being modified.</p>
          87  +
    /* BuilderGenerator.kt:336 */
   54     88   
    pub fn get_table_name(&self) -> &::std::option::Option<::std::string::String> {
          89  +
        /* BuilderGenerator.kt:337 */
   55     90   
        &self.table_name
          91  +
        /* BuilderGenerator.kt:336 */
   56     92   
    }
   57         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
          93  +
    /// /* BuilderGenerator.kt:286 */<p>The ARN for the specific Kinesis data stream.</p>
          94  +
    /* BuilderGenerator.kt:291 */
   58     95   
    pub fn stream_arn(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
          96  +
        /* BuilderGenerator.kt:292 */
   59     97   
        self.stream_arn = ::std::option::Option::Some(input.into());
          98  +
        /* BuilderGenerator.kt:293 */
   60     99   
        self
         100  +
        /* BuilderGenerator.kt:291 */
   61    101   
    }
   62         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
         102  +
    /// /* BuilderGenerator.kt:312 */<p>The ARN for the specific Kinesis data stream.</p>
         103  +
    /* BuilderGenerator.kt:314 */
   63    104   
    pub fn set_stream_arn(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         105  +
        /* BuilderGenerator.kt:315 */
   64    106   
        self.stream_arn = input;
   65    107   
        self
         108  +
        /* BuilderGenerator.kt:314 */
   66    109   
    }
   67         -
    /// <p>The ARN for the specific Kinesis data stream.</p>
         110  +
    /// /* BuilderGenerator.kt:334 */<p>The ARN for the specific Kinesis data stream.</p>
         111  +
    /* BuilderGenerator.kt:336 */
   68    112   
    pub fn get_stream_arn(&self) -> &::std::option::Option<::std::string::String> {
         113  +
        /* BuilderGenerator.kt:337 */
   69    114   
        &self.stream_arn
         115  +
        /* BuilderGenerator.kt:336 */
   70    116   
    }
   71         -
    /// <p>The current status of the replication.</p>
         117  +
    /// /* BuilderGenerator.kt:286 */<p>The current status of the replication.</p>
         118  +
    /* BuilderGenerator.kt:291 */
   72    119   
    pub fn destination_status(mut self, input: crate::types::DestinationStatus) -> Self {
         120  +
        /* BuilderGenerator.kt:292 */
   73    121   
        self.destination_status = ::std::option::Option::Some(input);
         122  +
        /* BuilderGenerator.kt:293 */
   74    123   
        self
         124  +
        /* BuilderGenerator.kt:291 */
   75    125   
    }
   76         -
    /// <p>The current status of the replication.</p>
         126  +
    /// /* BuilderGenerator.kt:312 */<p>The current status of the replication.</p>
         127  +
    /* BuilderGenerator.kt:314 */
   77    128   
    pub fn set_destination_status(mut self, input: ::std::option::Option<crate::types::DestinationStatus>) -> Self {
         129  +
        /* BuilderGenerator.kt:315 */
   78    130   
        self.destination_status = input;
   79    131   
        self
         132  +
        /* BuilderGenerator.kt:314 */
   80    133   
    }
   81         -
    /// <p>The current status of the replication.</p>
         134  +
    /// /* BuilderGenerator.kt:334 */<p>The current status of the replication.</p>
         135  +
    /* BuilderGenerator.kt:336 */
   82    136   
    pub fn get_destination_status(&self) -> &::std::option::Option<crate::types::DestinationStatus> {
         137  +
        /* BuilderGenerator.kt:337 */
   83    138   
        &self.destination_status
         139  +
        /* BuilderGenerator.kt:336 */
   84    140   
    }
   85         -
    /// Consumes the builder and constructs a [`EnableKinesisStreamingDestinationOutput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput).
         141  +
    /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EnableKinesisStreamingDestinationOutput`](crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput).
         142  +
    /* BuilderGenerator.kt:253 */
   86    143   
    pub fn build(self) -> crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput {
         144  +
        /* BuilderGenerator.kt:477 */
   87    145   
        crate::operation::enable_kinesis_streaming_destination::EnableKinesisStreamingDestinationOutput {
   88         -
            table_name: self.table_name,
         146  +
            /* BuilderGenerator.kt:481 */ table_name: self.table_name,
         147  +
            /* BuilderGenerator.kt:481 */
   89    148   
            stream_arn: self.stream_arn,
         149  +
            /* BuilderGenerator.kt:481 */
   90    150   
            destination_status: self.destination_status,
         151  +
            /* BuilderGenerator.kt:477 */
   91    152   
        }
         153  +
        /* BuilderGenerator.kt:253 */
   92    154   
    }
         155  +
    /* BuilderGenerator.kt:355 */
   93    156   
}