Struct rabbitmq_stream_client::ProducerBuilder

pub struct ProducerBuilder<T> {
    pub batch_size: usize,
    pub batch_publishing_delay: Duration,
    /* private fields */
}

Builder for Producer

Fields

batch_size: usize

batch_publishing_delay: Duration

Implementations

impl<T> ProducerBuilder<T>

pub async fn build( self, stream: &str ) -> Result<Producer<T>, ProducerCreateError>

pub fn batch_size(self, batch_size: usize) -> Self

pub fn batch_delay(self, delay: Duration) -> Self

pub fn name(self, name: &str) -> ProducerBuilder<Dedup>