aws_sdk_kafka/client/
create_cluster.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2impl super::Client {
3    /// Constructs a fluent builder for the [`CreateCluster`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder) operation.
4    ///
5    /// - The fluent builder is configurable:
6    ///   - [`broker_node_group_info(BrokerNodeGroupInfo)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::broker_node_group_info) / [`set_broker_node_group_info(Option<BrokerNodeGroupInfo>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_broker_node_group_info):<br>required: **true**<br><p>Information about the broker nodes in the cluster.</p><br>
7    ///   - [`client_authentication(ClientAuthentication)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::client_authentication) / [`set_client_authentication(Option<ClientAuthentication>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_client_authentication):<br>required: **false**<br><p>Includes all client authentication related information.</p><br>
8    ///   - [`cluster_name(impl Into<String>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::cluster_name) / [`set_cluster_name(Option<String>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_cluster_name):<br>required: **true**<br><p>The name of the cluster.</p><br>
9    ///   - [`configuration_info(ConfigurationInfo)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::configuration_info) / [`set_configuration_info(Option<ConfigurationInfo>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_configuration_info):<br>required: **false**<br><p>Represents the configuration that you want MSK to use for the brokers in a cluster.</p><br>
10    ///   - [`encryption_info(EncryptionInfo)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::encryption_info) / [`set_encryption_info(Option<EncryptionInfo>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_encryption_info):<br>required: **false**<br><p>Includes all encryption-related information.</p><br>
11    ///   - [`enhanced_monitoring(EnhancedMonitoring)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::enhanced_monitoring) / [`set_enhanced_monitoring(Option<EnhancedMonitoring>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_enhanced_monitoring):<br>required: **false**<br><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><br>
12    ///   - [`open_monitoring(OpenMonitoringInfo)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::open_monitoring) / [`set_open_monitoring(Option<OpenMonitoringInfo>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_open_monitoring):<br>required: **false**<br><p>The settings for open monitoring.</p><br>
13    ///   - [`kafka_version(impl Into<String>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::kafka_version) / [`set_kafka_version(Option<String>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_kafka_version):<br>required: **true**<br><p>The version of Apache Kafka.</p><br>
14    ///   - [`logging_info(LoggingInfo)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::logging_info) / [`set_logging_info(Option<LoggingInfo>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_logging_info):<br>required: **false**<br>(undocumented)<br>
15    ///   - [`number_of_broker_nodes(i32)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::number_of_broker_nodes) / [`set_number_of_broker_nodes(Option<i32>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_number_of_broker_nodes):<br>required: **true**<br><p>The number of broker nodes in the cluster.</p><br>
16    ///   - [`tags(impl Into<String>, impl Into<String>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::tags) / [`set_tags(Option<HashMap::<String, String>>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_tags):<br>required: **false**<br><p>Create tags when creating the cluster.</p><br>
17    ///   - [`storage_mode(StorageMode)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::storage_mode) / [`set_storage_mode(Option<StorageMode>)`](crate::operation::create_cluster::builders::CreateClusterFluentBuilder::set_storage_mode):<br>required: **false**<br><p>This controls storage mode for supported storage tiers.</p><br>
18    /// - On success, responds with [`CreateClusterOutput`](crate::operation::create_cluster::CreateClusterOutput) with field(s):
19    ///   - [`cluster_arn(Option<String>)`](crate::operation::create_cluster::CreateClusterOutput::cluster_arn): <p>The Amazon Resource Name (ARN) of the cluster.</p>
20    ///   - [`cluster_name(Option<String>)`](crate::operation::create_cluster::CreateClusterOutput::cluster_name): <p>The name of the MSK cluster.</p>
21    ///   - [`state(Option<ClusterState>)`](crate::operation::create_cluster::CreateClusterOutput::state): <p>The state of the cluster. The possible states are ACTIVE, CREATING, DELETING, FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.</p>
22    /// - On failure, responds with [`SdkError<CreateClusterError>`](crate::operation::create_cluster::CreateClusterError)
23    pub fn create_cluster(&self) -> crate::operation::create_cluster::builders::CreateClusterFluentBuilder {
24        crate::operation::create_cluster::builders::CreateClusterFluentBuilder::new(self.handle.clone())
25    }
26}
aws_sdk_kafka/client/create_cluster.rs

aws_sdk_kafka/client/
create_cluster.rs
