aws_sdk_kafka/types/
_provisioned.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2
3/// <p>Provisioned cluster.</p>
4#[non_exhaustive]
5#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
6pub struct Provisioned {
7    /// <p>Information about the brokers.</p>
8    pub broker_node_group_info: ::std::option::Option<crate::types::BrokerNodeGroupInfo>,
9    /// <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>
10    pub rebalancing: ::std::option::Option<crate::types::Rebalancing>,
11    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
12    pub current_broker_software_info: ::std::option::Option<crate::types::BrokerSoftwareInfo>,
13    /// <p>Includes all client authentication information.</p>
14    pub client_authentication: ::std::option::Option<crate::types::ClientAuthentication>,
15    /// <p>Includes all encryption-related information.</p>
16    pub encryption_info: ::std::option::Option<crate::types::EncryptionInfo>,
17    /// <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>
18    pub enhanced_monitoring: ::std::option::Option<crate::types::EnhancedMonitoring>,
19    /// <p>The settings for open monitoring.</p>
20    pub open_monitoring: ::std::option::Option<crate::types::OpenMonitoringInfo>,
21    /// <p>Log delivery information for the cluster.</p>
22    pub logging_info: ::std::option::Option<crate::types::LoggingInfo>,
23    /// <p>The number of broker nodes in the cluster.</p>
24    pub number_of_broker_nodes: ::std::option::Option<i32>,
25    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
26    pub zookeeper_connect_string: ::std::option::Option<::std::string::String>,
27    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
28    pub zookeeper_connect_string_tls: ::std::option::Option<::std::string::String>,
29    /// <p>This controls storage mode for supported storage tiers.</p>
30    pub storage_mode: ::std::option::Option<crate::types::StorageMode>,
31    /// <p>Determines if there is an action required from the customer.</p>
32    pub customer_action_status: ::std::option::Option<crate::types::CustomerActionStatus>,
33}
34impl Provisioned {
35    /// <p>Information about the brokers.</p>
36    pub fn broker_node_group_info(&self) -> ::std::option::Option<&crate::types::BrokerNodeGroupInfo> {
37        self.broker_node_group_info.as_ref()
38    }
39    /// <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>
40    pub fn rebalancing(&self) -> ::std::option::Option<&crate::types::Rebalancing> {
41        self.rebalancing.as_ref()
42    }
43    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
44    pub fn current_broker_software_info(&self) -> ::std::option::Option<&crate::types::BrokerSoftwareInfo> {
45        self.current_broker_software_info.as_ref()
46    }
47    /// <p>Includes all client authentication information.</p>
48    pub fn client_authentication(&self) -> ::std::option::Option<&crate::types::ClientAuthentication> {
49        self.client_authentication.as_ref()
50    }
51    /// <p>Includes all encryption-related information.</p>
52    pub fn encryption_info(&self) -> ::std::option::Option<&crate::types::EncryptionInfo> {
53        self.encryption_info.as_ref()
54    }
55    /// <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>
56    pub fn enhanced_monitoring(&self) -> ::std::option::Option<&crate::types::EnhancedMonitoring> {
57        self.enhanced_monitoring.as_ref()
58    }
59    /// <p>The settings for open monitoring.</p>
60    pub fn open_monitoring(&self) -> ::std::option::Option<&crate::types::OpenMonitoringInfo> {
61        self.open_monitoring.as_ref()
62    }
63    /// <p>Log delivery information for the cluster.</p>
64    pub fn logging_info(&self) -> ::std::option::Option<&crate::types::LoggingInfo> {
65        self.logging_info.as_ref()
66    }
67    /// <p>The number of broker nodes in the cluster.</p>
68    pub fn number_of_broker_nodes(&self) -> ::std::option::Option<i32> {
69        self.number_of_broker_nodes
70    }
71    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
72    pub fn zookeeper_connect_string(&self) -> ::std::option::Option<&str> {
73        self.zookeeper_connect_string.as_deref()
74    }
75    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
76    pub fn zookeeper_connect_string_tls(&self) -> ::std::option::Option<&str> {
77        self.zookeeper_connect_string_tls.as_deref()
78    }
79    /// <p>This controls storage mode for supported storage tiers.</p>
80    pub fn storage_mode(&self) -> ::std::option::Option<&crate::types::StorageMode> {
81        self.storage_mode.as_ref()
82    }
83    /// <p>Determines if there is an action required from the customer.</p>
84    pub fn customer_action_status(&self) -> ::std::option::Option<&crate::types::CustomerActionStatus> {
85        self.customer_action_status.as_ref()
86    }
87}
88impl Provisioned {
89    /// Creates a new builder-style object to manufacture [`Provisioned`](crate::types::Provisioned).
90    pub fn builder() -> crate::types::builders::ProvisionedBuilder {
91        crate::types::builders::ProvisionedBuilder::default()
92    }
93}
94
95/// A builder for [`Provisioned`](crate::types::Provisioned).
96#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
97#[non_exhaustive]
98pub struct ProvisionedBuilder {
99    pub(crate) broker_node_group_info: ::std::option::Option<crate::types::BrokerNodeGroupInfo>,
100    pub(crate) rebalancing: ::std::option::Option<crate::types::Rebalancing>,
101    pub(crate) current_broker_software_info: ::std::option::Option<crate::types::BrokerSoftwareInfo>,
102    pub(crate) client_authentication: ::std::option::Option<crate::types::ClientAuthentication>,
103    pub(crate) encryption_info: ::std::option::Option<crate::types::EncryptionInfo>,
104    pub(crate) enhanced_monitoring: ::std::option::Option<crate::types::EnhancedMonitoring>,
105    pub(crate) open_monitoring: ::std::option::Option<crate::types::OpenMonitoringInfo>,
106    pub(crate) logging_info: ::std::option::Option<crate::types::LoggingInfo>,
107    pub(crate) number_of_broker_nodes: ::std::option::Option<i32>,
108    pub(crate) zookeeper_connect_string: ::std::option::Option<::std::string::String>,
109    pub(crate) zookeeper_connect_string_tls: ::std::option::Option<::std::string::String>,
110    pub(crate) storage_mode: ::std::option::Option<crate::types::StorageMode>,
111    pub(crate) customer_action_status: ::std::option::Option<crate::types::CustomerActionStatus>,
112}
113impl ProvisionedBuilder {
114    /// <p>Information about the brokers.</p>
115    /// This field is required.
116    pub fn broker_node_group_info(mut self, input: crate::types::BrokerNodeGroupInfo) -> Self {
117        self.broker_node_group_info = ::std::option::Option::Some(input);
118        self
119    }
120    /// <p>Information about the brokers.</p>
121    pub fn set_broker_node_group_info(mut self, input: ::std::option::Option<crate::types::BrokerNodeGroupInfo>) -> Self {
122        self.broker_node_group_info = input;
123        self
124    }
125    /// <p>Information about the brokers.</p>
126    pub fn get_broker_node_group_info(&self) -> &::std::option::Option<crate::types::BrokerNodeGroupInfo> {
127        &self.broker_node_group_info
128    }
129    /// <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>
130    pub fn rebalancing(mut self, input: crate::types::Rebalancing) -> Self {
131        self.rebalancing = ::std::option::Option::Some(input);
132        self
133    }
134    /// <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>
135    pub fn set_rebalancing(mut self, input: ::std::option::Option<crate::types::Rebalancing>) -> Self {
136        self.rebalancing = input;
137        self
138    }
139    /// <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>
140    pub fn get_rebalancing(&self) -> &::std::option::Option<crate::types::Rebalancing> {
141        &self.rebalancing
142    }
143    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
144    pub fn current_broker_software_info(mut self, input: crate::types::BrokerSoftwareInfo) -> Self {
145        self.current_broker_software_info = ::std::option::Option::Some(input);
146        self
147    }
148    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
149    pub fn set_current_broker_software_info(mut self, input: ::std::option::Option<crate::types::BrokerSoftwareInfo>) -> Self {
150        self.current_broker_software_info = input;
151        self
152    }
153    /// <p>Information about the Apache Kafka version deployed on the brokers.</p>
154    pub fn get_current_broker_software_info(&self) -> &::std::option::Option<crate::types::BrokerSoftwareInfo> {
155        &self.current_broker_software_info
156    }
157    /// <p>Includes all client authentication information.</p>
158    pub fn client_authentication(mut self, input: crate::types::ClientAuthentication) -> Self {
159        self.client_authentication = ::std::option::Option::Some(input);
160        self
161    }
162    /// <p>Includes all client authentication information.</p>
163    pub fn set_client_authentication(mut self, input: ::std::option::Option<crate::types::ClientAuthentication>) -> Self {
164        self.client_authentication = input;
165        self
166    }
167    /// <p>Includes all client authentication information.</p>
168    pub fn get_client_authentication(&self) -> &::std::option::Option<crate::types::ClientAuthentication> {
169        &self.client_authentication
170    }
171    /// <p>Includes all encryption-related information.</p>
172    pub fn encryption_info(mut self, input: crate::types::EncryptionInfo) -> Self {
173        self.encryption_info = ::std::option::Option::Some(input);
174        self
175    }
176    /// <p>Includes all encryption-related information.</p>
177    pub fn set_encryption_info(mut self, input: ::std::option::Option<crate::types::EncryptionInfo>) -> Self {
178        self.encryption_info = input;
179        self
180    }
181    /// <p>Includes all encryption-related information.</p>
182    pub fn get_encryption_info(&self) -> &::std::option::Option<crate::types::EncryptionInfo> {
183        &self.encryption_info
184    }
185    /// <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>
186    pub fn enhanced_monitoring(mut self, input: crate::types::EnhancedMonitoring) -> Self {
187        self.enhanced_monitoring = ::std::option::Option::Some(input);
188        self
189    }
190    /// <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>
191    pub fn set_enhanced_monitoring(mut self, input: ::std::option::Option<crate::types::EnhancedMonitoring>) -> Self {
192        self.enhanced_monitoring = input;
193        self
194    }
195    /// <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>
196    pub fn get_enhanced_monitoring(&self) -> &::std::option::Option<crate::types::EnhancedMonitoring> {
197        &self.enhanced_monitoring
198    }
199    /// <p>The settings for open monitoring.</p>
200    pub fn open_monitoring(mut self, input: crate::types::OpenMonitoringInfo) -> Self {
201        self.open_monitoring = ::std::option::Option::Some(input);
202        self
203    }
204    /// <p>The settings for open monitoring.</p>
205    pub fn set_open_monitoring(mut self, input: ::std::option::Option<crate::types::OpenMonitoringInfo>) -> Self {
206        self.open_monitoring = input;
207        self
208    }
209    /// <p>The settings for open monitoring.</p>
210    pub fn get_open_monitoring(&self) -> &::std::option::Option<crate::types::OpenMonitoringInfo> {
211        &self.open_monitoring
212    }
213    /// <p>Log delivery information for the cluster.</p>
214    pub fn logging_info(mut self, input: crate::types::LoggingInfo) -> Self {
215        self.logging_info = ::std::option::Option::Some(input);
216        self
217    }
218    /// <p>Log delivery information for the cluster.</p>
219    pub fn set_logging_info(mut self, input: ::std::option::Option<crate::types::LoggingInfo>) -> Self {
220        self.logging_info = input;
221        self
222    }
223    /// <p>Log delivery information for the cluster.</p>
224    pub fn get_logging_info(&self) -> &::std::option::Option<crate::types::LoggingInfo> {
225        &self.logging_info
226    }
227    /// <p>The number of broker nodes in the cluster.</p>
228    /// This field is required.
229    pub fn number_of_broker_nodes(mut self, input: i32) -> Self {
230        self.number_of_broker_nodes = ::std::option::Option::Some(input);
231        self
232    }
233    /// <p>The number of broker nodes in the cluster.</p>
234    pub fn set_number_of_broker_nodes(mut self, input: ::std::option::Option<i32>) -> Self {
235        self.number_of_broker_nodes = input;
236        self
237    }
238    /// <p>The number of broker nodes in the cluster.</p>
239    pub fn get_number_of_broker_nodes(&self) -> &::std::option::Option<i32> {
240        &self.number_of_broker_nodes
241    }
242    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
243    pub fn zookeeper_connect_string(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
244        self.zookeeper_connect_string = ::std::option::Option::Some(input.into());
245        self
246    }
247    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
248    pub fn set_zookeeper_connect_string(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
249        self.zookeeper_connect_string = input;
250        self
251    }
252    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster.</p>
253    pub fn get_zookeeper_connect_string(&self) -> &::std::option::Option<::std::string::String> {
254        &self.zookeeper_connect_string
255    }
256    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
257    pub fn zookeeper_connect_string_tls(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
258        self.zookeeper_connect_string_tls = ::std::option::Option::Some(input.into());
259        self
260    }
261    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
262    pub fn set_zookeeper_connect_string_tls(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
263        self.zookeeper_connect_string_tls = input;
264        self
265    }
266    /// <p>The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.</p>
267    pub fn get_zookeeper_connect_string_tls(&self) -> &::std::option::Option<::std::string::String> {
268        &self.zookeeper_connect_string_tls
269    }
270    /// <p>This controls storage mode for supported storage tiers.</p>
271    pub fn storage_mode(mut self, input: crate::types::StorageMode) -> Self {
272        self.storage_mode = ::std::option::Option::Some(input);
273        self
274    }
275    /// <p>This controls storage mode for supported storage tiers.</p>
276    pub fn set_storage_mode(mut self, input: ::std::option::Option<crate::types::StorageMode>) -> Self {
277        self.storage_mode = input;
278        self
279    }
280    /// <p>This controls storage mode for supported storage tiers.</p>
281    pub fn get_storage_mode(&self) -> &::std::option::Option<crate::types::StorageMode> {
282        &self.storage_mode
283    }
284    /// <p>Determines if there is an action required from the customer.</p>
285    pub fn customer_action_status(mut self, input: crate::types::CustomerActionStatus) -> Self {
286        self.customer_action_status = ::std::option::Option::Some(input);
287        self
288    }
289    /// <p>Determines if there is an action required from the customer.</p>
290    pub fn set_customer_action_status(mut self, input: ::std::option::Option<crate::types::CustomerActionStatus>) -> Self {
291        self.customer_action_status = input;
292        self
293    }
294    /// <p>Determines if there is an action required from the customer.</p>
295    pub fn get_customer_action_status(&self) -> &::std::option::Option<crate::types::CustomerActionStatus> {
296        &self.customer_action_status
297    }
298    /// Consumes the builder and constructs a [`Provisioned`](crate::types::Provisioned).
299    pub fn build(self) -> crate::types::Provisioned {
300        crate::types::Provisioned {
301            broker_node_group_info: self.broker_node_group_info,
302            rebalancing: self.rebalancing,
303            current_broker_software_info: self.current_broker_software_info,
304            client_authentication: self.client_authentication,
305            encryption_info: self.encryption_info,
306            enhanced_monitoring: self.enhanced_monitoring,
307            open_monitoring: self.open_monitoring,
308            logging_info: self.logging_info,
309            number_of_broker_nodes: self.number_of_broker_nodes,
310            zookeeper_connect_string: self.zookeeper_connect_string,
311            zookeeper_connect_string_tls: self.zookeeper_connect_string_tls,
312            storage_mode: self.storage_mode,
313            customer_action_status: self.customer_action_status,
314        }
315    }
316}
aws_sdk_kafka/types/_provisioned.rs

aws_sdk_kafka/types/
_provisioned.rs
