Struct rusoto_kafka::KafkaClient

pub struct KafkaClient { /* fields omitted */ }

A client for the Kafka API.

Implementations

impl KafkaClient

pub fn new(region: Region) -> KafkaClient

Creates a client backed by the default tokio event loop.

The client will use the default credentials provider and tls client.

pub fn new_with<P, D>(
    request_dispatcher: D,
    credentials_provider: P,
    region: Region
) -> KafkaClient where
    P: ProvideAwsCredentials + Send + Sync + 'static,
    D: DispatchSignedRequest + Send + Sync + 'static, 

pub fn new_with_client(client: Client, region: Region) -> KafkaClient

Trait Implementations

impl Clone for KafkaClient

pub fn clone(&self) -> KafkaClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Kafka for KafkaClient

pub fn create_cluster<'life0, 'async_trait>(
    &'life0 self,
    input: CreateClusterRequest
) -> Pin<Box<dyn Future<Output = Result<CreateClusterResponse, RusotoError<CreateClusterError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Creates a new MSK cluster.</p>

pub fn create_configuration<'life0, 'async_trait>(
    &'life0 self,
    input: CreateConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<CreateConfigurationResponse, RusotoError<CreateConfigurationError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Creates a new MSK configuration.</p>

pub fn delete_cluster<'life0, 'async_trait>(
    &'life0 self,
    input: DeleteClusterRequest
) -> Pin<Box<dyn Future<Output = Result<DeleteClusterResponse, RusotoError<DeleteClusterError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Deletes the MSK cluster specified by the Amazon Resource Name (ARN) in the request.</p>

pub fn describe_cluster<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeClusterRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeClusterResponse, RusotoError<DescribeClusterError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a description of the MSK cluster whose Amazon Resource Name (ARN) is specified in the request.</p>

pub fn describe_cluster_operation<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeClusterOperationRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeClusterOperationResponse, RusotoError<DescribeClusterOperationError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a description of the cluster operation specified by the ARN.</p>

pub fn describe_configuration<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeConfigurationResponse, RusotoError<DescribeConfigurationError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a description of this MSK configuration.</p>

pub fn describe_configuration_revision<'life0, 'async_trait>(
    &'life0 self,
    input: DescribeConfigurationRevisionRequest
) -> Pin<Box<dyn Future<Output = Result<DescribeConfigurationRevisionResponse, RusotoError<DescribeConfigurationRevisionError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a description of this revision of the configuration.</p>

pub fn get_bootstrap_brokers<'life0, 'async_trait>(
    &'life0 self,
    input: GetBootstrapBrokersRequest
) -> Pin<Box<dyn Future<Output = Result<GetBootstrapBrokersResponse, RusotoError<GetBootstrapBrokersError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>A list of brokers that a client application can use to bootstrap.</p>

pub fn get_compatible_kafka_versions<'life0, 'async_trait>(
    &'life0 self,
    input: GetCompatibleKafkaVersionsRequest
) -> Pin<Box<dyn Future<Output = Result<GetCompatibleKafkaVersionsResponse, RusotoError<GetCompatibleKafkaVersionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Gets the Apache Kafka versions to which you can update the MSK cluster.</p>

pub fn list_cluster_operations<'life0, 'async_trait>(
    &'life0 self,
    input: ListClusterOperationsRequest
) -> Pin<Box<dyn Future<Output = Result<ListClusterOperationsResponse, RusotoError<ListClusterOperationsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a list of all the operations that have been performed on the specified MSK cluster.</p>

pub fn list_clusters<'life0, 'async_trait>(
    &'life0 self,
    input: ListClustersRequest
) -> Pin<Box<dyn Future<Output = Result<ListClustersResponse, RusotoError<ListClustersError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a list of all the MSK clusters in the current Region.</p>

pub fn list_configuration_revisions<'life0, 'async_trait>(
    &'life0 self,
    input: ListConfigurationRevisionsRequest
) -> Pin<Box<dyn Future<Output = Result<ListConfigurationRevisionsResponse, RusotoError<ListConfigurationRevisionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a list of all the MSK configurations in this Region.</p>

pub fn list_configurations<'life0, 'async_trait>(
    &'life0 self,
    input: ListConfigurationsRequest
) -> Pin<Box<dyn Future<Output = Result<ListConfigurationsResponse, RusotoError<ListConfigurationsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a list of all the MSK configurations in this Region.</p>

pub fn list_kafka_versions<'life0, 'async_trait>(
    &'life0 self,
    input: ListKafkaVersionsRequest
) -> Pin<Box<dyn Future<Output = Result<ListKafkaVersionsResponse, RusotoError<ListKafkaVersionsError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a list of Kafka versions.</p>

pub fn list_nodes<'life0, 'async_trait>(
    &'life0 self,
    input: ListNodesRequest
) -> Pin<Box<dyn Future<Output = Result<ListNodesResponse, RusotoError<ListNodesError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a list of the broker nodes in the cluster.</p>

pub fn list_tags_for_resource<'life0, 'async_trait>(
    &'life0 self,
    input: ListTagsForResourceRequest
) -> Pin<Box<dyn Future<Output = Result<ListTagsForResourceResponse, RusotoError<ListTagsForResourceError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Returns a list of the tags associated with the specified resource.</p>

pub fn tag_resource<'life0, 'async_trait>(
    &'life0 self,
    input: TagResourceRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<TagResourceError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Adds tags to the specified MSK resource.</p>

pub fn untag_resource<'life0, 'async_trait>(
    &'life0 self,
    input: UntagResourceRequest
) -> Pin<Box<dyn Future<Output = Result<(), RusotoError<UntagResourceError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Removes the tags associated with the keys that are provided in the query.</p>

pub fn update_broker_count<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateBrokerCountRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateBrokerCountResponse, RusotoError<UpdateBrokerCountError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Updates the number of broker nodes in the cluster.</p>

pub fn update_broker_storage<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateBrokerStorageRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateBrokerStorageResponse, RusotoError<UpdateBrokerStorageError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Updates the EBS storage associated with MSK brokers.</p>

pub fn update_cluster_configuration<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateClusterConfigurationRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateClusterConfigurationResponse, RusotoError<UpdateClusterConfigurationError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Updates the cluster with the configuration that is specified in the request body.</p>

pub fn update_cluster_kafka_version<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateClusterKafkaVersionRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateClusterKafkaVersionResponse, RusotoError<UpdateClusterKafkaVersionError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Updates the Apache Kafka version for the cluster.</p>

pub fn update_monitoring<'life0, 'async_trait>(
    &'life0 self,
    input: UpdateMonitoringRequest
) -> Pin<Box<dyn Future<Output = Result<UpdateMonitoringResponse, RusotoError<UpdateMonitoringError>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

        <p>Updates the monitoring settings for the cluster. You can use this operation to specify which Apache Kafka metrics you want Amazon MSK to send to Amazon CloudWatch. You can also specify settings for open monitoring with Prometheus.</p>