Struct ProducerConfig 

pub struct ProducerConfig { /* private fields */ }

Implementations

impl ProducerConfig

pub fn retry_response_codes(&self) -> &HashSet<i32>

pub fn producer_group(&self) -> &CheetahString

pub fn topics(&self) -> &Vec<CheetahString>

pub fn create_topic_key(&self) -> &CheetahString

pub fn default_topic_queue_nums(&self) -> u32

pub fn send_msg_timeout(&self) -> u32

pub fn send_msg_max_timeout_per_request(&self) -> Option<u32>

pub fn compress_msg_body_over_howmuch(&self) -> u32

pub fn retry_times_when_send_failed(&self) -> u32

pub fn retry_times_when_send_async_failed(&self) -> u32

pub fn retry_another_broker_when_not_store_ok(&self) -> bool

pub fn max_message_size(&self) -> u32

pub fn trace_dispatcher(&self) -> Option<&ArcTraceDispatcher>

pub fn auto_batch(&self) -> bool

pub fn batch_max_delay_ms(&self) -> Option<u32>

pub fn batch_max_bytes(&self) -> Option<u64>

pub fn total_batch_max_bytes(&self) -> Option<u64>

pub fn produce_accumulator(&self) -> Option<&Arc<ProduceAccumulator>>

pub fn enable_backpressure_for_async_mode(&self) -> bool

pub fn back_pressure_for_async_send_num(&self) -> u32

pub fn back_pressure_for_async_send_size(&self) -> u32

pub fn rpc_hook(&self) -> &Option<Arc<dyn RPCHook>>

pub fn compress_level(&self) -> i32

pub fn compress_type(&self) -> CompressionType

pub fn compressor(&self) -> Option<&'static (dyn Compressor + Send + Sync)>

Trait Implementations

impl Clone for ProducerConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ProducerConfig

fn default() -> Self

Returns the “default value” for a type.