pub trait MQAdminExt: Send {
Show 78 methods
// Required methods
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: Option<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<()>;
}Required Methods§
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: Option<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<()>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.