pub trait MQAdminExt: Send {
Show 140 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 check_rocksdb_cq_write_progress(
&self,
broker_addr: CheetahString,
topic: CheetahString,
check_store_time: i64,
) -> RocketMQResult<CheckRocksdbCqWriteResult>;
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_all_producer_info(
&self,
broker_addr: CheetahString,
) -> RocketMQResult<ProducerTableInfo>;
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_broker_concurrent(
&self,
addrs: HashSet<CheetahString>,
topic: CheetahString,
) -> AdminToolResult<BrokerOperatorResult>;
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_old(
&self,
cluster_name: Option<CheetahString>,
consumer_group: CheetahString,
topic: CheetahString,
timestamp: u64,
force: bool,
) -> RocketMQResult<Vec<RollbackStats>>;
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 reset_offset_new_concurrent(
&self,
group: CheetahString,
topic: CheetahString,
timestamp: u64,
) -> AdminToolResult<BrokerOperatorResult>;
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 query_consume_time_span(
&self,
topic: CheetahString,
group: CheetahString,
) -> RocketMQResult<Vec<QueueTimeSpan>>;
async fn query_consume_time_span_concurrent(
&self,
topic: CheetahString,
group: CheetahString,
) -> AdminToolResult<Vec<QueueTimeSpan>>;
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 message_track_detail(
&self,
msg: MessageExt,
) -> RocketMQResult<Vec<MessageTrack>>;
async fn message_track_detail_concurrent(
&self,
msg: MessageExt,
) -> AdminToolResult<Vec<MessageTrack>>;
async fn clone_group_offset(
&self,
src_group: CheetahString,
dest_group: CheetahString,
topic: CheetahString,
is_offline: bool,
) -> RocketMQResult<()>;
async fn view_broker_stats_data(
&self,
broker_addr: CheetahString,
stats_name: CheetahString,
stats_key: CheetahString,
) -> RocketMQResult<BrokerStatsData>;
async fn get_cluster_list(
&self,
topic: String,
) -> RocketMQResult<HashSet<CheetahString>>;
async fn fetch_consume_stats_in_broker(
&self,
broker_addr: CheetahString,
is_order: bool,
timeout_millis: u64,
) -> RocketMQResult<ConsumeStatsList>;
async fn get_topic_cluster_list(
&self,
topic: String,
) -> RocketMQResult<HashSet<CheetahString>>;
async fn get_all_subscription_group(
&self,
broker_addr: CheetahString,
timeout_millis: u64,
) -> RocketMQResult<SubscriptionGroupWrapper>;
async fn get_user_subscription_group(
&self,
broker_addr: CheetahString,
timeout_millis: u64,
) -> RocketMQResult<SubscriptionGroupWrapper>;
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 probe_name_server(
&self,
name_server: CheetahString,
) -> RocketMQResult<()>;
async fn query_consume_queue(
&self,
broker_addr: CheetahString,
topic: CheetahString,
queue_id: i32,
index: u64,
count: i32,
consumer_group: CheetahString,
) -> RocketMQResult<QueryConsumeQueueResponseBody>;
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 update_and_get_group_read_forbidden(
&self,
broker_addr: CheetahString,
group_name: CheetahString,
topic_name: CheetahString,
readable: Option<bool>,
) -> RocketMQResult<GroupForbidden>;
async fn query_message(
&self,
cluster_name: CheetahString,
topic: CheetahString,
msg_id: CheetahString,
) -> RocketMQResult<MessageExt>;
async fn get_broker_ha_status(
&self,
broker_addr: CheetahString,
) -> RocketMQResult<HARuntimeInfo>;
async fn get_in_sync_state_data(
&self,
controller_address: CheetahString,
brokers: Vec<CheetahString>,
) -> RocketMQResult<BrokerReplicasInfo>;
async fn get_broker_epoch_cache(
&self,
broker_addr: CheetahString,
) -> RocketMQResult<EpochEntryCache>;
async fn get_controller_meta_data(
&self,
controller_addr: CheetahString,
) -> RocketMQResult<GetMetaDataResponseHeader>;
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 elect_master(
&self,
controller_addr: CheetahString,
cluster_name: CheetahString,
broker_name: CheetahString,
broker_id: Option<u64>,
) -> RocketMQResult<(ElectMasterResponseHeader, BrokerMemberGroup)>;
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 create_user_with_info(
&self,
broker_addr: CheetahString,
username: CheetahString,
password: CheetahString,
) -> RocketMQResult<()>;
async fn update_user(
&self,
broker_addr: CheetahString,
username: CheetahString,
password: CheetahString,
user_type: CheetahString,
user_status: CheetahString,
) -> RocketMQResult<()>;
async fn update_user_with_info(
&self,
broker_addr: CheetahString,
username: CheetahString,
password: CheetahString,
) -> RocketMQResult<()>;
async fn delete_user(
&self,
broker_addr: CheetahString,
username: CheetahString,
) -> RocketMQResult<()>;
async fn get_user(
&self,
broker_addr: CheetahString,
username: CheetahString,
) -> RocketMQResult<Option<UserInfo>>;
async fn list_users(
&self,
broker_addr: CheetahString,
filter: CheetahString,
) -> RocketMQResult<Vec<UserInfo>>;
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 create_acl_with_info(
&self,
broker_addr: CheetahString,
subject: 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 update_acl_with_info(
&self,
broker_addr: CheetahString,
subject: CheetahString,
) -> RocketMQResult<()>;
async fn delete_acl(
&self,
broker_addr: CheetahString,
subject: CheetahString,
resource: CheetahString,
) -> RocketMQResult<()>;
async fn get_acl(
&self,
broker_addr: CheetahString,
subject: CheetahString,
) -> RocketMQResult<AclInfo>;
async fn list_acl(
&self,
broker_addr: CheetahString,
subject_filter: CheetahString,
resource_filter: CheetahString,
) -> RocketMQResult<Vec<AclInfo>>;
async fn create_lite_pull_topic(
&self,
addr: CheetahString,
topic: CheetahString,
queue_num: i32,
topic_sys_flag: i32,
read_queue_nums: i32,
write_queue_nums: i32,
) -> RocketMQResult<()>;
async fn update_lite_pull_topic(
&self,
addr: CheetahString,
topic: CheetahString,
read_queue_nums: i32,
write_queue_nums: i32,
) -> RocketMQResult<()>;
async fn get_lite_pull_topic(
&self,
addr: CheetahString,
topic: CheetahString,
) -> RocketMQResult<TopicConfig>;
async fn delete_lite_pull_topic(
&self,
addr: CheetahString,
cluster_name: CheetahString,
topic: CheetahString,
) -> RocketMQResult<()>;
async fn query_lite_pull_topic_list(
&self,
addr: CheetahString,
) -> RocketMQResult<TopicList>;
async fn query_lite_pull_topic_by_cluster(
&self,
cluster_name: CheetahString,
) -> RocketMQResult<TopicList>;
async fn query_lite_pull_subscription_list(
&self,
addr: CheetahString,
topic: CheetahString,
) -> RocketMQResult<GroupList>;
async fn update_lite_pull_consumer_offset(
&self,
addr: CheetahString,
topic: CheetahString,
group: CheetahString,
queue_id: i32,
offset: u64,
) -> RocketMQResult<()>;
async fn examine_consume_stats_with_queue(
&self,
consumer_group: CheetahString,
topic: Option<CheetahString>,
queue_id: Option<i32>,
) -> RocketMQResult<ConsumeStats>;
async fn examine_consume_stats_concurrent(
&self,
consumer_group: CheetahString,
topic: Option<CheetahString>,
) -> AdminToolResult<ConsumeStats>;
async fn examine_consume_stats_concurrent_with_cluster(
&self,
consumer_group: CheetahString,
topic: Option<CheetahString>,
cluster_name: Option<CheetahString>,
) -> AdminToolResult<ConsumeStats>;
async fn export_rocksdb_consumer_offset_to_json(
&self,
broker_addr: CheetahString,
file_path: CheetahString,
) -> RocketMQResult<()>;
async fn export_rocksdb_consumer_offset_from_memory(
&self,
broker_addr: CheetahString,
) -> RocketMQResult<CheetahString>;
async fn sync_broker_member_group(
&self,
controller_addr: CheetahString,
cluster_name: CheetahString,
broker_name: CheetahString,
) -> RocketMQResult<()>;
async fn get_topic_config_by_topic_name(
&self,
broker_addr: CheetahString,
topic_name: CheetahString,
) -> RocketMQResult<TopicConfig>;
async fn notify_min_broker_id_changed(
&self,
cluster_name: CheetahString,
broker_name: CheetahString,
min_broker_id: u64,
min_broker_addr: CheetahString,
offline_broker_addr: Option<CheetahString>,
ha_broker_addr: Option<CheetahString>,
) -> RocketMQResult<()>;
async fn get_topic_stats_info(
&self,
broker_addr: CheetahString,
topic: CheetahString,
) -> RocketMQResult<TopicStatsTable>;
async fn query_broker_has_topic(
&self,
broker_addr: CheetahString,
topic: CheetahString,
) -> RocketMQResult<bool>;
async fn get_system_topic_list_from_broker(
&self,
broker_addr: CheetahString,
) -> RocketMQResult<TopicList>;
async fn examine_topic_route_info_with_timeout(
&self,
topic: CheetahString,
timeout_millis: u64,
) -> RocketMQResult<Option<TopicRouteData>>;
async fn export_pop_records(
&self,
broker_addr: CheetahString,
timeout: u64,
) -> RocketMQResult<()>;
async fn switch_timer_engine(
&self,
broker_addr: CheetahString,
des_timer_engine: CheetahString,
) -> RocketMQResult<()>;
async fn get_broker_lite_info(
&self,
broker_addr: CheetahString,
) -> RocketMQResult<GetBrokerLiteInfoResponseBody>;
async fn get_parent_topic_info(
&self,
broker_addr: CheetahString,
topic: CheetahString,
) -> RocketMQResult<GetParentTopicInfoResponseBody>;
async fn get_lite_topic_info(
&self,
broker_addr: CheetahString,
parent_topic: CheetahString,
lite_topic: CheetahString,
) -> RocketMQResult<GetLiteTopicInfoResponseBody>;
async fn get_lite_client_info(
&self,
broker_addr: CheetahString,
parent_topic: CheetahString,
group: CheetahString,
client_id: CheetahString,
) -> RocketMQResult<GetLiteClientInfoResponseBody>;
async fn get_lite_group_info(
&self,
broker_addr: CheetahString,
group: CheetahString,
lite_topic: CheetahString,
top_k: i32,
) -> RocketMQResult<GetLiteGroupInfoResponseBody>;
async fn trigger_lite_dispatch(
&self,
broker_addr: CheetahString,
group: CheetahString,
client_id: CheetahString,
) -> RocketMQResult<()>;
async fn export_rocksdb_config_to_json(
&self,
broker_addr: CheetahString,
config_types: Vec<CheetahString>,
) -> RocketMQResult<()>;
async fn search_offset(
&self,
broker_addr: CheetahString,
topic_name: CheetahString,
queue_id: i32,
timestamp: u64,
timeout_millis: u64,
) -> RocketMQResult<u64>;
async fn min_offset(
&self,
broker_addr: CheetahString,
message_queue: MessageQueue,
timeout_millis: u64,
) -> RocketMQResult<i64>;
async fn max_offset(
&self,
broker_addr: CheetahString,
message_queue: MessageQueue,
timeout_millis: u64,
) -> RocketMQResult<i64>;
}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 check_rocksdb_cq_write_progress( &self, broker_addr: CheetahString, topic: CheetahString, check_store_time: i64, ) -> RocketMQResult<CheckRocksdbCqWriteResult>
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_all_producer_info( &self, broker_addr: CheetahString, ) -> RocketMQResult<ProducerTableInfo>
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_broker_concurrent( &self, addrs: HashSet<CheetahString>, topic: CheetahString, ) -> AdminToolResult<BrokerOperatorResult>
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_old( &self, cluster_name: Option<CheetahString>, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, force: bool, ) -> RocketMQResult<Vec<RollbackStats>>
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 reset_offset_new_concurrent( &self, group: CheetahString, topic: CheetahString, timestamp: u64, ) -> AdminToolResult<BrokerOperatorResult>
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 query_consume_time_span( &self, topic: CheetahString, group: CheetahString, ) -> RocketMQResult<Vec<QueueTimeSpan>>
async fn query_consume_time_span_concurrent( &self, topic: CheetahString, group: CheetahString, ) -> AdminToolResult<Vec<QueueTimeSpan>>
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 message_track_detail( &self, msg: MessageExt, ) -> RocketMQResult<Vec<MessageTrack>>
async fn message_track_detail_concurrent( &self, msg: MessageExt, ) -> AdminToolResult<Vec<MessageTrack>>
async fn clone_group_offset( &self, src_group: CheetahString, dest_group: CheetahString, topic: CheetahString, is_offline: bool, ) -> RocketMQResult<()>
async fn view_broker_stats_data( &self, broker_addr: CheetahString, stats_name: CheetahString, stats_key: CheetahString, ) -> RocketMQResult<BrokerStatsData>
async fn get_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>
async fn fetch_consume_stats_in_broker( &self, broker_addr: CheetahString, is_order: bool, timeout_millis: u64, ) -> RocketMQResult<ConsumeStatsList>
async fn get_topic_cluster_list( &self, topic: String, ) -> RocketMQResult<HashSet<CheetahString>>
async fn get_all_subscription_group( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> RocketMQResult<SubscriptionGroupWrapper>
async fn get_user_subscription_group( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> RocketMQResult<SubscriptionGroupWrapper>
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 probe_name_server( &self, name_server: CheetahString, ) -> RocketMQResult<()>
async fn query_consume_queue( &self, broker_addr: CheetahString, topic: CheetahString, queue_id: i32, index: u64, count: i32, consumer_group: CheetahString, ) -> RocketMQResult<QueryConsumeQueueResponseBody>
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 update_and_get_group_read_forbidden( &self, broker_addr: CheetahString, group_name: CheetahString, topic_name: CheetahString, readable: Option<bool>, ) -> RocketMQResult<GroupForbidden>
async fn query_message( &self, cluster_name: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> RocketMQResult<MessageExt>
async fn get_broker_ha_status( &self, broker_addr: CheetahString, ) -> RocketMQResult<HARuntimeInfo>
async fn get_in_sync_state_data( &self, controller_address: CheetahString, brokers: Vec<CheetahString>, ) -> RocketMQResult<BrokerReplicasInfo>
async fn get_broker_epoch_cache( &self, broker_addr: CheetahString, ) -> RocketMQResult<EpochEntryCache>
async fn get_controller_meta_data( &self, controller_addr: CheetahString, ) -> RocketMQResult<GetMetaDataResponseHeader>
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 elect_master( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: Option<u64>, ) -> RocketMQResult<(ElectMasterResponseHeader, BrokerMemberGroup)>
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 create_user_with_info( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, ) -> RocketMQResult<()>
async fn update_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, user_status: CheetahString, ) -> RocketMQResult<()>
async fn update_user_with_info( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, ) -> RocketMQResult<()>
async fn delete_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> RocketMQResult<()>
async fn get_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> RocketMQResult<Option<UserInfo>>
async fn list_users( &self, broker_addr: CheetahString, filter: CheetahString, ) -> RocketMQResult<Vec<UserInfo>>
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 create_acl_with_info( &self, broker_addr: CheetahString, subject: 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 update_acl_with_info( &self, broker_addr: CheetahString, subject: CheetahString, ) -> RocketMQResult<()>
async fn delete_acl( &self, broker_addr: CheetahString, subject: CheetahString, resource: CheetahString, ) -> RocketMQResult<()>
async fn get_acl( &self, broker_addr: CheetahString, subject: CheetahString, ) -> RocketMQResult<AclInfo>
async fn list_acl( &self, broker_addr: CheetahString, subject_filter: CheetahString, resource_filter: CheetahString, ) -> RocketMQResult<Vec<AclInfo>>
async fn create_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, queue_num: i32, topic_sys_flag: i32, read_queue_nums: i32, write_queue_nums: i32, ) -> RocketMQResult<()>
async fn update_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, read_queue_nums: i32, write_queue_nums: i32, ) -> RocketMQResult<()>
async fn get_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<TopicConfig>
async fn delete_lite_pull_topic( &self, addr: CheetahString, cluster_name: CheetahString, topic: CheetahString, ) -> RocketMQResult<()>
async fn query_lite_pull_topic_list( &self, addr: CheetahString, ) -> RocketMQResult<TopicList>
async fn query_lite_pull_topic_by_cluster( &self, cluster_name: CheetahString, ) -> RocketMQResult<TopicList>
async fn query_lite_pull_subscription_list( &self, addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<GroupList>
async fn update_lite_pull_consumer_offset( &self, addr: CheetahString, topic: CheetahString, group: CheetahString, queue_id: i32, offset: u64, ) -> RocketMQResult<()>
async fn examine_consume_stats_with_queue( &self, consumer_group: CheetahString, topic: Option<CheetahString>, queue_id: Option<i32>, ) -> RocketMQResult<ConsumeStats>
async fn examine_consume_stats_concurrent( &self, consumer_group: CheetahString, topic: Option<CheetahString>, ) -> AdminToolResult<ConsumeStats>
async fn examine_consume_stats_concurrent_with_cluster( &self, consumer_group: CheetahString, topic: Option<CheetahString>, cluster_name: Option<CheetahString>, ) -> AdminToolResult<ConsumeStats>
async fn export_rocksdb_consumer_offset_to_json( &self, broker_addr: CheetahString, file_path: CheetahString, ) -> RocketMQResult<()>
async fn export_rocksdb_consumer_offset_from_memory( &self, broker_addr: CheetahString, ) -> RocketMQResult<CheetahString>
async fn sync_broker_member_group( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, ) -> RocketMQResult<()>
async fn get_topic_config_by_topic_name( &self, broker_addr: CheetahString, topic_name: CheetahString, ) -> RocketMQResult<TopicConfig>
async fn notify_min_broker_id_changed( &self, cluster_name: CheetahString, broker_name: CheetahString, min_broker_id: u64, min_broker_addr: CheetahString, offline_broker_addr: Option<CheetahString>, ha_broker_addr: Option<CheetahString>, ) -> RocketMQResult<()>
async fn get_topic_stats_info( &self, broker_addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<TopicStatsTable>
async fn query_broker_has_topic( &self, broker_addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<bool>
async fn get_system_topic_list_from_broker( &self, broker_addr: CheetahString, ) -> RocketMQResult<TopicList>
async fn examine_topic_route_info_with_timeout( &self, topic: CheetahString, timeout_millis: u64, ) -> RocketMQResult<Option<TopicRouteData>>
async fn export_pop_records( &self, broker_addr: CheetahString, timeout: u64, ) -> RocketMQResult<()>
async fn switch_timer_engine( &self, broker_addr: CheetahString, des_timer_engine: CheetahString, ) -> RocketMQResult<()>
async fn get_broker_lite_info( &self, broker_addr: CheetahString, ) -> RocketMQResult<GetBrokerLiteInfoResponseBody>
async fn get_parent_topic_info( &self, broker_addr: CheetahString, topic: CheetahString, ) -> RocketMQResult<GetParentTopicInfoResponseBody>
async fn get_lite_topic_info( &self, broker_addr: CheetahString, parent_topic: CheetahString, lite_topic: CheetahString, ) -> RocketMQResult<GetLiteTopicInfoResponseBody>
async fn get_lite_client_info( &self, broker_addr: CheetahString, parent_topic: CheetahString, group: CheetahString, client_id: CheetahString, ) -> RocketMQResult<GetLiteClientInfoResponseBody>
async fn get_lite_group_info( &self, broker_addr: CheetahString, group: CheetahString, lite_topic: CheetahString, top_k: i32, ) -> RocketMQResult<GetLiteGroupInfoResponseBody>
async fn trigger_lite_dispatch( &self, broker_addr: CheetahString, group: CheetahString, client_id: CheetahString, ) -> RocketMQResult<()>
async fn export_rocksdb_config_to_json( &self, broker_addr: CheetahString, config_types: Vec<CheetahString>, ) -> RocketMQResult<()>
async fn search_offset( &self, broker_addr: CheetahString, topic_name: CheetahString, queue_id: i32, timestamp: u64, timeout_millis: u64, ) -> RocketMQResult<u64>
async fn min_offset( &self, broker_addr: CheetahString, message_queue: MessageQueue, timeout_millis: u64, ) -> RocketMQResult<i64>
async fn max_offset( &self, broker_addr: CheetahString, message_queue: MessageQueue, timeout_millis: u64, ) -> RocketMQResult<i64>
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.