Struct ProducerBuilder

pub struct ProducerBuilder<T> {
    pub batch_size: usize,
    pub filter_value_extractor: Option<Arc<dyn Fn(&Message) -> String + Send + Sync + 'static>>,
    /* private fields */
}

Builder for Producer

Fields

batch_size: usize

filter_value_extractor: Option<Arc<dyn Fn(&Message) -> String + Send + Sync + 'static>>

Implementations

impl<T> ProducerBuilder<T>

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

pub fn on_closed( self, on_closed: Box<dyn OnClosed + Send + Sync>, ) -> ProducerBuilder<T>

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

pub fn overwrite_heartbeat(self, heartbeat: u32) -> ProducerBuilder<T>

Don’t use this in production, it is only for testing purposes.

pub fn client_provided_name(self, name: &str) -> Self

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

pub fn filter_value_extractor( self, filter_value_extractor: impl Fn(&Message) -> String + Send + Sync + 'static, ) -> Self

pub fn filter_value_extractor_arc( self, filter_value_extractor: Option<Arc<dyn Fn(&Message) -> String + Send + Sync + 'static>>, ) -> Self