Struct KafkaClient 

pub struct KafkaClient { /* private fields */ }

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

fn clone(&self) -> KafkaClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Kafka for KafkaClient

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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 Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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 Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: 'async_trait,

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

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 Self: 'async_trait, 'life0: 'async_trait,

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

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

where Self: 'async_trait, 'life0: '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>