Struct aws_sdk_kafka::model::provisioned::Builder

source ·

pub struct Builder { /* private fields */ }

Expand description

The connection string to use to connect to the Apache ZooKeeper cluster on a TLS port.

Examples found in repository ?

src/json_deser.rs (lines 4358-4364)

pub(crate) fn deser_structure_crate_model_provisioned<'a, I>(
    tokens: &mut std::iter::Peekable<I>,
) -> Result<Option<crate::model::Provisioned>, aws_smithy_json::deserialize::error::DeserializeError>
where
    I: Iterator<
        Item = Result<
            aws_smithy_json::deserialize::Token<'a>,
            aws_smithy_json::deserialize::error::DeserializeError,
        >,
    >,
{
    match tokens.next().transpose()? {
        Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
        Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
            #[allow(unused_mut)]
            let mut builder = crate::model::provisioned::Builder::default();
            loop {
                match tokens.next().transpose()? {
                    Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                    Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                        match key.to_unescaped()?.as_ref() {
                            "brokerNodeGroupInfo" => {
                                builder = builder.set_broker_node_group_info(
                                    crate::json_deser::deser_structure_crate_model_broker_node_group_info(tokens)?
                                );
                            }
                            "currentBrokerSoftwareInfo" => {
                                builder = builder.set_current_broker_software_info(
                                    crate::json_deser::deser_structure_crate_model_broker_software_info(tokens)?
                                );
                            }
                            "clientAuthentication" => {
                                builder = builder.set_client_authentication(
                                    crate::json_deser::deser_structure_crate_model_client_authentication(tokens)?
                                );
                            }
                            "encryptionInfo" => {
                                builder = builder.set_encryption_info(
                                    crate::json_deser::deser_structure_crate_model_encryption_info(
                                        tokens,
                                    )?,
                                );
                            }
                            "enhancedMonitoring" => {
                                builder = builder.set_enhanced_monitoring(
                                    aws_smithy_json::deserialize::token::expect_string_or_null(
                                        tokens.next(),
                                    )?
                                    .map(|s| {
                                        s.to_unescaped().map(|u| {
                                            crate::model::EnhancedMonitoring::from(u.as_ref())
                                        })
                                    })
                                    .transpose()?,
                                );
                            }
                            "openMonitoring" => {
                                builder = builder.set_open_monitoring(
                                    crate::json_deser::deser_structure_crate_model_open_monitoring_info(tokens)?
                                );
                            }
                            "loggingInfo" => {
                                builder = builder.set_logging_info(
                                    crate::json_deser::deser_structure_crate_model_logging_info(
                                        tokens,
                                    )?,
                                );
                            }
                            "numberOfBrokerNodes" => {
                                builder = builder.set_number_of_broker_nodes(
                                    aws_smithy_json::deserialize::token::expect_number_or_null(
                                        tokens.next(),
                                    )?
                                    .map(i32::try_from)
                                    .transpose()?,
                                );
                            }
                            "zookeeperConnectString" => {
                                builder = builder.set_zookeeper_connect_string(
                                    aws_smithy_json::deserialize::token::expect_string_or_null(
                                        tokens.next(),
                                    )?
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                    .transpose()?,
                                );
                            }
                            "zookeeperConnectStringTls" => {
                                builder = builder.set_zookeeper_connect_string_tls(
                                    aws_smithy_json::deserialize::token::expect_string_or_null(
                                        tokens.next(),
                                    )?
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                    .transpose()?,
                                );
                            }
                            _ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
                        }
                    }
                    other => {
                        return Err(
                            aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                                "expected object key or end object, found: {:?}",
                                other
                            )),
                        )
                    }
                }
            }
            Ok(Some(builder.build()))
        }
        _ => Err(
            aws_smithy_json::deserialize::error::DeserializeError::custom(
                "expected start object or null",
            ),
        ),
    }
}

source

pub fn build(self) -> Provisioned

Consumes the builder and constructs a Provisioned.

Examples found in repository ?

src/json_deser.rs (line 4379)

pub(crate) fn deser_structure_crate_model_provisioned<'a, I>(
    tokens: &mut std::iter::Peekable<I>,
) -> Result<Option<crate::model::Provisioned>, aws_smithy_json::deserialize::error::DeserializeError>
where
    I: Iterator<
        Item = Result<
            aws_smithy_json::deserialize::Token<'a>,
            aws_smithy_json::deserialize::error::DeserializeError,
        >,
    >,
{
    match tokens.next().transpose()? {
        Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
        Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
            #[allow(unused_mut)]
            let mut builder = crate::model::provisioned::Builder::default();
            loop {
                match tokens.next().transpose()? {
                    Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
                    Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
                        match key.to_unescaped()?.as_ref() {
                            "brokerNodeGroupInfo" => {
                                builder = builder.set_broker_node_group_info(
                                    crate::json_deser::deser_structure_crate_model_broker_node_group_info(tokens)?
                                );
                            }
                            "currentBrokerSoftwareInfo" => {
                                builder = builder.set_current_broker_software_info(
                                    crate::json_deser::deser_structure_crate_model_broker_software_info(tokens)?
                                );
                            }
                            "clientAuthentication" => {
                                builder = builder.set_client_authentication(
                                    crate::json_deser::deser_structure_crate_model_client_authentication(tokens)?
                                );
                            }
                            "encryptionInfo" => {
                                builder = builder.set_encryption_info(
                                    crate::json_deser::deser_structure_crate_model_encryption_info(
                                        tokens,
                                    )?,
                                );
                            }
                            "enhancedMonitoring" => {
                                builder = builder.set_enhanced_monitoring(
                                    aws_smithy_json::deserialize::token::expect_string_or_null(
                                        tokens.next(),
                                    )?
                                    .map(|s| {
                                        s.to_unescaped().map(|u| {
                                            crate::model::EnhancedMonitoring::from(u.as_ref())
                                        })
                                    })
                                    .transpose()?,
                                );
                            }
                            "openMonitoring" => {
                                builder = builder.set_open_monitoring(
                                    crate::json_deser::deser_structure_crate_model_open_monitoring_info(tokens)?
                                );
                            }
                            "loggingInfo" => {
                                builder = builder.set_logging_info(
                                    crate::json_deser::deser_structure_crate_model_logging_info(
                                        tokens,
                                    )?,
                                );
                            }
                            "numberOfBrokerNodes" => {
                                builder = builder.set_number_of_broker_nodes(
                                    aws_smithy_json::deserialize::token::expect_number_or_null(
                                        tokens.next(),
                                    )?
                                    .map(i32::try_from)
                                    .transpose()?,
                                );
                            }
                            "zookeeperConnectString" => {
                                builder = builder.set_zookeeper_connect_string(
                                    aws_smithy_json::deserialize::token::expect_string_or_null(
                                        tokens.next(),
                                    )?
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                    .transpose()?,
                                );
                            }
                            "zookeeperConnectStringTls" => {
                                builder = builder.set_zookeeper_connect_string_tls(
                                    aws_smithy_json::deserialize::token::expect_string_or_null(
                                        tokens.next(),
                                    )?
                                    .map(|s| s.to_unescaped().map(|u| u.into_owned()))
                                    .transpose()?,
                                );
                            }
                            _ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
                        }
                    }
                    other => {
                        return Err(
                            aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
                                "expected object key or end object, found: {:?}",
                                other
                            )),
                        )
                    }
                }
            }
            Ok(Some(builder.build()))
        }
        _ => Err(
            aws_smithy_json::deserialize::error::DeserializeError::custom(
                "expected start object or null",
            ),
        ),
    }
}

Trait Implementations§

source §

impl Clone for Builder

source §

fn clone(&self) -> Builder

Returns a copy of the value. Read more

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason. Read more

source §

impl StructuralPartialEq for Builder

impl<T> ToOwned for Twhere
T: Clone,

§

type Owned = T

impl<T> WithSubscriber for T

source §

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source §

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct aws_sdk_kafka::model::provisioned::Builder

Implementations§

impl Builder

pub fn broker_node_group_info(self, input: BrokerNodeGroupInfo) -> Self

pub fn set_broker_node_group_info( self, input: Option<BrokerNodeGroupInfo>) -> Self

pub fn current_broker_software_info(self, input: BrokerSoftwareInfo) -> Self

pub fn set_current_broker_software_info( self, input: Option<BrokerSoftwareInfo>) -> Self

pub fn client_authentication(self, input: ClientAuthentication) -> Self

pub fn set_client_authentication( self, input: Option<ClientAuthentication>) -> Self

pub fn encryption_info(self, input: EncryptionInfo) -> Self

pub fn set_encryption_info(self, input: Option<EncryptionInfo>) -> Self

pub fn enhanced_monitoring(self, input: EnhancedMonitoring) -> Self

pub fn set_enhanced_monitoring(self, input: Option<EnhancedMonitoring>) -> Self

pub fn open_monitoring(self, input: OpenMonitoringInfo) -> Self

pub fn set_open_monitoring(self, input: Option<OpenMonitoringInfo>) -> Self

pub fn logging_info(self, input: LoggingInfo) -> Self

pub fn set_logging_info(self, input: Option<LoggingInfo>) -> Self

pub fn number_of_broker_nodes(self, input: i32) -> Self

pub fn set_number_of_broker_nodes(self, input: Option<i32>) -> Self

pub fn zookeeper_connect_string(self, input: impl Into<String>) -> Self

pub fn set_zookeeper_connect_string(self, input: Option<String>) -> Self

pub fn zookeeper_connect_string_tls(self, input: impl Into<String>) -> Self

pub fn set_zookeeper_connect_string_tls(self, input: Option<String>) -> Self

pub fn build(self) -> Provisioned

Trait Implementations§

impl Clone for Builder

fn clone(&self) -> Builder

fn clone_from(&mut self, source: &Self)

impl Debug for Builder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl Default for Builder

fn default() -> Builder

impl PartialEq<Builder> for Builder

fn eq(&self, other: &Builder) -> bool

fn ne(&self, other: &Rhs) -> bool

impl StructuralPartialEq for Builder

Auto Trait Implementations§

impl RefUnwindSafe for Builder

impl Send for Builder

impl Sync for Builder

impl Unpin for Builder

impl UnwindSafe for Builder

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Same<T> for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

pub fn set_broker_node_group_info(
self,
input: Option<BrokerNodeGroupInfo>
) -> Self

pub fn set_current_broker_software_info(
self,
input: Option<BrokerSoftwareInfo>
) -> Self

pub fn set_client_authentication(
self,
input: Option<ClientAuthentication>
) -> Self

impl<T> Any for Twhere
T: 'static + ?Sized,

impl<T> Borrow<T> for Twhere
T: ?Sized,

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

impl<T, U> Into<U> for Twhere
U: From<T>,

impl<T> ToOwned for Twhere
T: Clone,

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,