aws-sdk-datazone 1.136.0

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
pub use crate::operation::create_data_source::_create_data_source_input::CreateDataSourceInputBuilder;

pub use crate::operation::create_data_source::_create_data_source_output::CreateDataSourceOutputBuilder;

impl crate::operation::create_data_source::builders::CreateDataSourceInputBuilder {
    /// Sends a request with this input using the given client.
    pub async fn send_with(
        self,
        client: &crate::Client,
    ) -> ::std::result::Result<
        crate::operation::create_data_source::CreateDataSourceOutput,
        ::aws_smithy_runtime_api::client::result::SdkError<
            crate::operation::create_data_source::CreateDataSourceError,
            ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
        >,
    > {
        let mut fluent_builder = client.create_data_source();
        fluent_builder.inner = self;
        fluent_builder.send().await
    }
}
/// Fluent builder constructing a request to `CreateDataSource`.
///
/// <p>Creates an Amazon DataZone data source.</p>
#[derive(::std::clone::Clone, ::std::fmt::Debug)]
pub struct CreateDataSourceFluentBuilder {
    handle: ::std::sync::Arc<crate::client::Handle>,
    inner: crate::operation::create_data_source::builders::CreateDataSourceInputBuilder,
    config_override: ::std::option::Option<crate::config::Builder>,
}
impl
    crate::client::customize::internal::CustomizableSend<
        crate::operation::create_data_source::CreateDataSourceOutput,
        crate::operation::create_data_source::CreateDataSourceError,
    > for CreateDataSourceFluentBuilder
{
    fn send(
        self,
        config_override: crate::config::Builder,
    ) -> crate::client::customize::internal::BoxFuture<
        crate::client::customize::internal::SendResult<
            crate::operation::create_data_source::CreateDataSourceOutput,
            crate::operation::create_data_source::CreateDataSourceError,
        >,
    > {
        ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
    }
}
impl CreateDataSourceFluentBuilder {
    /// Creates a new `CreateDataSourceFluentBuilder`.
    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 CreateDataSource as a reference.
    pub fn as_input(&self) -> &crate::operation::create_data_source::builders::CreateDataSourceInputBuilder {
        &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::create_data_source::CreateDataSourceOutput,
        ::aws_smithy_runtime_api::client::result::SdkError<
            crate::operation::create_data_source::CreateDataSourceError,
            ::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::create_data_source::CreateDataSource::operation_runtime_plugins(
            self.handle.runtime_plugins.clone(),
            &self.handle.conf,
            self.config_override,
        );
        crate::operation::create_data_source::CreateDataSource::orchestrate(&runtime_plugins, input).await
    }

    /// Consumes this builder, creating a customizable operation that can be modified before being sent.
    pub fn customize(
        self,
    ) -> crate::client::customize::CustomizableOperation<
        crate::operation::create_data_source::CreateDataSourceOutput,
        crate::operation::create_data_source::CreateDataSourceError,
        Self,
    > {
        crate::client::customize::CustomizableOperation::new(self)
    }
    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
    }

    pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
        self.config_override = config_override;
        self
    }
    /// <p>The name of the data source.</p>
    pub fn name(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.name(input.into());
        self
    }
    /// <p>The name of the data source.</p>
    pub fn set_name(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_name(input);
        self
    }
    /// <p>The name of the data source.</p>
    pub fn get_name(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_name()
    }
    /// <p>The description of the data source.</p>
    pub fn description(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.description(input.into());
        self
    }
    /// <p>The description of the data source.</p>
    pub fn set_description(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_description(input);
        self
    }
    /// <p>The description of the data source.</p>
    pub fn get_description(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_description()
    }
    /// <p>The ID of the Amazon DataZone domain where the data source is created.</p>
    pub fn domain_identifier(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.domain_identifier(input.into());
        self
    }
    /// <p>The ID of the Amazon DataZone domain where the data source is created.</p>
    pub fn set_domain_identifier(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_domain_identifier(input);
        self
    }
    /// <p>The ID of the Amazon DataZone domain where the data source is created.</p>
    pub fn get_domain_identifier(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_domain_identifier()
    }
    /// <p>The identifier of the Amazon DataZone project in which you want to add this data source.</p>
    pub fn project_identifier(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.project_identifier(input.into());
        self
    }
    /// <p>The identifier of the Amazon DataZone project in which you want to add this data source.</p>
    pub fn set_project_identifier(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_project_identifier(input);
        self
    }
    /// <p>The identifier of the Amazon DataZone project in which you want to add this data source.</p>
    pub fn get_project_identifier(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_project_identifier()
    }
    /// <p>The unique identifier of the Amazon DataZone environment to which the data source publishes assets.</p>
    pub fn environment_identifier(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.environment_identifier(input.into());
        self
    }
    /// <p>The unique identifier of the Amazon DataZone environment to which the data source publishes assets.</p>
    pub fn set_environment_identifier(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_environment_identifier(input);
        self
    }
    /// <p>The unique identifier of the Amazon DataZone environment to which the data source publishes assets.</p>
    pub fn get_environment_identifier(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_environment_identifier()
    }
    /// <p>The ID of the connection.</p>
    pub fn connection_identifier(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.connection_identifier(input.into());
        self
    }
    /// <p>The ID of the connection.</p>
    pub fn set_connection_identifier(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_connection_identifier(input);
        self
    }
    /// <p>The ID of the connection.</p>
    pub fn get_connection_identifier(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_connection_identifier()
    }
    /// <p>The type of the data source. In Amazon DataZone, you can use data sources to import technical metadata of assets (data) from the source databases or data warehouses into Amazon DataZone. In the current release of Amazon DataZone, you can create and run data sources for Amazon Web Services Glue and Amazon Redshift.</p>
    pub fn r#type(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.r#type(input.into());
        self
    }
    /// <p>The type of the data source. In Amazon DataZone, you can use data sources to import technical metadata of assets (data) from the source databases or data warehouses into Amazon DataZone. In the current release of Amazon DataZone, you can create and run data sources for Amazon Web Services Glue and Amazon Redshift.</p>
    pub fn set_type(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_type(input);
        self
    }
    /// <p>The type of the data source. In Amazon DataZone, you can use data sources to import technical metadata of assets (data) from the source databases or data warehouses into Amazon DataZone. In the current release of Amazon DataZone, you can create and run data sources for Amazon Web Services Glue and Amazon Redshift.</p>
    pub fn get_type(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_type()
    }
    /// <p>Specifies the configuration of the data source. It can be set to either <code>glueRunConfiguration</code> or <code>redshiftRunConfiguration</code>.</p>
    pub fn configuration(mut self, input: crate::types::DataSourceConfigurationInput) -> Self {
        self.inner = self.inner.configuration(input);
        self
    }
    /// <p>Specifies the configuration of the data source. It can be set to either <code>glueRunConfiguration</code> or <code>redshiftRunConfiguration</code>.</p>
    pub fn set_configuration(mut self, input: ::std::option::Option<crate::types::DataSourceConfigurationInput>) -> Self {
        self.inner = self.inner.set_configuration(input);
        self
    }
    /// <p>Specifies the configuration of the data source. It can be set to either <code>glueRunConfiguration</code> or <code>redshiftRunConfiguration</code>.</p>
    pub fn get_configuration(&self) -> &::std::option::Option<crate::types::DataSourceConfigurationInput> {
        self.inner.get_configuration()
    }
    /// <p>Specifies whether the business name generation is to be enabled for this data source.</p>
    pub fn recommendation(mut self, input: crate::types::RecommendationConfiguration) -> Self {
        self.inner = self.inner.recommendation(input);
        self
    }
    /// <p>Specifies whether the business name generation is to be enabled for this data source.</p>
    pub fn set_recommendation(mut self, input: ::std::option::Option<crate::types::RecommendationConfiguration>) -> Self {
        self.inner = self.inner.set_recommendation(input);
        self
    }
    /// <p>Specifies whether the business name generation is to be enabled for this data source.</p>
    pub fn get_recommendation(&self) -> &::std::option::Option<crate::types::RecommendationConfiguration> {
        self.inner.get_recommendation()
    }
    /// <p>Specifies whether the data source is enabled.</p>
    pub fn enable_setting(mut self, input: crate::types::EnableSetting) -> Self {
        self.inner = self.inner.enable_setting(input);
        self
    }
    /// <p>Specifies whether the data source is enabled.</p>
    pub fn set_enable_setting(mut self, input: ::std::option::Option<crate::types::EnableSetting>) -> Self {
        self.inner = self.inner.set_enable_setting(input);
        self
    }
    /// <p>Specifies whether the data source is enabled.</p>
    pub fn get_enable_setting(&self) -> &::std::option::Option<crate::types::EnableSetting> {
        self.inner.get_enable_setting()
    }
    /// <p>The schedule of the data source runs.</p>
    pub fn schedule(mut self, input: crate::types::ScheduleConfiguration) -> Self {
        self.inner = self.inner.schedule(input);
        self
    }
    /// <p>The schedule of the data source runs.</p>
    pub fn set_schedule(mut self, input: ::std::option::Option<crate::types::ScheduleConfiguration>) -> Self {
        self.inner = self.inner.set_schedule(input);
        self
    }
    /// <p>The schedule of the data source runs.</p>
    pub fn get_schedule(&self) -> &::std::option::Option<crate::types::ScheduleConfiguration> {
        self.inner.get_schedule()
    }
    /// <p>Specifies whether the assets that this data source creates in the inventory are to be also automatically published to the catalog.</p>
    pub fn publish_on_import(mut self, input: bool) -> Self {
        self.inner = self.inner.publish_on_import(input);
        self
    }
    /// <p>Specifies whether the assets that this data source creates in the inventory are to be also automatically published to the catalog.</p>
    pub fn set_publish_on_import(mut self, input: ::std::option::Option<bool>) -> Self {
        self.inner = self.inner.set_publish_on_import(input);
        self
    }
    /// <p>Specifies whether the assets that this data source creates in the inventory are to be also automatically published to the catalog.</p>
    pub fn get_publish_on_import(&self) -> &::std::option::Option<bool> {
        self.inner.get_publish_on_import()
    }
    ///
    /// Appends an item to `assetFormsInput`.
    ///
    /// To override the contents of this collection use [`set_asset_forms_input`](Self::set_asset_forms_input).
    ///
    /// <p>The metadata forms that are to be attached to the assets that this data source works with.</p>
    pub fn asset_forms_input(mut self, input: crate::types::FormInput) -> Self {
        self.inner = self.inner.asset_forms_input(input);
        self
    }
    /// <p>The metadata forms that are to be attached to the assets that this data source works with.</p>
    pub fn set_asset_forms_input(mut self, input: ::std::option::Option<::std::vec::Vec<crate::types::FormInput>>) -> Self {
        self.inner = self.inner.set_asset_forms_input(input);
        self
    }
    /// <p>The metadata forms that are to be attached to the assets that this data source works with.</p>
    pub fn get_asset_forms_input(&self) -> &::std::option::Option<::std::vec::Vec<crate::types::FormInput>> {
        self.inner.get_asset_forms_input()
    }
    /// <p>A unique, case-sensitive identifier that is provided to ensure the idempotency of the request.</p>
    pub fn client_token(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.inner = self.inner.client_token(input.into());
        self
    }
    /// <p>A unique, case-sensitive identifier that is provided to ensure the idempotency of the request.</p>
    pub fn set_client_token(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.inner = self.inner.set_client_token(input);
        self
    }
    /// <p>A unique, case-sensitive identifier that is provided to ensure the idempotency of the request.</p>
    pub fn get_client_token(&self) -> &::std::option::Option<::std::string::String> {
        self.inner.get_client_token()
    }
}