aws_sdk_s3/operation/
create_bucket.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2/// Orchestration and serialization glue logic for `CreateBucket`.
3#[derive(::std::clone::Clone, ::std::default::Default, ::std::fmt::Debug)]
4#[non_exhaustive]
5pub struct CreateBucket;
6impl CreateBucket {
7    /// Creates a new `CreateBucket`
8    pub fn new() -> Self {
9        Self
10    }
11    pub(crate) async fn orchestrate(
12        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
13        input: crate::operation::create_bucket::CreateBucketInput,
14    ) -> ::std::result::Result<
15        crate::operation::create_bucket::CreateBucketOutput,
16        ::aws_smithy_runtime_api::client::result::SdkError<
17            crate::operation::create_bucket::CreateBucketError,
18            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
19        >,
20    > {
21        let map_err = |err: ::aws_smithy_runtime_api::client::result::SdkError<
22            ::aws_smithy_runtime_api::client::interceptors::context::Error,
23            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
24        >| {
25            err.map_service_error(|err| {
26                err.downcast::<crate::operation::create_bucket::CreateBucketError>()
27                    .expect("correct error type")
28            })
29        };
30        let context = Self::orchestrate_with_stop_point(runtime_plugins, input, ::aws_smithy_runtime::client::orchestrator::StopPoint::None)
31            .await
32            .map_err(map_err)?;
33        let output = context.finalize().map_err(map_err)?;
34        ::std::result::Result::Ok(
35            output
36                .downcast::<crate::operation::create_bucket::CreateBucketOutput>()
37                .expect("correct output type"),
38        )
39    }
40
41    pub(crate) async fn orchestrate_with_stop_point(
42        runtime_plugins: &::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
43        input: crate::operation::create_bucket::CreateBucketInput,
44        stop_point: ::aws_smithy_runtime::client::orchestrator::StopPoint,
45    ) -> ::std::result::Result<
46        ::aws_smithy_runtime_api::client::interceptors::context::InterceptorContext,
47        ::aws_smithy_runtime_api::client::result::SdkError<
48            ::aws_smithy_runtime_api::client::interceptors::context::Error,
49            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
50        >,
51    > {
52        let input = ::aws_smithy_runtime_api::client::interceptors::context::Input::erase(input);
53        use ::tracing::Instrument;
54        ::aws_smithy_runtime::client::orchestrator::invoke_with_stop_point("S3", "CreateBucket", input, runtime_plugins, stop_point)
55            // Create a parent span for the entire operation. Includes a random, internal-only,
56            // seven-digit ID for the operation orchestration so that it can be correlated in the logs.
57            .instrument(::tracing::debug_span!(
58                "S3.CreateBucket",
59                "rpc.service" = "S3",
60                "rpc.method" = "CreateBucket",
61                "sdk_invocation_id" = ::fastrand::u32(1_000_000..10_000_000),
62                "rpc.system" = "aws-api",
63            ))
64            .await
65    }
66
67    pub(crate) fn operation_runtime_plugins(
68        client_runtime_plugins: ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins,
69        client_config: &crate::config::Config,
70        config_override: ::std::option::Option<crate::config::Builder>,
71    ) -> ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugins {
72        let mut runtime_plugins = client_runtime_plugins.with_operation_plugin(Self::new());
73
74        if let ::std::option::Option::Some(config_override) = config_override {
75            for plugin in config_override.runtime_plugins.iter().cloned() {
76                runtime_plugins = runtime_plugins.with_operation_plugin(plugin);
77            }
78            runtime_plugins = runtime_plugins.with_operation_plugin(crate::config::ConfigOverrideRuntimePlugin::new(
79                config_override,
80                client_config.config.clone(),
81                &client_config.runtime_components,
82            ));
83        }
84        runtime_plugins
85    }
86}
87impl ::aws_smithy_runtime_api::client::runtime_plugin::RuntimePlugin for CreateBucket {
88    fn config(&self) -> ::std::option::Option<::aws_smithy_types::config_bag::FrozenLayer> {
89        let mut cfg = ::aws_smithy_types::config_bag::Layer::new("CreateBucket");
90
91        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedRequestSerializer::new(
92            CreateBucketRequestSerializer,
93        ));
94        cfg.store_put(::aws_smithy_runtime_api::client::ser_de::SharedResponseDeserializer::new(
95            CreateBucketResponseDeserializer,
96        ));
97
98        cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
99            crate::config::auth::Params::builder()
100                .operation_name("CreateBucket")
101                .build()
102                .expect("required fields set"),
103        ));
104
105        cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new("CreateBucket", "S3"));
106        let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
107        signing_options.double_uri_encode = false;
108        signing_options.content_sha256_header = true;
109        signing_options.normalize_uri_path = false;
110        signing_options.payload_override = None;
111
112        cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
113            signing_options,
114            ..::std::default::Default::default()
115        });
116
117        ::std::option::Option::Some(cfg.freeze())
118    }
119
120    fn runtime_components(
121        &self,
122        _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
123    ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
124        #[allow(unused_mut)]
125        let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("CreateBucket")
126            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
127                CreateBucketTelemetryInputCaptureInterceptor,
128            ))
129            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
130                ::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default(),
131            ))
132            .with_interceptor(::aws_smithy_runtime_api::client::interceptors::SharedInterceptor::permanent(
133                CreateBucketEndpointParamsInterceptor,
134            ))
135            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
136                crate::operation::create_bucket::CreateBucketError,
137            >::new())
138            .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
139                crate::operation::create_bucket::CreateBucketError,
140            >::new())
141            .with_retry_classifier(
142                ::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<crate::operation::create_bucket::CreateBucketError>::builder()
143                    .transient_errors({
144                        let mut transient_errors: Vec<&'static str> = ::aws_runtime::retries::classifiers::TRANSIENT_ERRORS.into();
145                        transient_errors.push("InternalError");
146                        ::std::borrow::Cow::Owned(transient_errors)
147                    })
148                    .build(),
149            )
150            .with_retry_classifier(::aws_runtime::service_clock_skew::ServiceClockSkewClassifier::<
151                crate::operation::create_bucket::CreateBucketError,
152            >::new());
153
154        ::std::borrow::Cow::Owned(rcb)
155    }
156}
157
158#[derive(Debug)]
159struct CreateBucketTelemetryInputCaptureInterceptor;
160
161#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
162impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateBucketTelemetryInputCaptureInterceptor {
163    fn name(&self) -> &'static str {
164        "CreateBucketTelemetryInputCaptureInterceptor"
165    }
166
167    fn read_before_execution(
168        &self,
169        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
170            '_,
171            ::aws_smithy_runtime_api::client::interceptors::context::Input,
172            ::aws_smithy_runtime_api::client::interceptors::context::Output,
173            ::aws_smithy_runtime_api::client::interceptors::context::Error,
174        >,
175        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
176    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
177        // Nothing to do unless the customer opted in by naming members to record.
178        let ::std::option::Option::Some(requested) = cfg
179            .load::<::aws_smithy_types::telemetry::RequestedTelemetryAttributes>()
180            .filter(|r| !r.is_empty())
181        else {
182            return ::std::result::Result::Ok(());
183        };
184
185        let ::std::option::Option::Some(input) = context.input().downcast_ref::<CreateBucketInput>() else {
186            // A mismatched input is not this interceptor's concern; skip quietly.
187            return ::std::result::Result::Ok(());
188        };
189
190        let mut captured = ::aws_smithy_types::telemetry::CapturedTelemetryAttributes::default();
191        if requested.should_capture("Bucket") {
192            if let ::std::option::Option::Some(value) = input.bucket.as_deref() {
193                captured.insert("Bucket", value);
194            }
195        }
196        if requested.should_capture("GrantFullControl") {
197            if let ::std::option::Option::Some(value) = input.grant_full_control.as_deref() {
198                captured.insert("GrantFullControl", value);
199            }
200        }
201        if requested.should_capture("GrantRead") {
202            if let ::std::option::Option::Some(value) = input.grant_read.as_deref() {
203                captured.insert("GrantRead", value);
204            }
205        }
206        if requested.should_capture("GrantReadACP") {
207            if let ::std::option::Option::Some(value) = input.grant_read_acp.as_deref() {
208                captured.insert("GrantReadACP", value);
209            }
210        }
211        if requested.should_capture("GrantWrite") {
212            if let ::std::option::Option::Some(value) = input.grant_write.as_deref() {
213                captured.insert("GrantWrite", value);
214            }
215        }
216        if requested.should_capture("GrantWriteACP") {
217            if let ::std::option::Option::Some(value) = input.grant_write_acp.as_deref() {
218                captured.insert("GrantWriteACP", value);
219            }
220        }
221
222        cfg.interceptor_state().store_put(captured);
223        ::std::result::Result::Ok(())
224    }
225}
226#[derive(Debug)]
227struct CreateBucketResponseDeserializer;
228impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for CreateBucketResponseDeserializer {
229    fn deserialize_nonstreaming_with_config(
230        &self,
231        response: &::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
232        _cfg: &::aws_smithy_types::config_bag::ConfigBag,
233    ) -> ::aws_smithy_runtime_api::client::interceptors::context::OutputOrError {
234        let (success, status) = (response.status().is_success(), response.status().as_u16());
235        let headers = response.headers();
236        let body = response.body().bytes().expect("body loaded");
237        #[allow(unused_mut)]
238        let mut force_error = false;
239        ::tracing::debug!(extended_request_id = ?crate::s3_request_id::RequestIdExt::extended_request_id(response));
240        if matches!(crate::rest_xml_unwrapped_errors::body_is_error(body), Ok(true)) {
241            force_error = true;
242        }
243        ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
244        let parse_result = if !success && status != 200 || force_error {
245            crate::protocol_serde::shape_create_bucket::de_create_bucket_http_error(status, headers, body, _cfg)
246        } else {
247            crate::protocol_serde::shape_create_bucket::de_create_bucket_http_response(status, headers, body, _cfg)
248        };
249        crate::protocol_serde::type_erase_result(parse_result)
250    }
251}
252#[derive(Debug)]
253struct CreateBucketRequestSerializer;
254impl ::aws_smithy_runtime_api::client::ser_de::SerializeRequest for CreateBucketRequestSerializer {
255    #[allow(unused_mut, clippy::let_and_return, clippy::needless_borrow, clippy::useless_conversion)]
256    fn serialize_input(
257        &self,
258        input: ::aws_smithy_runtime_api::client::interceptors::context::Input,
259        _cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
260    ) -> ::std::result::Result<::aws_smithy_runtime_api::client::orchestrator::HttpRequest, ::aws_smithy_runtime_api::box_error::BoxError> {
261        let input = input
262            .downcast::<crate::operation::create_bucket::CreateBucketInput>()
263            .expect("correct type");
264        let _header_serialization_settings = _cfg
265            .load::<crate::serialization_settings::HeaderSerializationSettings>()
266            .cloned()
267            .unwrap_or_default();
268        let mut request_builder = {
269            #[allow(clippy::uninlined_format_args)]
270            fn uri_base(
271                _input: &crate::operation::create_bucket::CreateBucketInput,
272                output: &mut ::std::string::String,
273            ) -> ::std::result::Result<(), ::aws_smithy_types::error::operation::BuildError> {
274                use ::std::fmt::Write as _;
275                ::std::write!(output, "/").expect("formatting should succeed");
276                ::std::result::Result::Ok(())
277            }
278            #[allow(clippy::unnecessary_wraps)]
279            fn update_http_builder(
280                input: &crate::operation::create_bucket::CreateBucketInput,
281                builder: ::http_1x::request::Builder,
282            ) -> ::std::result::Result<::http_1x::request::Builder, ::aws_smithy_types::error::operation::BuildError> {
283                let mut uri = ::std::string::String::new();
284                uri_base(input, &mut uri)?;
285                let builder = crate::protocol_serde::shape_create_bucket::ser_create_bucket_headers(input, builder)?;
286                ::std::result::Result::Ok(builder.method("PUT").uri(uri))
287            }
288            let mut builder = update_http_builder(&input, ::http_1x::request::Builder::new())?;
289            builder = _header_serialization_settings.set_default_header(builder, ::http_1x::header::CONTENT_TYPE, "application/xml");
290            builder
291        };
292        let body = ::aws_smithy_types::body::SdkBody::from(
293            crate::protocol_serde::shape_create_bucket_input::ser_create_bucket_configuration_http_payload(&input.create_bucket_configuration)?,
294        );
295        if let Some(content_length) = body.content_length() {
296            let content_length = content_length.to_string();
297            request_builder = _header_serialization_settings.set_default_header(request_builder, ::http_1x::header::CONTENT_LENGTH, &content_length);
298        }
299        ::std::result::Result::Ok(request_builder.body(body).expect("valid request").try_into().unwrap())
300    }
301}
302#[derive(Debug)]
303struct CreateBucketEndpointParamsInterceptor;
304
305#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
306impl ::aws_smithy_runtime_api::client::interceptors::Intercept for CreateBucketEndpointParamsInterceptor {
307    fn name(&self) -> &'static str {
308        "CreateBucketEndpointParamsInterceptor"
309    }
310
311    fn read_before_execution(
312        &self,
313        context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<
314            '_,
315            ::aws_smithy_runtime_api::client::interceptors::context::Input,
316            ::aws_smithy_runtime_api::client::interceptors::context::Output,
317            ::aws_smithy_runtime_api::client::interceptors::context::Error,
318        >,
319        cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
320    ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
321        let _input = context
322            .input()
323            .downcast_ref::<CreateBucketInput>()
324            .ok_or("failed to downcast to CreateBucketInput")?;
325
326        let params = crate::config::endpoint::Params::builder()
327            .set_region(cfg.load::<::aws_types::region::Region>().map(|r| r.as_ref().to_owned()))
328            .set_use_fips(cfg.load::<::aws_types::endpoint_config::UseFips>().map(|ty| ty.0))
329            .set_use_dual_stack(cfg.load::<::aws_types::endpoint_config::UseDualStack>().map(|ty| ty.0))
330            .set_endpoint(cfg.load::<::aws_types::endpoint_config::EndpointUrl>().map(|ty| ty.0.clone()))
331            .set_force_path_style(cfg.load::<crate::config::ForcePathStyle>().map(|ty| ty.0))
332            .set_use_arn_region(cfg.load::<crate::config::UseArnRegion>().map(|ty| ty.0))
333            .set_disable_multi_region_access_points(cfg.load::<crate::config::DisableMultiRegionAccessPoints>().map(|ty| ty.0))
334            .set_accelerate(cfg.load::<crate::config::Accelerate>().map(|ty| ty.0))
335            .set_disable_s3_express_session_auth(cfg.load::<crate::config::DisableS3ExpressSessionAuth>().map(|ty| ty.0))
336            .set_use_s3_express_control_endpoint(Some(true))
337            .set_disable_access_points(Some(true))
338            .set_bucket(Some(
339                _input
340                    .bucket
341                    .clone()
342                    .filter(|f| !AsRef::<str>::as_ref(f).trim().is_empty())
343                    .ok_or_else(|| ::aws_smithy_types::error::operation::BuildError::missing_field("bucket", "A required field was not set"))?,
344            ))
345            .build()
346            .map_err(|err| {
347                ::aws_smithy_runtime_api::client::interceptors::error::ContextAttachedError::new("endpoint params could not be built", err)
348            })?;
349        cfg.interceptor_state()
350            .store_put(::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams::new(params));
351        ::std::result::Result::Ok(())
352    }
353}
354
355// The get_* functions below are generated from JMESPath expressions in the
356// operationContextParams trait. They target the operation's input shape.
357
358/// Error type for the `CreateBucketError` operation.
359#[non_exhaustive]
360#[derive(::std::fmt::Debug)]
361pub enum CreateBucketError {
362    /// <p>The requested bucket name is not available. The bucket namespace is shared by all users of the system. Select a different name and try again.</p>
363    BucketAlreadyExists(crate::types::error::BucketAlreadyExists),
364    /// <p>The bucket you tried to create already exists, and you own it. Amazon S3 returns this error in all Amazon Web Services Regions except in the North Virginia Region. For legacy compatibility, if you re-create an existing bucket that you already own in the North Virginia Region, Amazon S3 returns 200 OK and resets the bucket access control lists (ACLs).</p>
365    BucketAlreadyOwnedByYou(crate::types::error::BucketAlreadyOwnedByYou),
366    /// An unexpected error occurred (e.g., invalid JSON returned by the service or an unknown error code).
367    #[deprecated(note = "Matching `Unhandled` directly is not forwards compatible. Instead, match using a \
368    variable wildcard pattern and check `.code()`:
369     \
370    &nbsp;&nbsp;&nbsp;`err if err.code() == Some(\"SpecificExceptionCode\") => { /* handle the error */ }`
371     \
372    See [`ProvideErrorMetadata`](#impl-ProvideErrorMetadata-for-CreateBucketError) for what information is available for the error.")]
373    Unhandled(crate::error::sealed_unhandled::Unhandled),
374}
375impl CreateBucketError {
376    /// Creates the `CreateBucketError::Unhandled` variant from any error type.
377    pub fn unhandled(
378        err: impl ::std::convert::Into<::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>>,
379    ) -> Self {
380        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
381            source: err.into(),
382            meta: ::std::default::Default::default(),
383        })
384    }
385
386    /// Creates the `CreateBucketError::Unhandled` variant from an [`ErrorMetadata`](::aws_smithy_types::error::ErrorMetadata).
387    pub fn generic(err: ::aws_smithy_types::error::ErrorMetadata) -> Self {
388        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
389            source: err.clone().into(),
390            meta: err,
391        })
392    }
393    ///
394    /// Returns error metadata, which includes the error code, message,
395    /// request ID, and potentially additional information.
396    ///
397    pub fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
398        match self {
399            Self::BucketAlreadyExists(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
400            Self::BucketAlreadyOwnedByYou(e) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(e),
401            Self::Unhandled(e) => &e.meta,
402        }
403    }
404    /// Returns `true` if the error kind is `CreateBucketError::BucketAlreadyExists`.
405    pub fn is_bucket_already_exists(&self) -> bool {
406        matches!(self, Self::BucketAlreadyExists(_))
407    }
408    /// Returns `true` if the error kind is `CreateBucketError::BucketAlreadyOwnedByYou`.
409    pub fn is_bucket_already_owned_by_you(&self) -> bool {
410        matches!(self, Self::BucketAlreadyOwnedByYou(_))
411    }
412}
413impl ::std::error::Error for CreateBucketError {
414    fn source(&self) -> ::std::option::Option<&(dyn ::std::error::Error + 'static)> {
415        match self {
416            Self::BucketAlreadyExists(_inner) => ::std::option::Option::Some(_inner),
417            Self::BucketAlreadyOwnedByYou(_inner) => ::std::option::Option::Some(_inner),
418            Self::Unhandled(_inner) => ::std::option::Option::Some(&*_inner.source),
419        }
420    }
421}
422impl ::std::fmt::Display for CreateBucketError {
423    fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
424        match self {
425            Self::BucketAlreadyExists(_inner) => _inner.fmt(f),
426            Self::BucketAlreadyOwnedByYou(_inner) => _inner.fmt(f),
427            Self::Unhandled(_inner) => {
428                if let ::std::option::Option::Some(code) = ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self) {
429                    write!(f, "unhandled error ({code})")
430                } else {
431                    f.write_str("unhandled error")
432                }
433            }
434        }
435    }
436}
437impl ::aws_smithy_types::retry::ProvideErrorKind for CreateBucketError {
438    fn code(&self) -> ::std::option::Option<&str> {
439        ::aws_smithy_types::error::metadata::ProvideErrorMetadata::code(self)
440    }
441    fn retryable_error_kind(&self) -> ::std::option::Option<::aws_smithy_types::retry::ErrorKind> {
442        ::std::option::Option::None
443    }
444}
445impl ::aws_smithy_types::error::metadata::ProvideErrorMetadata for CreateBucketError {
446    fn meta(&self) -> &::aws_smithy_types::error::ErrorMetadata {
447        match self {
448            Self::BucketAlreadyExists(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
449            Self::BucketAlreadyOwnedByYou(_inner) => ::aws_smithy_types::error::metadata::ProvideErrorMetadata::meta(_inner),
450            Self::Unhandled(_inner) => &_inner.meta,
451        }
452    }
453}
454impl ::aws_smithy_runtime_api::client::result::CreateUnhandledError for CreateBucketError {
455    fn create_unhandled_error(
456        source: ::std::boxed::Box<dyn ::std::error::Error + ::std::marker::Send + ::std::marker::Sync + 'static>,
457        meta: ::std::option::Option<::aws_smithy_types::error::ErrorMetadata>,
458    ) -> Self {
459        Self::Unhandled(crate::error::sealed_unhandled::Unhandled {
460            source,
461            meta: meta.unwrap_or_default(),
462        })
463    }
464}
465impl crate::s3_request_id::RequestIdExt for crate::operation::create_bucket::CreateBucketError {
466    fn extended_request_id(&self) -> Option<&str> {
467        self.meta().extended_request_id()
468    }
469}
470impl ::aws_types::request_id::RequestId for crate::operation::create_bucket::CreateBucketError {
471    fn request_id(&self) -> Option<&str> {
472        self.meta().request_id()
473    }
474}
475
476pub use crate::operation::create_bucket::_create_bucket_input::CreateBucketInput;
477
478pub use crate::operation::create_bucket::_create_bucket_output::CreateBucketOutput;
479
480mod _create_bucket_input;
481
482mod _create_bucket_output;
483
484/// Builders
485pub mod builders;
aws_sdk_s3/operation/create_bucket.rs

aws_sdk_s3/operation/
create_bucket.rs
