aws-sdk-kafka 1.126.0

// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.

/// <p>Provisioned cluster.</p>
#[non_exhaustive]
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
pub struct Provisioned {
    /// <p>Information about the brokers.</p>
    pub broker_node_group_info: ::std::option::Option<crate::types::BrokerNodeGroupInfo>,
    /// <p>Specifies whether or not intelligent rebalancing is turned on for a newly created MSK Provisioned cluster with Express brokers. Intelligent rebalancing performs automatic partition balancing operations when you scale your clusters up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based clusters.</p>
    pub rebalancing: ::std::option::Option<crate::types::Rebalancing>,
    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
    pub current_broker_software_info: ::std::option::Option<crate::types::BrokerSoftwareInfo>,
    /// <p>Includes all client authentication information.</p>
    pub client_authentication: ::std::option::Option<crate::types::ClientAuthentication>,
    /// <p>Includes all encryption-related information.</p>
    pub encryption_info: ::std::option::Option<crate::types::EncryptionInfo>,
    /// <p>Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.</p>
    pub enhanced_monitoring: ::std::option::Option<crate::types::EnhancedMonitoring>,
    /// <p>The settings for open monitoring.</p>
    pub open_monitoring: ::std::option::Option<crate::types::OpenMonitoringInfo>,
    /// <p>Log delivery information for the cluster.</p>
    pub logging_info: ::std::option::Option<crate::types::LoggingInfo>,
    /// <p>The number of broker nodes in the cluster.</p>
    pub number_of_broker_nodes: ::std::option::Option<i32>,
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
    pub zookeeper_connect_string: ::std::option::Option<::std::string::String>,
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
    pub zookeeper_connect_string_tls: ::std::option::Option<::std::string::String>,
    /// <p>This controls storage mode for supported storage tiers.</p>
    pub storage_mode: ::std::option::Option<crate::types::StorageMode>,
    /// <p>Determines if there is an action required from the customer.</p>
    pub customer_action_status: ::std::option::Option<crate::types::CustomerActionStatus>,
}
impl Provisioned {
    /// <p>Information about the brokers.</p>
    pub fn broker_node_group_info(&self) -> ::std::option::Option<&crate::types::BrokerNodeGroupInfo> {
        self.broker_node_group_info.as_ref()
    }
    /// <p>Specifies whether or not intelligent rebalancing is turned on for a newly created MSK Provisioned cluster with Express brokers. Intelligent rebalancing performs automatic partition balancing operations when you scale your clusters up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based clusters.</p>
    pub fn rebalancing(&self) -> ::std::option::Option<&crate::types::Rebalancing> {
        self.rebalancing.as_ref()
    }
    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
    pub fn current_broker_software_info(&self) -> ::std::option::Option<&crate::types::BrokerSoftwareInfo> {
        self.current_broker_software_info.as_ref()
    }
    /// <p>Includes all client authentication information.</p>
    pub fn client_authentication(&self) -> ::std::option::Option<&crate::types::ClientAuthentication> {
        self.client_authentication.as_ref()
    }
    /// <p>Includes all encryption-related information.</p>
    pub fn encryption_info(&self) -> ::std::option::Option<&crate::types::EncryptionInfo> {
        self.encryption_info.as_ref()
    }
    /// <p>Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.</p>
    pub fn enhanced_monitoring(&self) -> ::std::option::Option<&crate::types::EnhancedMonitoring> {
        self.enhanced_monitoring.as_ref()
    }
    /// <p>The settings for open monitoring.</p>
    pub fn open_monitoring(&self) -> ::std::option::Option<&crate::types::OpenMonitoringInfo> {
        self.open_monitoring.as_ref()
    }
    /// <p>Log delivery information for the cluster.</p>
    pub fn logging_info(&self) -> ::std::option::Option<&crate::types::LoggingInfo> {
        self.logging_info.as_ref()
    }
    /// <p>The number of broker nodes in the cluster.</p>
    pub fn number_of_broker_nodes(&self) -> ::std::option::Option<i32> {
        self.number_of_broker_nodes
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
    pub fn zookeeper_connect_string(&self) -> ::std::option::Option<&str> {
        self.zookeeper_connect_string.as_deref()
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
    pub fn zookeeper_connect_string_tls(&self) -> ::std::option::Option<&str> {
        self.zookeeper_connect_string_tls.as_deref()
    }
    /// <p>This controls storage mode for supported storage tiers.</p>
    pub fn storage_mode(&self) -> ::std::option::Option<&crate::types::StorageMode> {
        self.storage_mode.as_ref()
    }
    /// <p>Determines if there is an action required from the customer.</p>
    pub fn customer_action_status(&self) -> ::std::option::Option<&crate::types::CustomerActionStatus> {
        self.customer_action_status.as_ref()
    }
}
impl Provisioned {
    /// Creates a new builder-style object to manufacture [`Provisioned`](crate::types::Provisioned).
    pub fn builder() -> crate::types::builders::ProvisionedBuilder {
        crate::types::builders::ProvisionedBuilder::default()
    }
}

/// A builder for [`Provisioned`](crate::types::Provisioned).
#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
#[non_exhaustive]
pub struct ProvisionedBuilder {
    pub(crate) broker_node_group_info: ::std::option::Option<crate::types::BrokerNodeGroupInfo>,
    pub(crate) rebalancing: ::std::option::Option<crate::types::Rebalancing>,
    pub(crate) current_broker_software_info: ::std::option::Option<crate::types::BrokerSoftwareInfo>,
    pub(crate) client_authentication: ::std::option::Option<crate::types::ClientAuthentication>,
    pub(crate) encryption_info: ::std::option::Option<crate::types::EncryptionInfo>,
    pub(crate) enhanced_monitoring: ::std::option::Option<crate::types::EnhancedMonitoring>,
    pub(crate) open_monitoring: ::std::option::Option<crate::types::OpenMonitoringInfo>,
    pub(crate) logging_info: ::std::option::Option<crate::types::LoggingInfo>,
    pub(crate) number_of_broker_nodes: ::std::option::Option<i32>,
    pub(crate) zookeeper_connect_string: ::std::option::Option<::std::string::String>,
    pub(crate) zookeeper_connect_string_tls: ::std::option::Option<::std::string::String>,
    pub(crate) storage_mode: ::std::option::Option<crate::types::StorageMode>,
    pub(crate) customer_action_status: ::std::option::Option<crate::types::CustomerActionStatus>,
}
impl ProvisionedBuilder {
    /// <p>Information about the brokers.</p>
    /// This field is required.
    pub fn broker_node_group_info(mut self, input: crate::types::BrokerNodeGroupInfo) -> Self {
        self.broker_node_group_info = ::std::option::Option::Some(input);
        self
    }
    /// <p>Information about the brokers.</p>
    pub fn set_broker_node_group_info(mut self, input: ::std::option::Option<crate::types::BrokerNodeGroupInfo>) -> Self {
        self.broker_node_group_info = input;
        self
    }
    /// <p>Information about the brokers.</p>
    pub fn get_broker_node_group_info(&self) -> &::std::option::Option<crate::types::BrokerNodeGroupInfo> {
        &self.broker_node_group_info
    }
    /// <p>Specifies whether or not intelligent rebalancing is turned on for a newly created MSK Provisioned cluster with Express brokers. Intelligent rebalancing performs automatic partition balancing operations when you scale your clusters up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based clusters.</p>
    pub fn rebalancing(mut self, input: crate::types::Rebalancing) -> Self {
        self.rebalancing = ::std::option::Option::Some(input);
        self
    }
    /// <p>Specifies whether or not intelligent rebalancing is turned on for a newly created MSK Provisioned cluster with Express brokers. Intelligent rebalancing performs automatic partition balancing operations when you scale your clusters up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based clusters.</p>
    pub fn set_rebalancing(mut self, input: ::std::option::Option<crate::types::Rebalancing>) -> Self {
        self.rebalancing = input;
        self
    }
    /// <p>Specifies whether or not intelligent rebalancing is turned on for a newly created MSK Provisioned cluster with Express brokers. Intelligent rebalancing performs automatic partition balancing operations when you scale your clusters up or down. By default, intelligent rebalancing is ACTIVE for all new Express-based clusters.</p>
    pub fn get_rebalancing(&self) -> &::std::option::Option<crate::types::Rebalancing> {
        &self.rebalancing
    }
    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
    pub fn current_broker_software_info(mut self, input: crate::types::BrokerSoftwareInfo) -> Self {
        self.current_broker_software_info = ::std::option::Option::Some(input);
        self
    }
    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
    pub fn set_current_broker_software_info(mut self, input: ::std::option::Option<crate::types::BrokerSoftwareInfo>) -> Self {
        self.current_broker_software_info = input;
        self
    }
    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
    pub fn get_current_broker_software_info(&self) -> &::std::option::Option<crate::types::BrokerSoftwareInfo> {
        &self.current_broker_software_info
    }
    /// <p>Includes all client authentication information.</p>
    pub fn client_authentication(mut self, input: crate::types::ClientAuthentication) -> Self {
        self.client_authentication = ::std::option::Option::Some(input);
        self
    }
    /// <p>Includes all client authentication information.</p>
    pub fn set_client_authentication(mut self, input: ::std::option::Option<crate::types::ClientAuthentication>) -> Self {
        self.client_authentication = input;
        self
    }
    /// <p>Includes all client authentication information.</p>
    pub fn get_client_authentication(&self) -> &::std::option::Option<crate::types::ClientAuthentication> {
        &self.client_authentication
    }
    /// <p>Includes all encryption-related information.</p>
    pub fn encryption_info(mut self, input: crate::types::EncryptionInfo) -> Self {
        self.encryption_info = ::std::option::Option::Some(input);
        self
    }
    /// <p>Includes all encryption-related information.</p>
    pub fn set_encryption_info(mut self, input: ::std::option::Option<crate::types::EncryptionInfo>) -> Self {
        self.encryption_info = input;
        self
    }
    /// <p>Includes all encryption-related information.</p>
    pub fn get_encryption_info(&self) -> &::std::option::Option<crate::types::EncryptionInfo> {
        &self.encryption_info
    }
    /// <p>Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.</p>
    pub fn enhanced_monitoring(mut self, input: crate::types::EnhancedMonitoring) -> Self {
        self.enhanced_monitoring = ::std::option::Option::Some(input);
        self
    }
    /// <p>Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.</p>
    pub fn set_enhanced_monitoring(mut self, input: ::std::option::Option<crate::types::EnhancedMonitoring>) -> Self {
        self.enhanced_monitoring = input;
        self
    }
    /// <p>Specifies the level of monitoring for the MSK cluster. The possible values are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.</p>
    pub fn get_enhanced_monitoring(&self) -> &::std::option::Option<crate::types::EnhancedMonitoring> {
        &self.enhanced_monitoring
    }
    /// <p>The settings for open monitoring.</p>
    pub fn open_monitoring(mut self, input: crate::types::OpenMonitoringInfo) -> Self {
        self.open_monitoring = ::std::option::Option::Some(input);
        self
    }
    /// <p>The settings for open monitoring.</p>
    pub fn set_open_monitoring(mut self, input: ::std::option::Option<crate::types::OpenMonitoringInfo>) -> Self {
        self.open_monitoring = input;
        self
    }
    /// <p>The settings for open monitoring.</p>
    pub fn get_open_monitoring(&self) -> &::std::option::Option<crate::types::OpenMonitoringInfo> {
        &self.open_monitoring
    }
    /// <p>Log delivery information for the cluster.</p>
    pub fn logging_info(mut self, input: crate::types::LoggingInfo) -> Self {
        self.logging_info = ::std::option::Option::Some(input);
        self
    }
    /// <p>Log delivery information for the cluster.</p>
    pub fn set_logging_info(mut self, input: ::std::option::Option<crate::types::LoggingInfo>) -> Self {
        self.logging_info = input;
        self
    }
    /// <p>Log delivery information for the cluster.</p>
    pub fn get_logging_info(&self) -> &::std::option::Option<crate::types::LoggingInfo> {
        &self.logging_info
    }
    /// <p>The number of broker nodes in the cluster.</p>
    /// This field is required.
    pub fn number_of_broker_nodes(mut self, input: i32) -> Self {
        self.number_of_broker_nodes = ::std::option::Option::Some(input);
        self
    }
    /// <p>The number of broker nodes in the cluster.</p>
    pub fn set_number_of_broker_nodes(mut self, input: ::std::option::Option<i32>) -> Self {
        self.number_of_broker_nodes = input;
        self
    }
    /// <p>The number of broker nodes in the cluster.</p>
    pub fn get_number_of_broker_nodes(&self) -> &::std::option::Option<i32> {
        &self.number_of_broker_nodes
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
    pub fn zookeeper_connect_string(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.zookeeper_connect_string = ::std::option::Option::Some(input.into());
        self
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
    pub fn set_zookeeper_connect_string(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.zookeeper_connect_string = input;
        self
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
    pub fn get_zookeeper_connect_string(&self) -> &::std::option::Option<::std::string::String> {
        &self.zookeeper_connect_string
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
    pub fn zookeeper_connect_string_tls(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
        self.zookeeper_connect_string_tls = ::std::option::Option::Some(input.into());
        self
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
    pub fn set_zookeeper_connect_string_tls(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
        self.zookeeper_connect_string_tls = input;
        self
    }
    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
    pub fn get_zookeeper_connect_string_tls(&self) -> &::std::option::Option<::std::string::String> {
        &self.zookeeper_connect_string_tls
    }
    /// <p>This controls storage mode for supported storage tiers.</p>
    pub fn storage_mode(mut self, input: crate::types::StorageMode) -> Self {
        self.storage_mode = ::std::option::Option::Some(input);
        self
    }
    /// <p>This controls storage mode for supported storage tiers.</p>
    pub fn set_storage_mode(mut self, input: ::std::option::Option<crate::types::StorageMode>) -> Self {
        self.storage_mode = input;
        self
    }
    /// <p>This controls storage mode for supported storage tiers.</p>
    pub fn get_storage_mode(&self) -> &::std::option::Option<crate::types::StorageMode> {
        &self.storage_mode
    }
    /// <p>Determines if there is an action required from the customer.</p>
    pub fn customer_action_status(mut self, input: crate::types::CustomerActionStatus) -> Self {
        self.customer_action_status = ::std::option::Option::Some(input);
        self
    }
    /// <p>Determines if there is an action required from the customer.</p>
    pub fn set_customer_action_status(mut self, input: ::std::option::Option<crate::types::CustomerActionStatus>) -> Self {
        self.customer_action_status = input;
        self
    }
    /// <p>Determines if there is an action required from the customer.</p>
    pub fn get_customer_action_status(&self) -> &::std::option::Option<crate::types::CustomerActionStatus> {
        &self.customer_action_status
    }
    /// Consumes the builder and constructs a [`Provisioned`](crate::types::Provisioned).
    pub fn build(self) -> crate::types::Provisioned {
        crate::types::Provisioned {
            broker_node_group_info: self.broker_node_group_info,
            rebalancing: self.rebalancing,
            current_broker_software_info: self.current_broker_software_info,
            client_authentication: self.client_authentication,
            encryption_info: self.encryption_info,
            enhanced_monitoring: self.enhanced_monitoring,
            open_monitoring: self.open_monitoring,
            logging_info: self.logging_info,
            number_of_broker_nodes: self.number_of_broker_nodes,
            zookeeper_connect_string: self.zookeeper_connect_string,
            zookeeper_connect_string_tls: self.zookeeper_connect_string_tls,
            storage_mode: self.storage_mode,
            customer_action_status: self.customer_action_status,
        }
    }
}