Client Test

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/datetime_offsets.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `DatetimeOffsets`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct DatetimeOffsets;
 /* OperationGenerator.kt:85 */
 impl DatetimeOffsets {
     /// Creates a new `DatetimeOffsets`
     /// /* OperationGenerator.kt:86 */Creates a new `DatetimeOffsets`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::datetime_offsets::DatetimeOffsetsInput,
     ) -> ::std::result::Result<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::datetime_offsets::DatetimeOffsetsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::datetime_offsets::DatetimeOffsetsError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::datetime_offsets::DatetimeOffsetsOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -57,66 +265,282 @@

↥ Expand context

             .instrument(::tracing::debug_span!(
                 "Json Protocol.DatetimeOffsets",
                 "rpc.service" = "Json Protocol",
                 "rpc.method" = "DatetimeOffsets",
                 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
             ))
             .await
-73
+    }
-74
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for DatetimeOffsets {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("DatetimeOffsets");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             DatetimeOffsetsRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             DatetimeOffsetsResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "DatetimeOffsets",
             "Json Protocol",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("DatetimeOffsets")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(DatetimeOffsetsEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::datetime_offsets::DatetimeOffsetsError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::datetime_offsets::DatetimeOffsetsError,
             >::new());
-136
         ::std::borrow::Cow::Owned(rcb)
-138
+    }
-139
+}
-140
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct DatetimeOffsetsResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for DatetimeOffsetsResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-154
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_datetime_offsets::de_datetime_offsets_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_datetime_offsets::de_datetime_offsets_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-161
+    }
-162
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct DatetimeOffsetsRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for DatetimeOffsetsRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::datetime_offsets::DatetimeOffsetsInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::datetime_offsets::DatetimeOffsetsInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-188
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::datetime_offsets::DatetimeOffsetsInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-197
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.1");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http::header::HeaderName::from_static("x-amz-target"),
                 "JsonProtocol.DatetimeOffsets",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_datetime_offsets::ser_datetime_offsets_input(&input)?);
-208
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-210
+    }
-211
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct DatetimeOffsetsEndpointParamsInterceptor;
-215
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for DatetimeOffsetsEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "DatetimeOffsetsEndpointParamsInterceptor"
-219
+    }
-220
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<DatetimeOffsetsInput>()
             .ok_or("failed to downcast to DatetimeOffsetsInput")?;
-235
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-242
+    }
-243
+}
-244
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-247
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod datetime_offsets_test {
-254
     /// Ensures that clients can correctly parse datetime (timestamps) with offsets
     /// Test ID: AwsJson11DateTimeWithNegativeOffset
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn aws_json11_date_time_with_negative_offset_response() {
         let expected_output = crate::operation::datetime_offsets::DatetimeOffsetsOutput::builder()
             .set_datetime(::std::option::Option::Some(::aws_smithy_types::DateTime::from_fractional_secs(
                 1576540098, 0_f64,

↧ Expand context

             )))
             .build();
         let mut http_response = ::aws_smithy_runtime_api::http::Response::try_from(
             ::http::response::Builder::new()
                 .header("Content-Type", "application/x-amz-json-1.1")
                 .status(200)
                 .body(::aws_smithy_types::body::SdkBody::from(
                     "      {\n          \"datetime\": \"2019-12-16T22:48:18-01:00\"\n      }\n",
                 ))
                 .unwrap(),
-273
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-277
         let op = crate::operation::datetime_offsets::DatetimeOffsets::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");

@@ -299,316 +428,504 @@

↥ Expand context

                     "      {\n          \"datetime\": \"2019-12-17T00:48:18+01:00\"\n      }\n",
                 ))
                 .unwrap(),
-319
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-323
         let op = crate::operation::datetime_offsets::DatetimeOffsets::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");
-329
         let parsed = de.deserialize_streaming(&mut http_response);
         let parsed = parsed.unwrap_or_else(|| {
             let http_response = http_response.map(|body| {
                 ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     body.bytes().unwrap(),
                     ::aws_smithy_protocol_test::MediaType::from("application/json"),

                 )))
             });
             de.deserialize_nonstreaming(&http_response)
         });
         let parsed = parsed
             .expect("should be successful response")
             .downcast::<crate::operation::datetime_offsets::DatetimeOffsetsOutput>()
             .unwrap();
         ::pretty_assertions::assert_eq!(parsed.datetime, expected_output.datetime, "Unexpected value for `datetime`");
-345
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-348
+}
-349
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `DatetimeOffsetsError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum DatetimeOffsetsError {
 pub /* OperationErrorGenerator.kt:81 */ enum DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-361
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-363
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-DatetimeOffsetsError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-367
+}
 /* OperationErrorGenerator.kt:218 */
 impl DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `DatetimeOffsetsError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-379
+    }
-380
     /// Creates the `DatetimeOffsetsError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-387
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-398
+        }
         /* OperationErrorGenerator.kt:242 */
-400
+    }
     /* OperationErrorGenerator.kt:218 */
-402
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-415
+        }
         /* OperationErrorGenerator.kt:270 */
-417
+    }
     /* OperationErrorGenerator.kt:269 */
-419
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-433
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-436
+        }
         /* OperationErrorGenerator.kt:134 */
-438
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-440
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-448
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-454
+    }
     /* OperationErrorGenerator.kt:182 */
-456
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-469
+        }
         /* OperationErrorGenerator.kt:164 */
-471
+    }
     /* OperationErrorGenerator.kt:163 */
-473
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for DatetimeOffsetsError {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-487
+    }
     /* OperationErrorGenerator.kt:109 */
-489
+}
-490
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::datetime_offsets::_datetime_offsets_output::DatetimeOffsetsOutput;
-493
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::datetime_offsets::_datetime_offsets_input::DatetimeOffsetsInput;
-496
 /* RustModule.kt:172 */
 mod _datetime_offsets_input;
-499
 /* RustModule.kt:172 */
 mod _datetime_offsets_output;
-502
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/datetime_offsets/_datetime_offsets_input.rs

@@ -1,1 +24,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct DatetimeOffsetsInput {}
 pub /* StructureGenerator.kt:201 */ struct DatetimeOffsetsInput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl DatetimeOffsetsInput {
     /// Creates a new builder-style object to manufacture [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct DatetimeOffsetsInputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct DatetimeOffsetsInputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl DatetimeOffsetsInputBuilder {
     /// Consumes the builder and constructs a [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DatetimeOffsetsInput`](crate::operation::datetime_offsets::DatetimeOffsetsInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::datetime_offsets::DatetimeOffsetsInput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::datetime_offsets::DatetimeOffsetsInput {})
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::datetime_offsets::DatetimeOffsetsInput {
             /* BuilderGenerator.kt:477 */}, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-42
+    }
     /* BuilderGenerator.kt:355 */
-44
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/datetime_offsets/_datetime_offsets_output.rs

@@ -1,1 +47,88 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct DatetimeOffsetsOutput {
 pub /* StructureGenerator.kt:201 */ struct DatetimeOffsetsOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub datetime: ::std::option::Option<::aws_smithy_types::DateTime>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl DatetimeOffsetsOutput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn datetime(&self) -> ::std::option::Option<&::aws_smithy_types::DateTime> {
         /* StructureGenerator.kt:170 */
         self.datetime.as_ref()
         /* StructureGenerator.kt:166 */
-23
+    }
     /* StructureGenerator.kt:135 */
-25
+}
 /* ClientCodegenVisitor.kt:237 */
 impl DatetimeOffsetsOutput {
     /// Creates a new builder-style object to manufacture [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::datetime_offsets::builders::DatetimeOffsetsOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::datetime_offsets::builders::DatetimeOffsetsOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* BuilderGenerator.kt:345 */
 pub struct DatetimeOffsetsOutputBuilder {
     pub(crate) datetime: ::std::option::Option<::aws_smithy_types::DateTime>,
     /* BuilderGenerator.kt:275 */ pub(crate) datetime: ::std::option::Option<::aws_smithy_types::DateTime>,
     /* BuilderGenerator.kt:345 */
-47
+}
 /* BuilderGenerator.kt:355 */
 impl DatetimeOffsetsOutputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:291 */
     pub fn datetime(mut self, input: ::aws_smithy_types::DateTime) -> Self {
         /* BuilderGenerator.kt:292 */
         self.datetime = ::std::option::Option::Some(input);
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-59
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_datetime(mut self, input: ::std::option::Option<::aws_smithy_types::DateTime>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.datetime = input;
         self
         /* BuilderGenerator.kt:314 */
-68
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_datetime(&self) -> &::std::option::Option<::aws_smithy_types::DateTime> {
         /* BuilderGenerator.kt:337 */
         &self.datetime
         /* BuilderGenerator.kt:336 */
-76
+    }
     /// Consumes the builder and constructs a [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`DatetimeOffsetsOutput`](crate::operation::datetime_offsets::DatetimeOffsetsOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::datetime_offsets::DatetimeOffsetsOutput {
         crate::operation::datetime_offsets::DatetimeOffsetsOutput { datetime: self.datetime }
         /* BuilderGenerator.kt:477 */
         crate::operation::datetime_offsets::DatetimeOffsetsOutput {
             /* BuilderGenerator.kt:481 */ datetime: self.datetime,
             /* BuilderGenerator.kt:477 */
-84
+        }
         /* BuilderGenerator.kt:253 */
-+
+    }
     /* BuilderGenerator.kt:355 */
-88
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/datetime_offsets/builders.rs

@@ -1,1 +110,122 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::datetime_offsets::_datetime_offsets_output::DatetimeOffsetsOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::datetime_offsets::_datetime_offsets_input::DatetimeOffsetsInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::datetime_offsets::DatetimeOffsetsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.datetime_offsets();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `DatetimeOffsets`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `DatetimeOffsets`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct DatetimeOffsetsFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         crate::operation::datetime_offsets::DatetimeOffsetsError,
     > for DatetimeOffsetsFluentBuilder
-42
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::datetime_offsets::DatetimeOffsetsOutput,
             crate::operation::datetime_offsets::DatetimeOffsetsError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-53
+    }
-54
+}
 /* FluentBuilderGenerator.kt:282 */
 impl DatetimeOffsetsFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `DatetimeOffsetsFluentBuilder`.
     pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
         Self {
             handle,
             inner: ::std::default::Default::default(),
             config_override: ::std::option::Option::None,
-64
+        }
-65
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the DatetimeOffsets as a reference.
     pub fn as_input(&self) -> &crate::operation::datetime_offsets::builders::DatetimeOffsetsInputBuilder {
         &self.inner
-70
+    }
     /* FluentBuilderGenerator.kt:145 */
     /// Sends the request and returns the response.
     ///
     /// If an error occurs, an `SdkError` will be returned with additional details that
     /// can be matched against.
     ///
     /// By default, any retryable failures will be retried twice. Retry behavior
     /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
     /// set when configuring the client.
     pub async fn send(
         self,
     ) -> ::std::result::Result<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::datetime_offsets::DatetimeOffsetsError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let input = self
             .inner
             .build()
             .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
         let runtime_plugins = crate::operation::datetime_offsets::DatetimeOffsets::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::datetime_offsets::DatetimeOffsets::orchestrate(&runtime_plugins, input).await
-99
+    }
-100
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::datetime_offsets::DatetimeOffsetsOutput,
         crate::operation::datetime_offsets::DatetimeOffsetsError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-110
+    }
     /* FluentBuilderGenerator.kt:315 */
     pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
         self.set_config_override(::std::option::Option::Some(config_override.into()));
         self
-115
+    }
-116
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-120
+    }
     /* FluentBuilderGenerator.kt:282 */
-122
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/empty_operation.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `EmptyOperation`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct EmptyOperation;
 /* OperationGenerator.kt:85 */
 impl EmptyOperation {
     /// Creates a new `EmptyOperation`
     /// /* OperationGenerator.kt:86 */Creates a new `EmptyOperation`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::empty_operation::EmptyOperationInput,
     ) -> ::std::result::Result<
         crate::operation::empty_operation::EmptyOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::empty_operation::EmptyOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::empty_operation::EmptyOperationError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::empty_operation::EmptyOperationOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -57,66 +265,282 @@

↥ Expand context

             .instrument(::tracing::debug_span!(
                 "Json Protocol.EmptyOperation",
                 "rpc.service" = "Json Protocol",
                 "rpc.method" = "EmptyOperation",
                 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
             ))
             .await
-73
+    }
-74
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for EmptyOperation {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("EmptyOperation");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             EmptyOperationRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             EmptyOperationResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "EmptyOperation",
             "Json Protocol",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("EmptyOperation")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(EmptyOperationEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::empty_operation::EmptyOperationError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::empty_operation::EmptyOperationError,
             >::new());
-136
         ::std::borrow::Cow::Owned(rcb)
-138
+    }
-139
+}
-140
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct EmptyOperationResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for EmptyOperationResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-154
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_empty_operation::de_empty_operation_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_empty_operation::de_empty_operation_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-161
+    }
-162
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct EmptyOperationRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for EmptyOperationRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::empty_operation::EmptyOperationInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::empty_operation::EmptyOperationInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-188
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::empty_operation::EmptyOperationInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-197
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.1");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http::header::HeaderName::from_static("x-amz-target"),
                 "JsonProtocol.EmptyOperation",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_empty_operation::ser_empty_operation_input(&input)?);
-208
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-210
+    }
-211
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct EmptyOperationEndpointParamsInterceptor;
-215
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for EmptyOperationEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "EmptyOperationEndpointParamsInterceptor"
-219
+    }
-220
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<EmptyOperationInput>()
             .ok_or("failed to downcast to EmptyOperationInput")?;
-235
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-242
+    }
-243
+}
-244
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-247
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod empty_operation_test {
-254
     /// Sends requests to /
     /// Test ID: sends_requests_to_slash
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn sends_requests_to_slash_request() {
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
-262

↧ Expand context

         let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
         let result = client.empty_operation().send().await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [
             ("Content-Type", "application/x-amz-json-1.1"),
             ("X-Amz-Target", "JsonProtocol.EmptyOperation"),
         ];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");
-275
+    }
-276
     /// Includes X-Amz-Target header and Content-Type
     /// Test ID: includes_x_amz_target_and_content_type
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn includes_x_amz_target_and_content_type_request() {
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);

@@ -411,428 +540,616 @@

↥ Expand context

                 .header("Content-Type", "application/x-amz-json-1.1")
                 .status(200)
                 .body(::aws_smithy_types::body::SdkBody::from(""))
                 .unwrap(),
-432
+        )
         .unwrap();
         use ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin;
         use ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse;
-436
         let op = crate::operation::empty_operation::EmptyOperation::new();
         let config = op.config().expect("the operation has config");
         let de = config
             .load::<::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer>()
             .expect("the config must have a deserializer");
-442
         let parsed = de.deserialize_streaming(&mut http_response);
         let parsed = parsed.unwrap_or_else(|| {
             let http_response = http_response.map(|body| {
                 ::aws_smithy_types::body::SdkBody::from(::bytes::Bytes::copy_from_slice(&::aws_smithy_protocol_test::decode_body_data(
                     body.bytes().unwrap(),

                     ::aws_smithy_protocol_test::MediaType::from("unknown"),
                 )))
             });
             de.deserialize_nonstreaming(&http_response)
         });
         let parsed = parsed
             .expect("should be successful response")
             .downcast::<crate::operation::empty_operation::EmptyOperationOutput>()
             .unwrap();
-457
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-460
+}
-461
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `EmptyOperationError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum EmptyOperationError {
 pub /* OperationErrorGenerator.kt:81 */ enum EmptyOperationError {
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-473
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-475
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-EmptyOperationError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-479
+}
 /* OperationErrorGenerator.kt:218 */
 impl EmptyOperationError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `EmptyOperationError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-491
+    }
-492
     /// Creates the `EmptyOperationError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-499
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-510
+        }
         /* OperationErrorGenerator.kt:242 */
-512
+    }
     /* OperationErrorGenerator.kt:218 */
-514
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for EmptyOperationError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-527
+        }
         /* OperationErrorGenerator.kt:270 */
-529
+    }
     /* OperationErrorGenerator.kt:269 */
-531
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for EmptyOperationError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-545
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-548
+        }
         /* OperationErrorGenerator.kt:134 */
-550
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-552
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for EmptyOperationError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-560
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-566
+    }
     /* OperationErrorGenerator.kt:182 */
-568
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for EmptyOperationError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-581
+        }
         /* OperationErrorGenerator.kt:164 */
-583
+    }
     /* OperationErrorGenerator.kt:163 */
-585
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for EmptyOperationError {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-599
+    }
     /* OperationErrorGenerator.kt:109 */
-601
+}
-602
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_operation::_empty_operation_output::EmptyOperationOutput;
-605
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_operation::_empty_operation_input::EmptyOperationInput;
-608
 /* RustModule.kt:172 */
 mod _empty_operation_input;
-611
 /* RustModule.kt:172 */
 mod _empty_operation_output;
-614
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/empty_operation/_empty_operation_input.rs

@@ -1,1 +24,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EmptyOperationInput {}
 pub /* StructureGenerator.kt:201 */ struct EmptyOperationInput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl EmptyOperationInput {
     /// Creates a new builder-style object to manufacture [`EmptyOperationInput`](crate::operation::empty_operation::EmptyOperationInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EmptyOperationInput`](crate::operation::empty_operation::EmptyOperationInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::empty_operation::builders::EmptyOperationInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::empty_operation::builders::EmptyOperationInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`EmptyOperationInput`](crate::operation::empty_operation::EmptyOperationInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EmptyOperationInput`](crate::operation::empty_operation::EmptyOperationInput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct EmptyOperationInputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct EmptyOperationInputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl EmptyOperationInputBuilder {
     /// Consumes the builder and constructs a [`EmptyOperationInput`](crate::operation::empty_operation::EmptyOperationInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EmptyOperationInput`](crate::operation::empty_operation::EmptyOperationInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::empty_operation::EmptyOperationInput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::empty_operation::EmptyOperationInput {})
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::empty_operation::EmptyOperationInput {
             /* BuilderGenerator.kt:477 */}, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-42
+    }
     /* BuilderGenerator.kt:355 */
-44
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/empty_operation/_empty_operation_output.rs

@@ -1,1 +22,39 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EmptyOperationOutput {}
 pub /* StructureGenerator.kt:201 */ struct EmptyOperationOutput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl EmptyOperationOutput {
     /// Creates a new builder-style object to manufacture [`EmptyOperationOutput`](crate::operation::empty_operation::EmptyOperationOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EmptyOperationOutput`](crate::operation::empty_operation::EmptyOperationOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::empty_operation::builders::EmptyOperationOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::empty_operation::builders::EmptyOperationOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`EmptyOperationOutput`](crate::operation::empty_operation::EmptyOperationOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EmptyOperationOutput`](crate::operation::empty_operation::EmptyOperationOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct EmptyOperationOutputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct EmptyOperationOutputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl EmptyOperationOutputBuilder {
     /// Consumes the builder and constructs a [`EmptyOperationOutput`](crate::operation::empty_operation::EmptyOperationOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EmptyOperationOutput`](crate::operation::empty_operation::EmptyOperationOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::empty_operation::EmptyOperationOutput {
         crate::operation::empty_operation::EmptyOperationOutput {}
         /* BuilderGenerator.kt:477 */
         crate::operation::empty_operation::EmptyOperationOutput {
         /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:253 */
-37
+    }
     /* BuilderGenerator.kt:355 */
-39
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/empty_operation/builders.rs

@@ -1,1 +110,122 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_operation::_empty_operation_output::EmptyOperationOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::empty_operation::_empty_operation_input::EmptyOperationInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::empty_operation::builders::EmptyOperationInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::empty_operation::EmptyOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::empty_operation::EmptyOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.empty_operation();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `EmptyOperation`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `EmptyOperation`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct EmptyOperationFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::empty_operation::builders::EmptyOperationInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::empty_operation::EmptyOperationOutput,
         crate::operation::empty_operation::EmptyOperationError,
     > for EmptyOperationFluentBuilder
-42
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::empty_operation::EmptyOperationOutput,
             crate::operation::empty_operation::EmptyOperationError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-53
+    }
-54
+}
 /* FluentBuilderGenerator.kt:282 */
 impl EmptyOperationFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `EmptyOperationFluentBuilder`.
     pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
         Self {
             handle,
             inner: ::std::default::Default::default(),
             config_override: ::std::option::Option::None,
-64
+        }
-65
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the EmptyOperation as a reference.
     pub fn as_input(&self) -> &crate::operation::empty_operation::builders::EmptyOperationInputBuilder {
         &self.inner
-70
+    }
     /* FluentBuilderGenerator.kt:145 */
     /// Sends the request and returns the response.
     ///
     /// If an error occurs, an `SdkError` will be returned with additional details that
     /// can be matched against.
     ///
     /// By default, any retryable failures will be retried twice. Retry behavior
     /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
     /// set when configuring the client.
     pub async fn send(
         self,
     ) -> ::std::result::Result<
         crate::operation::empty_operation::EmptyOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::empty_operation::EmptyOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let input = self
             .inner
             .build()
             .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
         let runtime_plugins = crate::operation::empty_operation::EmptyOperation::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::empty_operation::EmptyOperation::orchestrate(&runtime_plugins, input).await
-99
+    }
-100
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::empty_operation::EmptyOperationOutput,
         crate::operation::empty_operation::EmptyOperationError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-110
+    }
     /* FluentBuilderGenerator.kt:315 */
     pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
         self.set_config_override(::std::option::Option::Some(config_override.into()));
         self
-115
+    }
-116
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-120
+    }
     /* FluentBuilderGenerator.kt:282 */
-122
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_operation.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `EndpointOperation`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct EndpointOperation;
 /* OperationGenerator.kt:85 */
 impl EndpointOperation {
     /// Creates a new `EndpointOperation`
     /// /* OperationGenerator.kt:86 */Creates a new `EndpointOperation`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::endpoint_operation::EndpointOperationInput,
     ) -> ::std::result::Result<
         crate::operation::endpoint_operation::EndpointOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::endpoint_operation::EndpointOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::endpoint_operation::EndpointOperationError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::endpoint_operation::EndpointOperationOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -57,66 +371,447 @@

↥ Expand context

             .instrument(::tracing::debug_span!(
                 "Json Protocol.EndpointOperation",
                 "rpc.service" = "Json Protocol",
                 "rpc.method" = "EndpointOperation",
                 "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
             ))
             .await
-73
+    }
-74
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-87
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-93
+        }
         runtime_plugins
-95
+    }
     /* OperationGenerator.kt:85 */
-97
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for EndpointOperation {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("EndpointOperation");
-102
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             EndpointOperationRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             EndpointOperationResponseDeserializer,
         ));
-109
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-113
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "EndpointOperation",
             "Json Protocol",
         ));
-118
         ::std::option::Option::Some(cfg.freeze())
-120
+    }
-121
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("EndpointOperation")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(EndpointOperationEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::endpoint_operation::EndpointOperationError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::endpoint_operation::EndpointOperationError,
             >::new());
-136
         ::std::borrow::Cow::Owned(rcb)
-138
+    }
-139
+}
-140
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct EndpointOperationResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for EndpointOperationResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-154
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_endpoint_operation::de_endpoint_operation_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_endpoint_operation::de_endpoint_operation_http_response(status, headers, body)
         };
         crate::protocol_serde::type_erase_result(parse_result)
-161
+    }
-162
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct EndpointOperationRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for EndpointOperationRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::endpoint_operation::EndpointOperationInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::endpoint_operation::EndpointOperationInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-188
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::endpoint_operation::EndpointOperationInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-197
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.1");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http::header::HeaderName::from_static("x-amz-target"),
                 "JsonProtocol.EndpointOperation",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(crate::protocol_serde::shape_endpoint_operation::ser_endpoint_operation_input(&input)?);
-208
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-210
+    }
-211
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct EndpointOperationEndpointParamsInterceptor;
-215
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for EndpointOperationEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "EndpointOperationEndpointParamsInterceptor"
-219
+    }
-220
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<EndpointOperationInput>()
             .ok_or("failed to downcast to EndpointOperationInput")?;
-235
         let endpoint_prefix = ::aws_smithy_runtime_api::client::endpoint::EndpointPrefix::new("foo.").map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint prefix could not be built", err)
         })?;
         cfg.interceptor_state().store_put(endpoint_prefix);
-240
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-247
+    }
-248
+}
-249
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-252
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod endpoint_operation_test {
-259
     /// Operations can prepend to the given host if they define the
     /// endpoint trait.
     /// Test ID: AwsJson11EndpointTrait
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn aws_json11_endpoint_trait_request() {
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
-268
         let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
         let result = client.endpoint_operation().send().await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [
             ("Content-Type", "application/x-amz-json-1.1"),
             ("X-Amz-Target", "JsonProtocol.EndpointOperation"),
         ];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let body = http_request.body().bytes().expect("body should be strict");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             body,
             "{}",
             ::aws_smithy_protocol_test::MediaType::from("unknown"),
         ));
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");
         ::pretty_assertions::assert_eq!(uri.host().expect("host should be set"), "foo.example.com");
-288
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-291
+}
-292
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `EndpointOperationError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum EndpointOperationError {
 pub /* OperationErrorGenerator.kt:81 */ enum EndpointOperationError {
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-304
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-306
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-EndpointOperationError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-310
+}
 /* OperationErrorGenerator.kt:218 */
 impl EndpointOperationError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `EndpointOperationError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-322
+    }
-323
     /// Creates the `EndpointOperationError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-330
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-341
+        }
         /* OperationErrorGenerator.kt:242 */
-343
+    }
     /* OperationErrorGenerator.kt:218 */
-345
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for EndpointOperationError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-358
+        }
         /* OperationErrorGenerator.kt:270 */
-360
+    }
     /* OperationErrorGenerator.kt:269 */
-362
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for EndpointOperationError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-376
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-379
+        }
         /* OperationErrorGenerator.kt:134 */
-381
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-383
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for EndpointOperationError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-391
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-397
+    }
     /* OperationErrorGenerator.kt:182 */
-399
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for EndpointOperationError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-412
+        }
         /* OperationErrorGenerator.kt:164 */
-414
+    }
     /* OperationErrorGenerator.kt:163 */
-416
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for EndpointOperationError {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-430
+    }
     /* OperationErrorGenerator.kt:109 */
-432
+}
-433
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_operation::_endpoint_operation_output::EndpointOperationOutput;
-436
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_operation::_endpoint_operation_input::EndpointOperationInput;
-439
 /* RustModule.kt:172 */
 mod _endpoint_operation_input;
-442
 /* RustModule.kt:172 */
 mod _endpoint_operation_output;
-445
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_operation/_endpoint_operation_input.rs

@@ -1,1 +24,44 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EndpointOperationInput {}
 pub /* StructureGenerator.kt:201 */ struct EndpointOperationInput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl EndpointOperationInput {
     /// Creates a new builder-style object to manufacture [`EndpointOperationInput`](crate::operation::endpoint_operation::EndpointOperationInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EndpointOperationInput`](crate::operation::endpoint_operation::EndpointOperationInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::endpoint_operation::builders::EndpointOperationInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::endpoint_operation::builders::EndpointOperationInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`EndpointOperationInput`](crate::operation::endpoint_operation::EndpointOperationInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EndpointOperationInput`](crate::operation::endpoint_operation::EndpointOperationInput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct EndpointOperationInputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct EndpointOperationInputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl EndpointOperationInputBuilder {
     /// Consumes the builder and constructs a [`EndpointOperationInput`](crate::operation::endpoint_operation::EndpointOperationInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EndpointOperationInput`](crate::operation::endpoint_operation::EndpointOperationInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<crate::operation::endpoint_operation::EndpointOperationInput, ::aws_smithy_types::error::operation::BuildError> {
         ::std::result::Result::Ok(crate::operation::endpoint_operation::EndpointOperationInput {})
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::endpoint_operation::EndpointOperationInput {
             /* BuilderGenerator.kt:477 */}, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-42
+    }
     /* BuilderGenerator.kt:355 */
-44
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_operation/_endpoint_operation_output.rs

@@ -1,1 +22,39 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EndpointOperationOutput {}
 pub /* StructureGenerator.kt:201 */ struct EndpointOperationOutput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl EndpointOperationOutput {
     /// Creates a new builder-style object to manufacture [`EndpointOperationOutput`](crate::operation::endpoint_operation::EndpointOperationOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EndpointOperationOutput`](crate::operation::endpoint_operation::EndpointOperationOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::endpoint_operation::builders::EndpointOperationOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::endpoint_operation::builders::EndpointOperationOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`EndpointOperationOutput`](crate::operation::endpoint_operation::EndpointOperationOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EndpointOperationOutput`](crate::operation::endpoint_operation::EndpointOperationOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct EndpointOperationOutputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct EndpointOperationOutputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl EndpointOperationOutputBuilder {
     /// Consumes the builder and constructs a [`EndpointOperationOutput`](crate::operation::endpoint_operation::EndpointOperationOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EndpointOperationOutput`](crate::operation::endpoint_operation::EndpointOperationOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::endpoint_operation::EndpointOperationOutput {
         crate::operation::endpoint_operation::EndpointOperationOutput {}
         /* BuilderGenerator.kt:477 */
         crate::operation::endpoint_operation::EndpointOperationOutput {
         /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:253 */
-37
+    }
     /* BuilderGenerator.kt:355 */
-39
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_operation/builders.rs

@@ -1,1 +110,122 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_operation::_endpoint_operation_output::EndpointOperationOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_operation::_endpoint_operation_input::EndpointOperationInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::endpoint_operation::builders::EndpointOperationInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::endpoint_operation::EndpointOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::endpoint_operation::EndpointOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.endpoint_operation();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `EndpointOperation`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `EndpointOperation`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct EndpointOperationFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::endpoint_operation::builders::EndpointOperationInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::endpoint_operation::EndpointOperationOutput,
         crate::operation::endpoint_operation::EndpointOperationError,
     > for EndpointOperationFluentBuilder
-42
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::endpoint_operation::EndpointOperationOutput,
             crate::operation::endpoint_operation::EndpointOperationError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-53
+    }
-54
+}
 /* FluentBuilderGenerator.kt:282 */
 impl EndpointOperationFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `EndpointOperationFluentBuilder`.
     pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
         Self {
             handle,
             inner: ::std::default::Default::default(),
             config_override: ::std::option::Option::None,
-64
+        }
-65
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the EndpointOperation as a reference.
     pub fn as_input(&self) -> &crate::operation::endpoint_operation::builders::EndpointOperationInputBuilder {
         &self.inner
-70
+    }
     /* FluentBuilderGenerator.kt:145 */
     /// Sends the request and returns the response.
     ///
     /// If an error occurs, an `SdkError` will be returned with additional details that
     /// can be matched against.
     ///
     /// By default, any retryable failures will be retried twice. Retry behavior
     /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
     /// set when configuring the client.
     pub async fn send(
         self,
     ) -> ::std::result::Result<
         crate::operation::endpoint_operation::EndpointOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::endpoint_operation::EndpointOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let input = self
             .inner
             .build()
             .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
         let runtime_plugins = crate::operation::endpoint_operation::EndpointOperation::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::endpoint_operation::EndpointOperation::orchestrate(&runtime_plugins, input).await
-99
+    }
-100
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::endpoint_operation::EndpointOperationOutput,
         crate::operation::endpoint_operation::EndpointOperationError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-110
+    }
     /* FluentBuilderGenerator.kt:315 */
     pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
         self.set_config_override(::std::option::Option::Some(config_override.into()));
         self
-115
+    }
-116
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-120
+    }
     /* FluentBuilderGenerator.kt:282 */
-122
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_with_host_label_operation.rs

@@ -1,1 +40,49 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* OperationGenerator.kt:77 */
 /// Orchestration and serialization glue logic for `EndpointWithHostLabelOperation`.
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* OperationGenerator.kt:84 */
 pub struct EndpointWithHostLabelOperation;
 /* OperationGenerator.kt:85 */
 impl EndpointWithHostLabelOperation {
     /// Creates a new `EndpointWithHostLabelOperation`
     /// /* OperationGenerator.kt:86 */Creates a new `EndpointWithHostLabelOperation`
     /* OperationGenerator.kt:87 */
     pub fn new() -> Self {
         /* OperationGenerator.kt:88 */
         Self
         /* OperationGenerator.kt:87 */
-18
+    }
     /* OperationGenerator.kt:138 */
     pub(crate) async fn orchestrate(
         runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         input: crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput,
     ) -> ::std::result::Result<
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {

↧ Expand context

         let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >| {
             err.map_service_error(|err| {
                 err.downcast::<crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError>()
                     .expect("correct error type")
             })
         };
         let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
             .await
             .map_err(map_err)?;
         let output = context.finalize().map_err(map_err)?;
         ::std::result::Result::Ok(
             output
                 .downcast::<crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput>()
                 .expect("correct output type"),
-47
+        )
-48
+    }
-49

@@ -63,72 +399,475 @@

↥ Expand context

         .instrument(::tracing::debug_span!(
             "Json Protocol.EndpointWithHostLabelOperation",
             "rpc.service" = "Json Protocol",
             "rpc.method" = "EndpointWithHostLabelOperation",
             "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
         ))
         .await
-79
+    }
-80
     pub(crate) fn operation_runtime_plugins(
         client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
         client_config: &crate::config::Config,
         config_override: ::std::option::Option<crate::config::Builder>,
     ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
         let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
         runtime_plugins = runtime_plugins.with_client_plugin(crate::auth_plugin::DefaultAuthOptionsPlugin::new(vec![
             ::aws_smithy_runtime::client::auth::no_auth::NO_AUTH_SCHEME_ID,
         ]));
         if let ::std::option::Option::Some(config_override) = config_override {
             for plugin in config_override.runtime_plugins.iter().cloned() {

                 runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
-93
+            }
             runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
                 config_override,
                 client_config.config.clone(),
                 &client_config.runtime_components,
             ));
-99
+        }
         runtime_plugins
-101
+    }
     /* OperationGenerator.kt:85 */
-103
+}
 /* OperationRuntimePluginGenerator.kt:55 */
 impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for EndpointWithHostLabelOperation {
     fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
         let mut cfg = ::aws_smithy_types::config_bag::Layer::new("EndpointWithHostLabelOperation");
-108
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
             EndpointWithHostLabelOperationRequestSerializer,
         ));
         cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
             EndpointWithHostLabelOperationResponseDeserializer,
         ));
-115
         cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
             ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
         ));
-119
         cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
             "EndpointWithHostLabelOperation",
             "Json Protocol",
         ));
-124
         ::std::option::Option::Some(cfg.freeze())
-126
+    }
-127
     fn runtime_components(
         &self,
         _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
     ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
         #[allow(unused_mut)]
         let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("EndpointWithHostLabelOperation")
             .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
             .with_interceptor(EndpointWithHostLabelOperationEndpointParamsInterceptor)
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
                 crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
             >::new())
             .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
                 crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
             >::new());
-142
         ::std::borrow::Cow::Owned(rcb)
-144
+    }
-145
+}
-146
 /* ResponseDeserializerGenerator.kt:64 */
 #[derive(Debug)]
 struct EndpointWithHostLabelOperationResponseDeserializer;
 impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for EndpointWithHostLabelOperationResponseDeserializer {
     fn deserialize_nonstreaming(
         &self,
         response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
     ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
         let (success, status) = (response.status().is_success(), response.status().as_u16());
         let headers = response.headers();
         let body = response.body().bytes().expect("body loaded");
         #[allow(unused_mut)]
         let mut force_error = false;
-160
         let parse_result = if !success && status != 200 || force_error {
             crate::protocol_serde::shape_endpoint_with_host_label_operation::de_endpoint_with_host_label_operation_http_error(status, headers, body)
         } else {
             crate::protocol_serde::shape_endpoint_with_host_label_operation::de_endpoint_with_host_label_operation_http_response(
                 status, headers, body,
-166
+            )
         };
         crate::protocol_serde::type_erase_result(parse_result)
-169
+    }
-170
+}
 /* RequestSerializerGenerator.kt:67 */
 #[derive(Debug)]
 struct EndpointWithHostLabelOperationRequestSerializer;
 impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for EndpointWithHostLabelOperationRequestSerializer {
     #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
     fn serialize_input(
         &self,
         input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
         _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
         let input = input
             .downcast::<crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput>()
             .expect("correct type");
         let _header_serialization_settings = _cfg
             .load::<crate::serialization_settings::HeaderSerializationSettings>()
             .cloned()
             .unwrap_or_default();
         let mut request_builder = {
             fn uri_base(
                 _input: &crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput,
                 output: &mut ::std::string::String,
             ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
                 use ::std::fmt::Write as _;
                 ::std::write!(output, "/").expect("formatting should succeed");
                 ::std::result::Result::Ok(())
-196
+            }
             #[allow(clippy::unnecessary_wraps)]
             fn update_http_builder(
                 input: &crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput,
                 builder: ::http::request::Builder,
             ) -> ::std::result::Result<::http::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
                 let mut uri = ::std::string::String::new();
                 uri_base(input, &mut uri)?;
                 ::std::result::Result::Ok(builder.method("POST").uri(uri))
-205
+            }
             let mut builder = update_http_builder(&input, ::http::request::Builder::new())?;
             builder = _header_serialization_settings.set_default_header(builder, ::http::header::CONTENT_TYPE, "application/x-amz-json-1.1");
             builder = _header_serialization_settings.set_default_header(
                 builder,
                 ::http::header::HeaderName::from_static("x-amz-target"),
                 "JsonProtocol.EndpointWithHostLabelOperation",
             );
             builder
         };
         let body = ::aws_smithy_types::body::SdkBody::from(
             crate::protocol_serde::shape_endpoint_with_host_label_operation::ser_endpoint_with_host_label_operation_input(&input)?,
         );
         if let Some(content_length) = body.content_length() {
             let content_length = content_length.to_string();
             request_builder = _header_serialization_settings.set_default_header(request_builder, ::http::header::CONTENT_LENGTH, &content_length);
-221
+        }
         ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
-223
+    }
-224
+}
 /* EndpointParamsInterceptorGenerator.kt:86 */
 #[derive(Debug)]
 struct EndpointWithHostLabelOperationEndpointParamsInterceptor;
-228
 impl ::aws_smithy_runtime_api::client::interceptors::Intercept for EndpointWithHostLabelOperationEndpointParamsInterceptor {
     fn name(&self) -> &'static str {
         "EndpointWithHostLabelOperationEndpointParamsInterceptor"
-232
+    }
-233
     fn read_before_execution(
         &self,
         context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
             '_,
             ::aws_smithy_runtime_api::client::interceptors::context::Input,
             ::aws_smithy_runtime_api::client::interceptors::context::Output,
             ::aws_smithy_runtime_api::client::interceptors::context::Error,
         >,
         cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
     ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
         let _input = context
             .input()
             .downcast_ref::<EndpointWithHostLabelOperationInput>()
             .ok_or("failed to downcast to EndpointWithHostLabelOperationInput")?;
-248
         let endpoint_prefix = {
             let label = _input.label.as_deref().unwrap_or_default();
             if label.is_empty() {
                 return Err(
                     ::aws_smithy_runtime_api::client::endpoint::error::InvalidEndpointError::failed_to_construct_uri(
                         "label was unset or empty but must be set as part of the endpoint prefix",
-255
+                    )
                     .into(),
                 );
-258
+            }
             ::aws_smithy_runtime_api::client::endpoint::EndpointPrefix::new(format!("foo.{label}.", label = label))
-260
+        }
         .map_err(|err| ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint prefix could not be built", err))?;
         cfg.interceptor_state().store_put(endpoint_prefix);
-263
         let params = crate::config::endpoint::Params::builder().build().map_err(|err| {
             ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
         })?;
         cfg.interceptor_state()
             .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
         ::std::result::Result::Ok(())
-270
+    }
-271
+}
-272
 // The get_* functions below are generated from JMESPath expressions in the
 // operationContextParams trait. They target the operation's input shape.
-275
 /* RustType.kt:516 */
 #[allow(unreachable_code, unused_variables)]
 /* RustType.kt:516 */
 #[cfg(test)]
 /* ProtocolTestGenerator.kt:98 */
 mod endpoint_with_host_label_operation_test {
-282
     /// Operations can prepend to the given host if they define the
     /// endpoint trait, and can use the host label trait to define
     /// further customization based on user input.
     /// Test ID: AwsJson11EndpointTraitWithHostLabel
     #[::tokio::test]
     #[::tracing_test::traced_test]
     async fn aws_json11_endpoint_trait_with_host_label_request() {
         let (http_client, request_receiver) = ::aws_smithy_http_client::test_util::capture_request(None);
         let config_builder = crate::config::Config::builder().with_test_defaults().endpoint_url("https://example.com");
-292
         let client = crate::Client::from_conf(config_builder.http_client(http_client).build());
         let result = client
             .endpoint_with_host_label_operation()
             .set_label(::std::option::Option::Some("bar".to_owned()))
             .send()
             .await;
         let _ = dbg!(result);
         let http_request = request_receiver.expect_request();
         let expected_headers = [
             ("Content-Type", "application/x-amz-json-1.1"),
             ("X-Amz-Target", "JsonProtocol.EndpointWithHostLabelOperation"),
         ];
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_headers(http_request.headers(), expected_headers));
         let body = http_request.body().bytes().expect("body should be strict");
         ::aws_smithy_protocol_test::assert_ok(::aws_smithy_protocol_test::validate_body(
             body,
             "{\"label\": \"bar\"}",
             ::aws_smithy_protocol_test::MediaType::from("application/json"),
         ));
         let uri: ::http::Uri = http_request.uri().parse().expect("invalid URI sent");
         ::pretty_assertions::assert_eq!(http_request.method(), "POST", "method was incorrect");
         ::pretty_assertions::assert_eq!(uri.path(), "/", "path was incorrect");
         ::pretty_assertions::assert_eq!(uri.host().expect("host should be set"), "foo.bar.example.com");
-316
+    }
-+
     /* ProtocolTestGenerator.kt:98 */
-319
+}
-320
 /* OperationErrorGenerator.kt:79 */
 /// Error type for the `EndpointWithHostLabelOperationError` operation.
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::fmt::Debug)]
 pub enum EndpointWithHostLabelOperationError {
 pub /* OperationErrorGenerator.kt:81 */ enum EndpointWithHostLabelOperationError {
     /* OperationErrorGenerator.kt:88 */
     /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
     #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
     variable wildcard pattern and check `.code()`:
-332
+     \
     &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
-334
+     \
     See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-EndpointWithHostLabelOperationError) for what information is available for the error.")]
     Unhandled(crate::error::sealed_unhandled::Unhandled),
     /* OperationErrorGenerator.kt:81 */
-338
+}
 /* OperationErrorGenerator.kt:218 */
 impl EndpointWithHostLabelOperationError {
     /* OperationErrorGenerator.kt:219 */
     /// Creates the `EndpointWithHostLabelOperationError::Unhandled` variant from any error type.
     pub fn unhandled(
         err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
     ) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.into(),
             meta: ::std::default::Default::default(),
         })
-350
+    }
-351
     /// Creates the `EndpointWithHostLabelOperationError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
     pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source: err.clone().into(),
             meta: err,
         })
-358
+    }
     ///
     /// /* OperationErrorGenerator.kt:236 */
     /// Returns error metadata, which includes the error code, message,
     /// request ID, and potentially additional information.
     ///
     /* OperationErrorGenerator.kt:242 */
     pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:243 */
         match self {
             Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:251 */ Self::Unhandled(e) => &e.meta,
             /* OperationErrorGenerator.kt:243 */
-369
+        }
         /* OperationErrorGenerator.kt:242 */
-371
+    }
     /* OperationErrorGenerator.kt:218 */
-373
+}
 /* OperationErrorGenerator.kt:269 */
 impl ::std::error::Error for EndpointWithHostLabelOperationError {
     /* OperationErrorGenerator.kt:270 */
     fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:279 */
                 ::std::option::Option::Some(&*_inner.source)
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-386
+        }
         /* OperationErrorGenerator.kt:270 */
-388
+    }
     /* OperationErrorGenerator.kt:269 */
-390
+}
 /* OperationErrorGenerator.kt:133 */
 impl ::std::fmt::Display for EndpointWithHostLabelOperationError {
     /* OperationErrorGenerator.kt:134 */
     fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
         /* OperationErrorGenerator.kt:318 */
         match self {
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:139 */
                 if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
                     write!(f, "unhandled error ({code})")
                 } else {
                     f.write_str("unhandled error")
-404
+                }
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-407
+        }
         /* OperationErrorGenerator.kt:134 */
-409
+    }
--
+    }
     /* OperationErrorGenerator.kt:133 */
-411
+}
 /* OperationErrorGenerator.kt:182 */
 impl ::aws_smithy_types::retry::ProvideErrorKind for EndpointWithHostLabelOperationError {
     /* OperationErrorGenerator.kt:186 */
     fn code(&self) -> ::std::option::Option<&str> {
         /* OperationErrorGenerator.kt:187 */
         ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
         /* OperationErrorGenerator.kt:186 */
-419
+    }
     /* OperationErrorGenerator.kt:190 */
     fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
         /* OperationErrorGenerator.kt:197 */
         ::std::option::Option::None
         /* OperationErrorGenerator.kt:190 */
-425
+    }
     /* OperationErrorGenerator.kt:182 */
-427
+}
 /* OperationErrorGenerator.kt:163 */
 impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for EndpointWithHostLabelOperationError {
     /* OperationErrorGenerator.kt:164 */
     fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
         /* OperationErrorGenerator.kt:318 */
         match self {
             Self::Unhandled(_inner) => &_inner.meta,
             /* OperationErrorGenerator.kt:326 */
             Self::Unhandled(_inner) => {
                 /* OperationErrorGenerator.kt:168 */
                 &_inner.meta
                 /* OperationErrorGenerator.kt:326 */
             } /* OperationErrorGenerator.kt:318 */
-440
+        }
         /* OperationErrorGenerator.kt:164 */
-442
+    }
     /* OperationErrorGenerator.kt:163 */
-444
+}
 /* OperationErrorGenerator.kt:109 */
 impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for EndpointWithHostLabelOperationError {
     /* OperationErrorGenerator.kt:110 */
     fn create_unhandled_error(
         source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
         meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
     ) -> Self {
         /* OperationErrorGenerator.kt:121 */
         Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
             source,
             meta: meta.unwrap_or_default(),
         })
         /* OperationErrorGenerator.kt:110 */
-458
+    }
     /* OperationErrorGenerator.kt:109 */
-460
+}
-461
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_with_host_label_operation::_endpoint_with_host_label_operation_output::EndpointWithHostLabelOperationOutput;
-464
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_with_host_label_operation::_endpoint_with_host_label_operation_input::EndpointWithHostLabelOperationInput;
-467
 /* RustModule.kt:172 */
 mod _endpoint_with_host_label_operation_input;
-470
 /* RustModule.kt:172 */
 mod _endpoint_with_host_label_operation_output;
-473
 /// Builders
 /// /* CodegenDelegator.kt:51 */Builders
 pub mod builders;

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_with_host_label_operation/_endpoint_with_host_label_operation_input.rs

@@ -1,1 +53,97 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EndpointWithHostLabelOperationInput {
 pub /* StructureGenerator.kt:201 */ struct EndpointWithHostLabelOperationInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
     pub label: ::std::option::Option<::std::string::String>,
     /* StructureGenerator.kt:201 */
-13
+}
 /* StructureGenerator.kt:135 */
 impl EndpointWithHostLabelOperationInput {
     /* StructureGenerator.kt:231 */
     #[allow(missing_docs)] // documentation missing in model
                            /* StructureGenerator.kt:166 */
     pub fn label(&self) -> ::std::option::Option<&str> {
         /* StructureGenerator.kt:169 */
         self.label.as_deref()
         /* StructureGenerator.kt:166 */
-23
+    }
     /* StructureGenerator.kt:135 */
-25
+}
 /* ClientCodegenVisitor.kt:237 */
 impl EndpointWithHostLabelOperationInput {
     /// Creates a new builder-style object to manufacture [`EndpointWithHostLabelOperationInput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EndpointWithHostLabelOperationInput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::endpoint_with_host_label_operation::builders::EndpointWithHostLabelOperationInputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::endpoint_with_host_label_operation::builders::EndpointWithHostLabelOperationInputBuilder::default()
         /* BuilderGenerator.kt:175 */
-34
+    }
     /* ClientCodegenVisitor.kt:237 */
-36
+}
-37
 /// A builder for [`EndpointWithHostLabelOperationInput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EndpointWithHostLabelOperationInput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* BuilderGenerator.kt:345 */
 pub struct EndpointWithHostLabelOperationInputBuilder {
     pub(crate) label: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:275 */ pub(crate) label: ::std::option::Option<::std::string::String>,
     /* BuilderGenerator.kt:345 */
-47
+}
 /* BuilderGenerator.kt:355 */
 impl EndpointWithHostLabelOperationInputBuilder {
     /* BuilderGenerator.kt:286 */
     #[allow(missing_docs)] // documentation missing in model
     /// This field is required.
     /// /* BuilderGenerator.kt:288 */This field is required.
     /* BuilderGenerator.kt:291 */
     pub fn label(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:292 */
         self.label = ::std::option::Option::Some(input.into());
         /* BuilderGenerator.kt:293 */
         self
         /* BuilderGenerator.kt:291 */
-60
+    }
     /* BuilderGenerator.kt:312 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:314 */
     pub fn set_label(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         /* BuilderGenerator.kt:315 */
         self.label = input;
         self
         /* BuilderGenerator.kt:314 */
-69
+    }
     /* BuilderGenerator.kt:334 */
     #[allow(missing_docs)] // documentation missing in model
                            /* BuilderGenerator.kt:336 */
     pub fn get_label(&self) -> &::std::option::Option<::std::string::String> {
         /* BuilderGenerator.kt:337 */
         &self.label
         /* BuilderGenerator.kt:336 */
-77
+    }
     /// Consumes the builder and constructs a [`EndpointWithHostLabelOperationInput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EndpointWithHostLabelOperationInput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput).
     /* BuilderGenerator.kt:253 */
     pub fn build(
         self,
     ) -> ::std::result::Result<
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput,
         ::aws_smithy_types::error::operation::BuildError,
     > {
         ::std::result::Result::Ok(crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput { label: self.label })
         /* BuilderGenerator.kt:254 */
         ::std::result::Result::Ok(
             /* BuilderGenerator.kt:477 */
             crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationInput {
                 /* BuilderGenerator.kt:481 */ label: self.label,
                 /* BuilderGenerator.kt:477 */
             }, /* BuilderGenerator.kt:254 */
-+
+        )
         /* BuilderGenerator.kt:253 */
-95
+    }
     /* BuilderGenerator.kt:355 */
-97
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_with_host_label_operation/_endpoint_with_host_label_operation_output.rs

@@ -1,1 +22,39 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* StructureGenerator.kt:197 */
 #[allow(missing_docs)] // documentation missing in model
 /* RustType.kt:516 */
 #[non_exhaustive]
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
 pub struct EndpointWithHostLabelOperationOutput {}
 pub /* StructureGenerator.kt:201 */ struct EndpointWithHostLabelOperationOutput {/* StructureGenerator.kt:201 */}
 /* ClientCodegenVisitor.kt:237 */
 impl EndpointWithHostLabelOperationOutput {
     /// Creates a new builder-style object to manufacture [`EndpointWithHostLabelOperationOutput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput).
     /// /* BuilderGenerator.kt:173 */Creates a new builder-style object to manufacture [`EndpointWithHostLabelOperationOutput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput).
     /* BuilderGenerator.kt:175 */
     pub fn builder() -> crate::operation::endpoint_with_host_label_operation::builders::EndpointWithHostLabelOperationOutputBuilder {
         /* BuilderGenerator.kt:176 */
         crate::operation::endpoint_with_host_label_operation::builders::EndpointWithHostLabelOperationOutputBuilder::default()
         /* BuilderGenerator.kt:175 */
-17
+    }
     /* ClientCodegenVisitor.kt:237 */
-19
+}
-20
 /// A builder for [`EndpointWithHostLabelOperationOutput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput).
 /// /* BuilderGenerator.kt:342 */A builder for [`EndpointWithHostLabelOperationOutput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput).
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
 /* RustType.kt:516 */
 #[non_exhaustive]
 pub struct EndpointWithHostLabelOperationOutputBuilder {}
 /* BuilderGenerator.kt:345 */
 pub struct EndpointWithHostLabelOperationOutputBuilder {/* BuilderGenerator.kt:345 */}
 /* BuilderGenerator.kt:355 */
 impl EndpointWithHostLabelOperationOutputBuilder {
     /// Consumes the builder and constructs a [`EndpointWithHostLabelOperationOutput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput).
     /// /* BuilderGenerator.kt:240 */Consumes the builder and constructs a [`EndpointWithHostLabelOperationOutput`](crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput).
     /* BuilderGenerator.kt:253 */
     pub fn build(self) -> crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput {
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput {}
         /* BuilderGenerator.kt:477 */
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput {
         /* BuilderGenerator.kt:477 */}
         /* BuilderGenerator.kt:253 */
-37
+    }
     /* BuilderGenerator.kt:355 */
-39
+}

tmp-codegen-diff/codegen-client-test/json_rpc11/rust-client-codegen/src/operation/endpoint_with_host_label_operation/builders.rs

@@ -1,1 +124,142 @@

 // Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_with_host_label_operation::_endpoint_with_host_label_operation_output::EndpointWithHostLabelOperationOutputBuilder;
-4
 /* CodegenDelegator.kt:255 */
 pub use crate::operation::endpoint_with_host_label_operation::_endpoint_with_host_label_operation_input::EndpointWithHostLabelOperationInputBuilder;
-7
 /* FluentBuilderGenerator.kt:408 */
 impl crate::operation::endpoint_with_host_label_operation::builders::EndpointWithHostLabelOperationInputBuilder {
     /// Sends a request with this input using the given client.
     pub async fn send_with(
         self,
         client: &crate::Client,
     ) -> ::std::result::Result<
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let mut fluent_builder = client.endpoint_with_host_label_operation();
         fluent_builder.inner = self;
         fluent_builder.send().await
-24
+    }
-25
+}
 /// Fluent builder constructing a request to `EndpointWithHostLabelOperation`.
 /// /* FluentBuilderGenerator.kt:129 */Fluent builder constructing a request to `EndpointWithHostLabelOperation`.
 ///
 /* RustType.kt:516 */
 #[derive(::std::clone::Clone, ::std::fmt::Debug)]
 /* FluentBuilderGenerator.kt:270 */
 pub struct EndpointWithHostLabelOperationFluentBuilder {
     handle: ::std::sync::Arc<crate::client::Handle>,
     inner: crate::operation::endpoint_with_host_label_operation::builders::EndpointWithHostLabelOperationInputBuilder,
     config_override: ::std::option::Option<crate::config::Builder>,
-35
+}
 /* FluentBuilderGenerator.kt:381 */
 impl
     crate::client::customize::internal::CustomizableSend<
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput,
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
     > for EndpointWithHostLabelOperationFluentBuilder
-42
+{
     fn send(
         self,
         config_override: crate::config::Builder,
     ) -> crate::client::customize::internal::BoxFuture<
         crate::client::customize::internal::SendResult<
             crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput,
             crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
         >,
     > {
         ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
-53
+    }
-54
+}
 /* FluentBuilderGenerator.kt:282 */
 impl EndpointWithHostLabelOperationFluentBuilder {
     /* FluentBuilderGenerator.kt:288 */
     /// Creates a new `EndpointWithHostLabelOperationFluentBuilder`.
     pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
         Self {
             handle,
             inner: ::std::default::Default::default(),
             config_override: ::std::option::Option::None,
-64
+        }
-65
+    }
     /* FluentBuilderGenerator.kt:301 */
     /// Access the EndpointWithHostLabelOperation as a reference.
     pub fn as_input(&self) -> &crate::operation::endpoint_with_host_label_operation::builders::EndpointWithHostLabelOperationInputBuilder {
         &self.inner
-70
+    }
     /* FluentBuilderGenerator.kt:145 */
     /// Sends the request and returns the response.
     ///
     /// If an error occurs, an `SdkError` will be returned with additional details that
     /// can be matched against.
     ///
     /// By default, any retryable failures will be retried twice. Retry behavior
     /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
     /// set when configuring the client.
     pub async fn send(
         self,
     ) -> ::std::result::Result<
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput,
         ::aws_smithy_runtime_api::client::result::SdkError<
             crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
             ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
         >,
     > {
         let input = self
             .inner
             .build()
             .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
         let runtime_plugins = crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperation::operation_runtime_plugins(
             self.handle.runtime_plugins.clone(),
             &self.handle.conf,
             self.config_override,
         );
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperation::orchestrate(&runtime_plugins, input).await
-99
+    }
-100
     /// Consumes this builder, creating a customizable operation that can be modified before being sent.
     pub fn customize(
         self,
     ) -> crate::client::customize::CustomizableOperation<
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationOutput,
         crate::operation::endpoint_with_host_label_operation::EndpointWithHostLabelOperationError,
         Self,
     > {
         crate::client::customize::CustomizableOperation::new(self)
-110
+    }
     /* FluentBuilderGenerator.kt:315 */
     pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
         self.set_config_override(::std::option::Option::Some(config_override.into()));
         self
-115
+    }
-116
     pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
         self.config_override = config_override;
         self
-120
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn label(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
         self.inner = self.inner.label(input.into());
         self
-127
+    }
     /* FluentBuilderGenerator.kt:498 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:500 */
     pub fn set_label(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
         self.inner = self.inner.set_label(input);
         self
-134
+    }
     /* FluentBuilderGenerator.kt:518 */
     #[allow(missing_docs)] // documentation missing in model
                            /* FluentBuilderGenerator.kt:520 */
     pub fn get_label(&self) -> &::std::option::Option<::std::string::String> {
         self.inner.get_label()
-140
+    }
     /* FluentBuilderGenerator.kt:282 */
-142
+}

Client Test

Files changed: