Struct danube_client::ProducerBuilder

pub struct ProducerBuilder { /* private fields */ }

Implementations

impl ProducerBuilder

pub fn new(client: &DanubeClient) -> Self

pub fn with_topic(self, topic: impl Into<String>) -> Self

sets the producer’s topic

pub fn with_name(self, producer_name: impl Into<String>) -> Self

sets the producer’s name

pub fn with_schema(self, schema_name: String, schema_type: SchemaType) -> Self

pub fn with_options(self, options: ProducerOptions) -> Self

pub fn build(self) -> Producer

Trait Implementations

impl Clone for ProducerBuilder

fn clone(&self) -> ProducerBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ProducerBuilder

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

Formats the value using the given formatter.