Struct ConsumerConfig

pub struct ConsumerConfig { /* private fields */ }

Implementations

impl ConsumerConfig

pub fn consumer_group(&self) -> &CheetahString

pub fn message_model(&self) -> MessageModel

pub fn consume_from_where(&self) -> ConsumeFromWhere

pub fn consume_timestamp(&self) -> &Option<CheetahString>

pub fn allocate_message_queue_strategy( &self, ) -> Option<Arc<dyn AllocateMessageQueueStrategy>>

pub fn subscription(&self) -> &ArcMut<HashMap<CheetahString, CheetahString>>

pub fn consume_thread_min(&self) -> u32

pub fn consume_thread_max(&self) -> u32

pub fn adjust_thread_pool_nums_threshold(&self) -> u64

pub fn consume_concurrently_max_span(&self) -> u32

pub fn pull_threshold_for_queue(&self) -> u32

pub fn pop_threshold_for_queue(&self) -> u32

pub fn pull_threshold_size_for_queue(&self) -> u32

pub fn pull_threshold_for_topic(&self) -> i32

pub fn pull_threshold_size_for_topic(&self) -> i32

pub fn pull_interval(&self) -> u64

pub fn consume_message_batch_max_size(&self) -> u32

pub fn pull_batch_size(&self) -> u32

pub fn pull_batch_size_in_bytes(&self) -> u32

pub fn post_subscription_when_pull(&self) -> bool

pub fn unit_mode(&self) -> bool

pub fn max_reconsume_times(&self) -> i32

pub fn suspend_current_queue_time_millis(&self) -> u64

pub fn consume_timeout(&self) -> u64

pub fn pop_invisible_time(&self) -> u64

pub fn pop_batch_nums(&self) -> u32

pub fn await_termination_millis_when_shutdown(&self) -> u64

pub fn trace_dispatcher( &self, ) -> &Option<Arc<Box<dyn TraceDispatcher + Send + Sync>>>

pub fn client_rebalance(&self) -> bool

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

pub fn set_consumer_group(&mut self, consumer_group: CheetahString)

pub fn set_message_model(&mut self, message_model: MessageModel)

pub fn set_consume_from_where(&mut self, consume_from_where: ConsumeFromWhere)

pub fn set_consume_timestamp( &mut self, consume_timestamp: Option<CheetahString>, )

pub fn set_allocate_message_queue_strategy( &mut self, allocate_message_queue_strategy: Arc<dyn AllocateMessageQueueStrategy>, )

pub fn set_subscription( &mut self, subscription: ArcMut<HashMap<CheetahString, CheetahString>>, )

This method will be removed in a certain version after April 5, 2020, so please do not use this method.

pub fn set_message_queue_listener( &mut self, message_queue_listener: Option<Arc<Box<dyn MessageQueueListener>>>, )

pub fn set_consume_thread_min(&mut self, consume_thread_min: u32)

pub fn set_consume_thread_max(&mut self, consume_thread_max: u32)

pub fn set_adjust_thread_pool_nums_threshold( &mut self, adjust_thread_pool_nums_threshold: u64, )

pub fn set_consume_concurrently_max_span( &mut self, consume_concurrently_max_span: u32, )

pub fn set_pull_threshold_for_queue(&mut self, pull_threshold_for_queue: u32)

pub fn set_pop_threshold_for_queue(&mut self, pop_threshold_for_queue: u32)

pub fn set_pull_threshold_size_for_queue( &mut self, pull_threshold_size_for_queue: u32, )

pub fn set_pull_threshold_for_topic(&mut self, pull_threshold_for_topic: i32)

pub fn set_pull_threshold_size_for_topic( &mut self, pull_threshold_size_for_topic: i32, )

pub fn set_pull_interval(&mut self, pull_interval: u64)

pub fn set_consume_message_batch_max_size( &mut self, consume_message_batch_max_size: u32, )

pub fn set_pull_batch_size(&mut self, pull_batch_size: u32)

pub fn set_pull_batch_size_in_bytes(&mut self, pull_batch_size_in_bytes: u32)

pub fn set_post_subscription_when_pull( &mut self, post_subscription_when_pull: bool, )

pub fn set_unit_mode(&mut self, unit_mode: bool)

pub fn set_max_reconsume_times(&mut self, max_reconsume_times: i32)

pub fn set_suspend_current_queue_time_millis( &mut self, suspend_current_queue_time_millis: u64, )

pub fn set_consume_timeout(&mut self, consume_timeout: u64)

pub fn set_pop_invisible_time(&mut self, pop_invisible_time: u64)

pub fn set_pop_batch_nums(&mut self, pop_batch_nums: u32)

pub fn set_await_termination_millis_when_shutdown( &mut self, await_termination_millis_when_shutdown: u64, )

pub fn set_trace_dispatcher( &mut self, trace_dispatcher: Option<Arc<Box<dyn TraceDispatcher + Send + Sync>>>, )

pub fn set_client_rebalance(&mut self, client_rebalance: bool)

pub fn set_rpc_hook(&mut self, rpc_hook: Option<Arc<Box<dyn RPCHook>>>)

Trait Implementations

impl Clone for ConsumerConfig

fn clone(&self) -> ConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ConsumerConfig

fn default() -> Self

Returns the “default value” for a type.