1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
pub use crate::operation::update_datastore::_update_datastore_output::UpdateDatastoreOutputBuilder;
pub use crate::operation::update_datastore::_update_datastore_input::UpdateDatastoreInputBuilder;
impl UpdateDatastoreInputBuilder {
/// Sends a request with this input using the given client.
pub async fn send_with(
self,
client: &crate::Client,
) -> ::std::result::Result<
crate::operation::update_datastore::UpdateDatastoreOutput,
::aws_smithy_http::result::SdkError<
crate::operation::update_datastore::UpdateDatastoreError,
::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
>,
> {
let mut fluent_builder = client.update_datastore();
fluent_builder.inner = self;
fluent_builder.send().await
}
}
/// Fluent builder constructing a request to `UpdateDatastore`.
///
/// <p>Used to update the settings of a data store.</p>
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
pub struct UpdateDatastoreFluentBuilder {
handle: ::std::sync::Arc<crate::client::Handle>,
inner: crate::operation::update_datastore::builders::UpdateDatastoreInputBuilder,
config_override: ::std::option::Option<crate::config::Builder>,
}
impl UpdateDatastoreFluentBuilder {
/// Creates a new `UpdateDatastore`.
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,
}
}
/// Access the UpdateDatastore as a reference.
pub fn as_input(&self) -> &crate::operation::update_datastore::builders::UpdateDatastoreInputBuilder {
&self.inner
}
/// 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::update_datastore::UpdateDatastoreOutput,
::aws_smithy_http::result::SdkError<
crate::operation::update_datastore::UpdateDatastoreError,
::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
>,
> {
let input = self.inner.build().map_err(::aws_smithy_http::result::SdkError::construction_failure)?;
let runtime_plugins = crate::operation::update_datastore::UpdateDatastore::operation_runtime_plugins(
self.handle.runtime_plugins.clone(),
&self.handle.conf,
self.config_override,
);
crate::operation::update_datastore::UpdateDatastore::orchestrate(&runtime_plugins, input).await
}
/// Consumes this builder, creating a customizable operation that can be modified before being
/// sent.
// TODO(enableNewSmithyRuntimeCleanup): Remove `async` and `Result` once we switch to orchestrator
pub async fn customize(
self,
) -> ::std::result::Result<
crate::client::customize::orchestrator::CustomizableOperation<
crate::operation::update_datastore::UpdateDatastoreOutput,
crate::operation::update_datastore::UpdateDatastoreError,
>,
::aws_smithy_http::result::SdkError<crate::operation::update_datastore::UpdateDatastoreError>,
> {
::std::result::Result::Ok(crate::client::customize::orchestrator::CustomizableOperation {
customizable_send: ::std::boxed::Box::new(move |config_override| {
::std::boxed::Box::pin(async { self.config_override(config_override).send().await })
}),
config_override: None,
interceptors: vec![],
runtime_plugins: vec![],
})
}
pub(crate) fn config_override(mut self, config_override: impl Into<crate::config::Builder>) -> Self {
self.set_config_override(Some(config_override.into()));
self
}
pub(crate) fn set_config_override(&mut self, config_override: Option<crate::config::Builder>) -> &mut Self {
self.config_override = config_override;
self
}
/// <p>The name of the data store to be updated.</p>
pub fn datastore_name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
self.inner = self.inner.datastore_name(input.into());
self
}
/// <p>The name of the data store to be updated.</p>
pub fn set_datastore_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
self.inner = self.inner.set_datastore_name(input);
self
}
/// <p>The name of the data store to be updated.</p>
pub fn get_datastore_name(&self) -> &::std::option::Option<::std::string::String> {
self.inner.get_datastore_name()
}
/// <p>How long, in days, message data is kept for the data store. The retention period can't be updated if the data store's Amazon S3 storage is customer-managed.</p>
pub fn retention_period(mut self, input: crate::types::RetentionPeriod) -> Self {
self.inner = self.inner.retention_period(input);
self
}
/// <p>How long, in days, message data is kept for the data store. The retention period can't be updated if the data store's Amazon S3 storage is customer-managed.</p>
pub fn set_retention_period(mut self, input: ::std::option::Option<crate::types::RetentionPeriod>) -> Self {
self.inner = self.inner.set_retention_period(input);
self
}
/// <p>How long, in days, message data is kept for the data store. The retention period can't be updated if the data store's Amazon S3 storage is customer-managed.</p>
pub fn get_retention_period(&self) -> &::std::option::Option<crate::types::RetentionPeriod> {
self.inner.get_retention_period()
}
/// <p>Where data in a data store is stored.. You can choose <code>serviceManagedS3</code> storage, <code>customerManagedS3</code> storage, or <code>iotSiteWiseMultiLayerStorage</code> storage. The default is <code>serviceManagedS3</code>. You can't change the choice of Amazon S3 storage after your data store is created. </p>
pub fn datastore_storage(mut self, input: crate::types::DatastoreStorage) -> Self {
self.inner = self.inner.datastore_storage(input);
self
}
/// <p>Where data in a data store is stored.. You can choose <code>serviceManagedS3</code> storage, <code>customerManagedS3</code> storage, or <code>iotSiteWiseMultiLayerStorage</code> storage. The default is <code>serviceManagedS3</code>. You can't change the choice of Amazon S3 storage after your data store is created. </p>
pub fn set_datastore_storage(mut self, input: ::std::option::Option<crate::types::DatastoreStorage>) -> Self {
self.inner = self.inner.set_datastore_storage(input);
self
}
/// <p>Where data in a data store is stored.. You can choose <code>serviceManagedS3</code> storage, <code>customerManagedS3</code> storage, or <code>iotSiteWiseMultiLayerStorage</code> storage. The default is <code>serviceManagedS3</code>. You can't change the choice of Amazon S3 storage after your data store is created. </p>
pub fn get_datastore_storage(&self) -> &::std::option::Option<crate::types::DatastoreStorage> {
self.inner.get_datastore_storage()
}
/// <p>Contains the configuration information of file formats. IoT Analytics data stores support JSON and <a href="https://parquet.apache.org/">Parquet</a>.</p>
/// <p>The default file format is JSON. You can specify only one format.</p>
/// <p>You can't change the file format after you create the data store.</p>
pub fn file_format_configuration(mut self, input: crate::types::FileFormatConfiguration) -> Self {
self.inner = self.inner.file_format_configuration(input);
self
}
/// <p>Contains the configuration information of file formats. IoT Analytics data stores support JSON and <a href="https://parquet.apache.org/">Parquet</a>.</p>
/// <p>The default file format is JSON. You can specify only one format.</p>
/// <p>You can't change the file format after you create the data store.</p>
pub fn set_file_format_configuration(mut self, input: ::std::option::Option<crate::types::FileFormatConfiguration>) -> Self {
self.inner = self.inner.set_file_format_configuration(input);
self
}
/// <p>Contains the configuration information of file formats. IoT Analytics data stores support JSON and <a href="https://parquet.apache.org/">Parquet</a>.</p>
/// <p>The default file format is JSON. You can specify only one format.</p>
/// <p>You can't change the file format after you create the data store.</p>
pub fn get_file_format_configuration(&self) -> &::std::option::Option<crate::types::FileFormatConfiguration> {
self.inner.get_file_format_configuration()
}
}