Struct ManagedKafka 

pub struct ManagedKafka { /* private fields */ }

Implements a client for the Managed Service for Apache Kafka API.

Example

let client = ManagedKafka::builder().build().await?;
// use `client` to make requests to the Managed Service for Apache Kafka API.

Service Description

The service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.

Configuration

To configure ManagedKafka use the with_* methods in the type returned by builder(). The default configuration should work for most applications. Common configuration changes include

• with_endpoint(): by default this client uses the global default endpoint (https://managedkafka.googleapis.com). Applications using regional endpoints or running in restricted networks (e.g. a network configured override this default.
• with_credentials(): by default this client uses Application Default Credentials. Applications using custom authentication may need to override this default.

Pooling and Cloning

ManagedKafka holds a connection pool internally, it is advised to create one and the reuse it. You do not need to wrap ManagedKafka in an Rc or Arc to reuse it, because it already uses an Arc internally.

Implementations

impl ManagedKafka

pub fn builder() -> ClientBuilder

Returns a builder for ManagedKafka.

let client = ManagedKafka::builder().build().await?;

pub fn from_stub<T>(stub: T) -> Self

where T: ManagedKafka + 'static,

Creates a new client from the provided stub.

The most common case for calling this function is in tests mocking the client’s behavior.

pub fn list_clusters(&self) -> ListClusters

Lists the clusters in a given project and location.

pub fn get_cluster(&self) -> GetCluster

Returns the properties of a single cluster.

pub fn create_cluster(&self) -> CreateCluster

Creates a new cluster in a given project and location.

Long running operations

This method is used to start, and/or poll a long-running Operation. The Working with long-running operations chapter in the user guide covers these operations in detail.

pub fn update_cluster(&self) -> UpdateCluster

Updates the properties of a single cluster.

Long running operations

This method is used to start, and/or poll a long-running Operation. The Working with long-running operations chapter in the user guide covers these operations in detail.

pub fn delete_cluster(&self) -> DeleteCluster

Deletes a single cluster.

Long running operations

This method is used to start, and/or poll a long-running Operation. The Working with long-running operations chapter in the user guide covers these operations in detail.

pub fn list_topics(&self) -> ListTopics

Lists the topics in a given cluster.

pub fn get_topic(&self) -> GetTopic

Returns the properties of a single topic.

pub fn create_topic(&self) -> CreateTopic

Creates a new topic in a given project and location.

pub fn update_topic(&self) -> UpdateTopic

Updates the properties of a single topic.

pub fn delete_topic(&self) -> DeleteTopic

Deletes a single topic.

pub fn list_consumer_groups(&self) -> ListConsumerGroups

Lists the consumer groups in a given cluster.

pub fn get_consumer_group(&self) -> GetConsumerGroup

Returns the properties of a single consumer group.

pub fn update_consumer_group(&self) -> UpdateConsumerGroup

Updates the properties of a single consumer group.

pub fn delete_consumer_group(&self) -> DeleteConsumerGroup

Deletes a single consumer group.

pub fn list_acls(&self) -> ListAcls

Lists the acls in a given cluster.

pub fn get_acl(&self) -> GetAcl

Returns the properties of a single acl.

pub fn create_acl(&self) -> CreateAcl

Creates a new acl in the given project, location, and cluster.

pub fn update_acl(&self) -> UpdateAcl

Updates the properties of a single acl.

pub fn delete_acl(&self) -> DeleteAcl

Deletes an acl.

pub fn add_acl_entry(&self) -> AddAclEntry

Incremental update: Adds an acl entry to an acl. Creates the acl if it does not exist yet.

pub fn remove_acl_entry(&self) -> RemoveAclEntry

Incremental update: Removes an acl entry from an acl. Deletes the acl if its acl entries become empty (i.e. if the removed entry was the last one in the acl).

pub fn list_locations(&self) -> ListLocations

Lists information about the supported locations for this service.

pub fn get_location(&self) -> GetLocation

Gets information about a location.

pub fn list_operations(&self) -> ListOperations

Provides the Operations service functionality in this service.

pub fn get_operation(&self) -> GetOperation

Provides the Operations service functionality in this service.

pub fn delete_operation(&self) -> DeleteOperation

Provides the Operations service functionality in this service.

pub fn cancel_operation(&self) -> CancelOperation

Provides the Operations service functionality in this service.

Trait Implementations

impl Clone for ManagedKafka

fn clone(&self) -> ManagedKafka

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ManagedKafka

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

Formats the value using the given formatter.