Struct MQFaultStrategy 

pub struct MQFaultStrategy { /* private fields */ }

Implementations

impl MQFaultStrategy

pub const DEFAULT_LATENCY_MAX: [u64; 7]

pub const DEFAULT_NOT_AVAILABLE_DURATION: [u64; 7]

pub fn new( service_context: ChildServiceContext, client_config: &ClientConfig, ) -> Self

pub fn start_detector(&self)

pub fn shutdown(&self)

pub async fn shutdown_async(&self) -> bool

pub fn is_start_detector_enable(&self) -> bool

pub fn set_start_detector_enable(&self, start_detector_enable: bool)

pub fn is_send_latency_fault_enable(&self) -> bool

pub fn select_one_message_queue( &self, tp_info: &TopicPublishInfo, last_broker_name: Option<&CheetahString>, reset_index: bool, ) -> Option<MessageQueue>

pub fn get_latency_max(&self) -> &[u64]

pub fn set_latency_max(&mut self, latency_max: impl Into<Vec<u64>>)

pub fn get_not_available_duration(&self) -> &[u64]

pub fn set_not_available_duration( &mut self, not_available_duration: impl Into<Vec<u64>>, )

pub async fn update_fault_item( &self, broker_name: CheetahString, current_latency: u64, isolation: bool, reachable: bool, )

pub fn set_send_latency_fault_enable(&self, send_latency_fault_enable: bool)

Trait Implementations

impl Clone for MQFaultStrategy

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.