pub struct DefaultMQAdminExtImpl { /* private fields */ }Implementations§
Source§impl DefaultMQAdminExtImpl
impl DefaultMQAdminExtImpl
pub fn new( rpc_hook: Option<Arc<Box<dyn RPCHook>>>, timeout_millis: Duration, client_config: ArcMut<ClientConfig>, admin_ext_group: CheetahString, ) -> Self
pub fn set_inner(&mut self, inner: ArcMut<DefaultMQAdminExtImpl>)
Trait Implementations§
Source§impl MQAdminExt for DefaultMQAdminExtImpl
impl MQAdminExt for DefaultMQAdminExtImpl
async fn start(&mut self) -> RocketMQResult<()>
async fn shutdown(&mut self)
async fn add_broker_to_container( &self, broker_container_addr: CheetahString, broker_config: CheetahString, ) -> RocketMQResult<()>
async fn remove_broker_from_container( &self, broker_container_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: u64, ) -> RocketMQResult<()>
async fn update_broker_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> RocketMQResult<()>
async fn get_broker_config( &self, broker_addr: CheetahString, ) -> RocketMQResult<HashMap<CheetahString, CheetahString>>
async fn create_and_update_topic_config( &self, addr: CheetahString, config: TopicConfig, ) -> RocketMQResult<()>
async fn create_and_update_topic_config_list( &self, addr: CheetahString, topic_config_list: Vec<TopicConfig>, ) -> RocketMQResult<()>
async fn create_and_update_plain_access_config( &self, addr: CheetahString, config: PlainAccessConfig, ) -> RocketMQResult<()>
async fn delete_plain_access_config( &self, addr: CheetahString, access_key: CheetahString, ) -> RocketMQResult<()>
async fn update_global_white_addr_config( &self, addr: CheetahString, global_white_addrs: CheetahString, acl_file_full_path: Option<CheetahString>, ) -> RocketMQResult<()>
async fn examine_broker_cluster_acl_version_info( &self, addr: CheetahString, ) -> RocketMQResult<CheetahString>
async fn create_and_update_subscription_group_config( &self, addr: CheetahString, config: SubscriptionGroupConfig, ) -> RocketMQResult<()>
async fn create_and_update_subscription_group_config_list( &self, broker_addr: CheetahString, configs: Vec<SubscriptionGroupConfig>, ) -> RocketMQResult<()>
async fn examine_subscription_group_config( &self, addr: CheetahString, group: CheetahString, ) -> RocketMQResult<SubscriptionGroupConfig>
async fn examine_topic_stats( &self, topic: CheetahString, broker_addr: Option<CheetahString>, ) -> RocketMQResult<TopicStatsTable>
async fn examine_topic_stats_concurrent( &self, topic: CheetahString, ) -> AdminToolResult<TopicStatsTable>
async fn fetch_all_topic_list(&self) -> RocketMQResult<TopicList>
async fn fetch_topics_by_cluster( &self, cluster_name: CheetahString, ) -> RocketMQResult<TopicList>
async fn fetch_broker_runtime_stats( &self, broker_addr: CheetahString, ) -> RocketMQResult<KVTable>
async fn examine_consume_stats( &self, consumer_group: CheetahString, topic: Option<CheetahString>, cluster_name: Option<CheetahString>, broker_addr: Option<CheetahString>, timeout_millis: Option<u64>, ) -> RocketMQResult<ConsumeStats>
async fn examine_broker_cluster_info(&self) -> RocketMQResult<ClusterInfo>
async fn examine_topic_route_info( &self, topic: CheetahString, ) -> RocketMQResult<Option<TopicRouteData>>
async fn examine_consumer_connection_info( &self, consumer_group: CheetahString, broker_addr: Option<CheetahString>, ) -> RocketMQResult<ConsumerConnection>
async fn examine_producer_connection_info( &self, producer_group: CheetahString, topic: CheetahString, ) -> RocketMQResult<ProducerConnection>
async fn get_name_server_address_list(&self) -> Vec<CheetahString>
async fn wipe_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> RocketMQResult<i32>
async fn add_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> RocketMQResult<i32>
async fn put_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, )
async fn get_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> RocketMQResult<CheetahString>
async fn get_kv_list_by_namespace( &self, namespace: CheetahString, ) -> RocketMQResult<KVTable>
async fn delete_topic( &self, topic_name: CheetahString, cluster_name: CheetahString, ) -> RocketMQResult<()>
async fn delete_topic_in_broker( &self, addrs: HashSet<CheetahString>, topic: CheetahString, ) -> RocketMQResult<()>
async fn delete_topic_in_name_server( &self, addrs: HashSet<CheetahString>, cluster_name: Option<CheetahString>, topic: CheetahString, ) -> RocketMQResult<()>
async fn delete_subscription_group( &self, addr: CheetahString, group_name: CheetahString, remove_offset: Option<bool>, ) -> RocketMQResult<()>
async fn create_and_update_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, ) -> RocketMQResult<()>
async fn delete_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> RocketMQResult<()>
async fn reset_offset_by_timestamp( &self, cluster_name: Option<CheetahString>, topic: CheetahString, group: CheetahString, timestamp: u64, is_force: bool, ) -> RocketMQResult<HashMap<MessageQueue, u64>>
async fn reset_offset_new( &self, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, ) -> RocketMQResult<()>
async fn get_consume_status( &self, topic: CheetahString, group: CheetahString, client_addr: CheetahString, ) -> RocketMQResult<HashMap<CheetahString, HashMap<MessageQueue, u64>>>
async fn create_or_update_order_conf( &self, key: CheetahString, value: CheetahString, is_cluster: bool, ) -> RocketMQResult<()>
async fn query_topic_consume_by_who( &self, topic: CheetahString, ) -> RocketMQResult<GroupList>
async fn query_topics_by_consumer( &self, group: CheetahString, ) -> RocketMQResult<TopicList>
async fn query_topics_by_consumer_concurrent( &self, group: CheetahString, ) -> AdminToolResult<TopicList>
async fn query_subscription( &self, group: CheetahString, topic: CheetahString, ) -> RocketMQResult<SubscriptionData>
async fn clean_expired_consumer_queue( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>
async fn delete_expired_commit_log( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>
async fn clean_unused_topic( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> RocketMQResult<bool>
async fn get_consumer_running_info( &self, consumer_group: CheetahString, client_id: CheetahString, jstack: bool, metrics: Option<bool>, ) -> RocketMQResult<ConsumerRunningInfo>
async fn consume_message_directly( &self, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<ConsumeMessageDirectlyResult>
async fn consume_message_directly_ext( &self, cluster_name: CheetahString, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<ConsumeMessageDirectlyResult>
async fn clone_group_offset( &self, src_group: CheetahString, dest_group: CheetahString, topic: CheetahString, is_offline: bool, ) -> RocketMQResult<()>
async fn get_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>
async fn get_topic_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>
async fn get_all_topic_config( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> RocketMQResult<TopicConfigSerializeWrapper>
async fn get_user_topic_config( &self, broker_addr: CheetahString, special_topic: bool, timeout_millis: u64, ) -> RocketMQResult<TopicConfigSerializeWrapper>
async fn update_consume_offset( &self, broker_addr: CheetahString, consume_group: CheetahString, mq: MessageQueue, offset: u64, ) -> RocketMQResult<()>
async fn update_name_server_config( &self, properties: HashMap<CheetahString, CheetahString>, name_servers: Vec<CheetahString>, ) -> RocketMQResult<()>
async fn get_name_server_config( &self, name_servers: Vec<CheetahString>, ) -> RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>
async fn resume_check_half_message( &self, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<bool>
async fn set_message_request_mode( &self, broker_addr: CheetahString, topic: CheetahString, consumer_group: CheetahString, mode: MessageRequestMode, pop_work_group_size: i32, timeout_millis: u64, ) -> RocketMQResult<()>
async fn reset_offset_by_queue_id( &self, broker_addr: CheetahString, consumer_group: CheetahString, topic_name: CheetahString, queue_id: i32, reset_offset: u64, ) -> RocketMQResult<()>
async fn examine_topic_config( &self, addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<TopicConfig>
async fn create_static_topic( &self, addr: CheetahString, default_topic: CheetahString, topic_config: TopicConfig, mapping_detail: TopicQueueMappingDetail, force: bool, ) -> RocketMQResult<()>
async fn reset_master_flush_offset( &self, broker_addr: CheetahString, master_flush_offset: u64, ) -> RocketMQResult<()>
async fn get_controller_config( &self, controller_servers: Vec<CheetahString>, ) -> RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>
async fn update_controller_config( &self, properties: HashMap<CheetahString, CheetahString>, controllers: Vec<CheetahString>, ) -> RocketMQResult<()>
async fn clean_controller_broker_data( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_controller_ids_to_clean: Option<CheetahString>, is_clean_living_broker: bool, ) -> RocketMQResult<()>
async fn update_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> RocketMQResult<()>
async fn remove_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> RocketMQResult<()>
async fn get_cold_data_flow_ctr_info( &self, broker_addr: CheetahString, ) -> RocketMQResult<CheetahString>
async fn set_commit_log_read_ahead_mode( &self, broker_addr: CheetahString, mode: CheetahString, ) -> RocketMQResult<CheetahString>
async fn create_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, ) -> RocketMQResult<()>
async fn update_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, user_status: CheetahString, ) -> RocketMQResult<()>
async fn delete_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> RocketMQResult<()>
async fn create_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> RocketMQResult<()>
async fn update_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> RocketMQResult<()>
async fn delete_acl( &self, broker_addr: CheetahString, subject: CheetahString, resource: CheetahString, ) -> RocketMQResult<()>
Auto Trait Implementations§
impl !Freeze for DefaultMQAdminExtImpl
impl !RefUnwindSafe for DefaultMQAdminExtImpl
impl Send for DefaultMQAdminExtImpl
impl Sync for DefaultMQAdminExtImpl
impl Unpin for DefaultMQAdminExtImpl
impl !UnwindSafe for DefaultMQAdminExtImpl
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FmtForward for T
impl<T> FmtForward for T
Source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.Source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.Source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.Source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.Source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.Source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.Source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.Source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<TraitVariantBlanketType> MQAdminExtLocal for TraitVariantBlanketTypewhere
TraitVariantBlanketType: MQAdminExt,
impl<TraitVariantBlanketType> MQAdminExtLocal for TraitVariantBlanketTypewhere
TraitVariantBlanketType: MQAdminExt,
async fn start(&mut self) -> Result<(), RocketmqError>
async fn shutdown(&mut self)
async fn add_broker_to_container( &self, broker_container_addr: CheetahString, broker_config: CheetahString, ) -> Result<(), RocketmqError>
async fn remove_broker_from_container( &self, broker_container_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: u64, ) -> Result<(), RocketmqError>
async fn update_broker_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> Result<(), RocketmqError>
async fn get_broker_config( &self, broker_addr: CheetahString, ) -> Result<HashMap<CheetahString, CheetahString>, RocketmqError>
async fn create_and_update_topic_config( &self, addr: CheetahString, config: TopicConfig, ) -> Result<(), RocketmqError>
async fn create_and_update_topic_config_list( &self, addr: CheetahString, topic_config_list: Vec<TopicConfig>, ) -> Result<(), RocketmqError>
async fn create_and_update_plain_access_config( &self, addr: CheetahString, config: PlainAccessConfig, ) -> Result<(), RocketmqError>
async fn delete_plain_access_config( &self, addr: CheetahString, access_key: CheetahString, ) -> Result<(), RocketmqError>
async fn update_global_white_addr_config( &self, addr: CheetahString, global_white_addrs: CheetahString, acl_file_full_path: Option<CheetahString>, ) -> Result<(), RocketmqError>
async fn examine_broker_cluster_acl_version_info( &self, addr: CheetahString, ) -> Result<CheetahString, RocketmqError>
async fn create_and_update_subscription_group_config( &self, addr: CheetahString, config: SubscriptionGroupConfig, ) -> Result<(), RocketmqError>
async fn create_and_update_subscription_group_config_list( &self, broker_addr: CheetahString, configs: Vec<SubscriptionGroupConfig>, ) -> Result<(), RocketmqError>
async fn examine_subscription_group_config( &self, addr: CheetahString, group: CheetahString, ) -> Result<SubscriptionGroupConfig, RocketmqError>
async fn examine_topic_stats( &self, topic: CheetahString, broker_addr: Option<CheetahString>, ) -> Result<TopicStatsTable, RocketmqError>
async fn examine_topic_stats_concurrent( &self, topic: CheetahString, ) -> AdminToolResult<TopicStatsTable>
async fn fetch_all_topic_list(&self) -> Result<TopicList, RocketmqError>
async fn fetch_topics_by_cluster( &self, cluster_name: CheetahString, ) -> Result<TopicList, RocketmqError>
async fn fetch_broker_runtime_stats( &self, broker_addr: CheetahString, ) -> Result<KVTable, RocketmqError>
async fn examine_consume_stats( &self, consumer_group: CheetahString, topic: Option<CheetahString>, cluster_name: Option<CheetahString>, broker_addr: Option<CheetahString>, timeout_millis: Option<u64>, ) -> Result<ConsumeStats, RocketmqError>
async fn examine_broker_cluster_info( &self, ) -> Result<ClusterInfo, RocketmqError>
async fn examine_topic_route_info( &self, topic: CheetahString, ) -> Result<Option<TopicRouteData>, RocketmqError>
async fn examine_consumer_connection_info( &self, consumer_group: CheetahString, broker_addr: Option<CheetahString>, ) -> Result<ConsumerConnection, RocketmqError>
async fn examine_producer_connection_info( &self, producer_group: CheetahString, topic: CheetahString, ) -> Result<ProducerConnection, RocketmqError>
async fn get_name_server_address_list(&self) -> Vec<CheetahString>
async fn wipe_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> Result<i32, RocketmqError>
async fn add_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> Result<i32, RocketmqError>
async fn put_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, )
async fn get_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> Result<CheetahString, RocketmqError>
async fn get_kv_list_by_namespace( &self, namespace: CheetahString, ) -> Result<KVTable, RocketmqError>
async fn delete_topic( &self, topic_name: CheetahString, cluster_name: CheetahString, ) -> Result<(), RocketmqError>
async fn delete_topic_in_broker( &self, addrs: HashSet<CheetahString>, topic: CheetahString, ) -> Result<(), RocketmqError>
async fn delete_topic_in_name_server( &self, addrs: HashSet<CheetahString>, cluster_name: Option<CheetahString>, topic: CheetahString, ) -> Result<(), RocketmqError>
async fn delete_subscription_group( &self, addr: CheetahString, group_name: CheetahString, remove_offset: Option<bool>, ) -> Result<(), RocketmqError>
async fn create_and_update_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, ) -> Result<(), RocketmqError>
async fn delete_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> Result<(), RocketmqError>
async fn reset_offset_by_timestamp( &self, cluster_name: Option<CheetahString>, topic: CheetahString, group: CheetahString, timestamp: u64, is_force: bool, ) -> Result<HashMap<MessageQueue, u64>, RocketmqError>
async fn reset_offset_new( &self, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, ) -> Result<(), RocketmqError>
async fn get_consume_status( &self, topic: CheetahString, group: CheetahString, client_addr: CheetahString, ) -> Result<HashMap<CheetahString, HashMap<MessageQueue, u64>>, RocketmqError>
async fn create_or_update_order_conf( &self, key: CheetahString, value: CheetahString, is_cluster: bool, ) -> Result<(), RocketmqError>
async fn query_topic_consume_by_who( &self, topic: CheetahString, ) -> Result<GroupList, RocketmqError>
async fn query_topics_by_consumer( &self, group: CheetahString, ) -> Result<TopicList, RocketmqError>
async fn query_topics_by_consumer_concurrent( &self, group: CheetahString, ) -> AdminToolResult<TopicList>
async fn query_subscription( &self, group: CheetahString, topic: CheetahString, ) -> Result<SubscriptionData, RocketmqError>
async fn clean_expired_consumer_queue( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> Result<bool, RocketmqError>
async fn delete_expired_commit_log( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> Result<bool, RocketmqError>
async fn clean_unused_topic( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> Result<bool, RocketmqError>
async fn get_consumer_running_info( &self, consumer_group: CheetahString, client_id: CheetahString, jstack: bool, metrics: Option<bool>, ) -> Result<ConsumerRunningInfo, RocketmqError>
async fn consume_message_directly( &self, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> Result<ConsumeMessageDirectlyResult, RocketmqError>
async fn consume_message_directly_ext( &self, cluster_name: CheetahString, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> Result<ConsumeMessageDirectlyResult, RocketmqError>
async fn clone_group_offset( &self, src_group: CheetahString, dest_group: CheetahString, topic: CheetahString, is_offline: bool, ) -> Result<(), RocketmqError>
async fn get_cluster_list( &self, topic: String, ) -> Result<HashSet<CheetahString>, RocketmqError>
async fn get_topic_cluster_list( &self, topic: String, ) -> Result<HashSet<CheetahString>, RocketmqError>
async fn get_all_topic_config( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> Result<TopicConfigSerializeWrapper, RocketmqError>
async fn get_user_topic_config( &self, broker_addr: CheetahString, special_topic: bool, timeout_millis: u64, ) -> Result<TopicConfigSerializeWrapper, RocketmqError>
async fn update_consume_offset( &self, broker_addr: CheetahString, consume_group: CheetahString, mq: MessageQueue, offset: u64, ) -> Result<(), RocketmqError>
async fn update_name_server_config( &self, properties: HashMap<CheetahString, CheetahString>, name_servers: Vec<CheetahString>, ) -> Result<(), RocketmqError>
async fn get_name_server_config( &self, name_servers: Vec<CheetahString>, ) -> Result<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>, RocketmqError>
async fn resume_check_half_message( &self, topic: CheetahString, msg_id: CheetahString, ) -> Result<bool, RocketmqError>
async fn set_message_request_mode( &self, broker_addr: CheetahString, topic: CheetahString, consumer_group: CheetahString, mode: MessageRequestMode, pop_work_group_size: i32, timeout_millis: u64, ) -> Result<(), RocketmqError>
async fn reset_offset_by_queue_id( &self, broker_addr: CheetahString, consumer_group: CheetahString, topic_name: CheetahString, queue_id: i32, reset_offset: u64, ) -> Result<(), RocketmqError>
async fn examine_topic_config( &self, addr: CheetahString, topic: CheetahString, ) -> Result<TopicConfig, RocketmqError>
async fn create_static_topic( &self, addr: CheetahString, default_topic: CheetahString, topic_config: TopicConfig, mapping_detail: TopicQueueMappingDetail, force: bool, ) -> Result<(), RocketmqError>
async fn reset_master_flush_offset( &self, broker_addr: CheetahString, master_flush_offset: u64, ) -> Result<(), RocketmqError>
async fn get_controller_config( &self, controller_servers: Vec<CheetahString>, ) -> Result<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>, RocketmqError>
async fn update_controller_config( &self, properties: HashMap<CheetahString, CheetahString>, controllers: Vec<CheetahString>, ) -> Result<(), RocketmqError>
async fn clean_controller_broker_data( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_controller_ids_to_clean: Option<CheetahString>, is_clean_living_broker: bool, ) -> Result<(), RocketmqError>
async fn update_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> Result<(), RocketmqError>
async fn remove_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> Result<(), RocketmqError>
async fn get_cold_data_flow_ctr_info( &self, broker_addr: CheetahString, ) -> Result<CheetahString, RocketmqError>
async fn set_commit_log_read_ahead_mode( &self, broker_addr: CheetahString, mode: CheetahString, ) -> Result<CheetahString, RocketmqError>
async fn create_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, ) -> Result<(), RocketmqError>
async fn update_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, user_status: CheetahString, ) -> Result<(), RocketmqError>
async fn delete_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> Result<(), RocketmqError>
async fn create_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> Result<(), RocketmqError>
async fn update_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> Result<(), RocketmqError>
async fn delete_acl( &self, broker_addr: CheetahString, subject: CheetahString, resource: CheetahString, ) -> Result<(), RocketmqError>
Source§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
Source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
Source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read moreSource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
Source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
Source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.Source§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.Source§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.Source§impl<T> Tap for T
impl<T> Tap for T
Source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read moreSource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read moreSource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read moreSource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read moreSource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read moreSource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read moreSource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.Source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.Source§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.Source§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.Source§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.Source§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.