Struct ClusterClient 

pub struct ClusterClient { /* private fields */ }

Client for interacting with a Rivven cluster

Implementations

impl ClusterClient

pub fn new() -> Self

Create a new cluster client with default configuration

pub fn with_config(config: ClusterClientConfig) -> Self

Create a new cluster client with custom configuration

pub async fn ensure_topic( &self, endpoints: &[String], topic_name: &str, partitions: u32, ) -> Result<TopicInfo>

Create or ensure a topic exists in the cluster

Returns information about the topic including whether it already existed.

pub async fn delete_topic( &self, endpoints: &[String], topic_name: &str, ) -> Result<()>

Delete a topic from the cluster

pub async fn list_topics(&self, endpoints: &[String]) -> Result<Vec<String>>

List all topics in the cluster

pub async fn topic_exists( &self, endpoints: &[String], topic_name: &str, ) -> Result<bool>

Check if a topic exists in the cluster

Trait Implementations

impl Default for ClusterClient

fn default() -> Self

Returns the “default value” for a type.