aws-sdk-kafka 1.126.0

AWS SDK for Managed Streaming for Kafka
Documentation
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
pub(crate) fn reflens_describe_topic_partitions_output_output_next_token(
    input: &crate::operation::describe_topic_partitions::DescribeTopicPartitionsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_client_vpc_connections_output_output_next_token(
    input: &crate::operation::list_client_vpc_connections::ListClientVpcConnectionsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_cluster_operations_output_output_next_token(
    input: &crate::operation::list_cluster_operations::ListClusterOperationsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_cluster_operations_v2_output_output_next_token(
    input: &crate::operation::list_cluster_operations_v2::ListClusterOperationsV2Output,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_clusters_output_output_next_token(
    input: &crate::operation::list_clusters::ListClustersOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_clusters_v2_output_output_next_token(
    input: &crate::operation::list_clusters_v2::ListClustersV2Output,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_configuration_revisions_output_output_next_token(
    input: &crate::operation::list_configuration_revisions::ListConfigurationRevisionsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_configurations_output_output_next_token(
    input: &crate::operation::list_configurations::ListConfigurationsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_kafka_versions_output_output_next_token(
    input: &crate::operation::list_kafka_versions::ListKafkaVersionsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_nodes_output_output_next_token(
    input: &crate::operation::list_nodes::ListNodesOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_replicators_output_output_next_token(
    input: &crate::operation::list_replicators::ListReplicatorsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_scram_secrets_output_output_next_token(
    input: &crate::operation::list_scram_secrets::ListScramSecretsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_topics_output_output_next_token(
    input: &crate::operation::list_topics::ListTopicsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn reflens_list_vpc_connections_output_output_next_token(
    input: &crate::operation::list_vpc_connections::ListVpcConnectionsOutput,
) -> ::std::option::Option<&::std::string::String> {
    let input = match &input.next_token {
        ::std::option::Option::None => return ::std::option::Option::None,
        ::std::option::Option::Some(t) => t,
    };
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_describe_topic_partitions_output_output_partitions(
    input: crate::operation::describe_topic_partitions::DescribeTopicPartitionsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::TopicPartitionInfo>> {
    let input = input.partitions?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_client_vpc_connections_output_output_client_vpc_connections(
    input: crate::operation::list_client_vpc_connections::ListClientVpcConnectionsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::ClientVpcConnection>> {
    let input = input.client_vpc_connections?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_cluster_operations_output_output_cluster_operation_info_list(
    input: crate::operation::list_cluster_operations::ListClusterOperationsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::ClusterOperationInfo>> {
    let input = input.cluster_operation_info_list?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_cluster_operations_v2_output_output_cluster_operation_info_list(
    input: crate::operation::list_cluster_operations_v2::ListClusterOperationsV2Output,
) -> ::std::option::Option<::std::vec::Vec<crate::types::ClusterOperationV2Summary>> {
    let input = input.cluster_operation_info_list?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_clusters_output_output_cluster_info_list(
    input: crate::operation::list_clusters::ListClustersOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::ClusterInfo>> {
    let input = input.cluster_info_list?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_clusters_v2_output_output_cluster_info_list(
    input: crate::operation::list_clusters_v2::ListClustersV2Output,
) -> ::std::option::Option<::std::vec::Vec<crate::types::Cluster>> {
    let input = input.cluster_info_list?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_configuration_revisions_output_output_revisions(
    input: crate::operation::list_configuration_revisions::ListConfigurationRevisionsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::ConfigurationRevision>> {
    let input = input.revisions?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_configurations_output_output_configurations(
    input: crate::operation::list_configurations::ListConfigurationsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::Configuration>> {
    let input = input.configurations?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_kafka_versions_output_output_kafka_versions(
    input: crate::operation::list_kafka_versions::ListKafkaVersionsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::KafkaVersion>> {
    let input = input.kafka_versions?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_nodes_output_output_node_info_list(
    input: crate::operation::list_nodes::ListNodesOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::NodeInfo>> {
    let input = input.node_info_list?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_replicators_output_output_replicators(
    input: crate::operation::list_replicators::ListReplicatorsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::ReplicatorSummary>> {
    let input = input.replicators?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_scram_secrets_output_output_secret_arn_list(
    input: crate::operation::list_scram_secrets::ListScramSecretsOutput,
) -> ::std::option::Option<::std::vec::Vec<::std::string::String>> {
    let input = input.secret_arn_list?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_topics_output_output_topics(
    input: crate::operation::list_topics::ListTopicsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::TopicInfo>> {
    let input = input.topics?;
    ::std::option::Option::Some(input)
}

pub(crate) fn lens_list_vpc_connections_output_output_vpc_connections(
    input: crate::operation::list_vpc_connections::ListVpcConnectionsOutput,
) -> ::std::option::Option<::std::vec::Vec<crate::types::VpcConnection>> {
    let input = input.vpc_connections?;
    ::std::option::Option::Some(input)
}