Struct TopicClient 

pub struct TopicClient { /* private fields */ }

Implementations

impl TopicClient

pub async fn create_topic( &mut self, path: String, options: CreateTopicOptions, ) -> YdbResult<()>

pub async fn alter_topic( &mut self, path: String, options: AlterTopicOptions, ) -> YdbResult<()>

pub async fn describe_consumer( &mut self, path: String, consumer: String, options: DescribeConsumerOptions, ) -> YdbResult<ConsumerDescription>

pub async fn describe_topic( &mut self, path: String, options: DescribeTopicOptions, ) -> YdbResult<TopicDescription>

pub async fn drop_topic(&mut self, path: String) -> YdbResult<()>

pub async fn create_reader( &mut self, consumer: String, topic: impl Into<TopicSelectors>, ) -> YdbResult<TopicReader>

pub async fn create_writer_with_params( &mut self, writer_options: TopicWriterOptions, ) -> YdbResult<TopicWriter>

pub async fn create_writer(&mut self, path: String) -> YdbResult<TopicWriter>

Trait Implementations

impl Clone for TopicClient

fn clone(&self) -> TopicClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.