Struct DanubeClient 

pub struct DanubeClient { /* private fields */ }

The main client for interacting with the Danube messaging system.

The DanubeClient struct is designed to facilitate communication with the Danube messaging system. It provides various methods for managing producers and consumers, performing topic lookups, and retrieving schema information. This client acts as the central interface for interacting with the messaging system and managing connections and services.

Implementations

impl DanubeClient

pub fn builder() -> DanubeClientBuilder

Initializes a new DanubeClientBuilder instance.

The builder pattern allows for configuring and constructing a DanubeClient instance with optional settings and options. Using the builder, you can customize various aspects of the DanubeClient, such as connection settings, timeouts, and other configurations before creating the final DanubeClient instance.

pub fn new_producer(&self) -> ProducerBuilder

Returns a new ProducerBuilder for configuring and creating a Producer instance.

This method initializes a ProducerBuilder, which is used to set up various options and settings for a Producer. The builder pattern allows you to specify details such as the topic, producer name, partitions, schema, and other configurations before creating the final Producer instance.

pub fn new_consumer(&self) -> ConsumerBuilder

Returns a new ConsumerBuilder for configuring and creating a Consumer instance.

This method initializes a ConsumerBuilder, which is used to set up various options and settings for a Consumer. The builder pattern allows you to specify details such as the topic, consumer name, subscription, subscription type, and other configurations before creating the final Consumer instance.

pub fn auth_service(&self) -> &AuthService

Returns a reference to the AuthService.

This method provides access to the AuthService instance used by the DanubeClient.

pub async fn lookup_topic( &self, addr: &Uri, topic: impl Into<String>, ) -> Result<LookupResult>

Retrieves the address of the broker responsible for a specified topic.

This asynchronous method performs a lookup to find the broker that is responsible for the given topic. The addr parameter specifies the address of the broker to connect to for performing the lookup. The method returns information about the broker handling the topic.

Parameters

• addr: The address of the broker to connect to for the lookup. This is provided as a &Uri, which specifies where the request should be sent.
• topic: The name of the topic for which to look up the broker.

Returns

• Ok(LookupResult): Contains the result of the lookup operation, including the broker address.
• Err(e): An error if the lookup fails or if there are issues during the operation. This could include connectivity problems, invalid topic names, or other errors related to the lookup process.

pub async fn get_schema(&self, topic: impl Into<String>) -> Result<Schema>

Retrieves the schema associated with a specified topic from the schema service.

This asynchronous method fetches the schema for the given topic from the schema service. The schema describes the structure and format of the messages for the specified topic. The method returns the schema details or an error if the retrieval fails.

Parameters

• topic: The name of the topic for which the schema is to be retrieved.

Returns

• Ok(Schema): The schema associated with the specified topic. This includes information about the schema type and its definition, if available.
• Err(e): An error if the schema retrieval fails or if there are issues during the operation. This could include errors such as non-existent topics, connectivity issues, or internal service errors.

Trait Implementations

impl Clone for DanubeClient

fn clone(&self) -> DanubeClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DanubeClient

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

Formats the value using the given formatter.