Trait rusoto_kafka::Kafka

pub trait Kafka {
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
    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;
}

Trait representing the capabilities of the Kafka API. Kafka clients implement this trait.

Required methods

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

Loading content...

Implementors

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

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

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>

Loading content...