Struct rocketmq_common::common::namesrv::namesrv_config::NamesrvConfig

pub struct NamesrvConfig {

    pub rocketmq_home: String,
    pub kv_config_path: String,
    pub config_store_path: String,
    pub product_env_name: String,
    pub cluster_test: bool,
    pub order_message_enable: bool,
    pub return_order_topic_config_to_broker: bool,
    pub client_request_thread_pool_nums: i32,
    pub default_thread_pool_nums: i32,
    pub client_request_thread_pool_queue_capacity: i32,
    pub default_thread_pool_queue_capacity: i32,
    pub scan_not_active_broker_interval: u64,
    pub unregister_broker_queue_capacity: i32,
    pub support_acting_master: bool,
    pub enable_all_topic_list: bool,
    pub enable_topic_list: bool,
    pub notify_min_broker_id_changed: bool,
    pub enable_controller_in_namesrv: bool,
    pub need_wait_for_service: bool,
    pub wait_seconds_for_service: i32,
    pub delete_topic_with_broker_registration: bool,
    pub config_black_list: String,
}

Fields

rocketmq_home: String

kv_config_path: String

config_store_path: String

product_env_name: String

cluster_test: bool

order_message_enable: bool

return_order_topic_config_to_broker: bool

client_request_thread_pool_nums: i32

default_thread_pool_nums: i32

client_request_thread_pool_queue_capacity: i32

default_thread_pool_queue_capacity: i32

scan_not_active_broker_interval: u64

unregister_broker_queue_capacity: i32

support_acting_master: bool

enable_all_topic_list: bool

enable_topic_list: bool

notify_min_broker_id_changed: bool

enable_controller_in_namesrv: bool

need_wait_for_service: bool

wait_seconds_for_service: i32

delete_topic_with_broker_registration: bool

config_black_list: String

Implementations

impl NamesrvConfig

pub fn new() -> NamesrvConfig

Trait Implementations

impl Clone for NamesrvConfig

fn clone(&self) -> NamesrvConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for NamesrvConfig

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

Formats the value using the given formatter.

impl Default for NamesrvConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for NamesrvConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.