pub trait MQAdminExt: Sync + Send {
Show 78 methods
// Required methods
fn start(&mut self) -> impl Future<Output = RocketMQResult<()>> + Send;
fn shutdown(&mut self) -> impl Future<Output = ()> + Send;
fn add_broker_to_container(
&self,
broker_container_addr: CheetahString,
broker_config: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn remove_broker_from_container(
&self,
broker_container_addr: CheetahString,
cluster_name: CheetahString,
broker_name: CheetahString,
broker_id: u64,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn update_broker_config(
&self,
broker_addr: CheetahString,
properties: HashMap<CheetahString, CheetahString>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn get_broker_config(
&self,
broker_addr: CheetahString,
) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, CheetahString>>> + Send;
fn create_and_update_topic_config(
&self,
addr: CheetahString,
config: TopicConfig,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn create_and_update_topic_config_list(
&self,
addr: CheetahString,
topic_config_list: Vec<TopicConfig>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn create_and_update_plain_access_config(
&self,
addr: CheetahString,
config: PlainAccessConfig,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn delete_plain_access_config(
&self,
addr: CheetahString,
access_key: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn update_global_white_addr_config(
&self,
addr: CheetahString,
global_white_addrs: CheetahString,
acl_file_full_path: Option<CheetahString>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn examine_broker_cluster_acl_version_info(
&self,
addr: CheetahString,
) -> impl Future<Output = RocketMQResult<CheetahString>> + Send;
fn create_and_update_subscription_group_config(
&self,
addr: CheetahString,
config: SubscriptionGroupConfig,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn create_and_update_subscription_group_config_list(
&self,
broker_addr: CheetahString,
configs: Vec<SubscriptionGroupConfig>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn examine_subscription_group_config(
&self,
addr: CheetahString,
group: CheetahString,
) -> impl Future<Output = RocketMQResult<SubscriptionGroupConfig>> + Send;
fn examine_topic_stats(
&self,
topic: CheetahString,
broker_addr: Option<CheetahString>,
) -> impl Future<Output = RocketMQResult<TopicStatsTable>> + Send;
fn examine_topic_stats_concurrent(
&self,
topic: CheetahString,
) -> impl Future<Output = AdminToolResult<TopicStatsTable>> + Send;
fn fetch_all_topic_list(
&self,
) -> impl Future<Output = RocketMQResult<TopicList>> + Send;
fn fetch_topics_by_cluster(
&self,
cluster_name: CheetahString,
) -> impl Future<Output = RocketMQResult<TopicList>> + Send;
fn fetch_broker_runtime_stats(
&self,
broker_addr: CheetahString,
) -> impl Future<Output = RocketMQResult<KVTable>> + Send;
fn examine_consume_stats(
&self,
consumer_group: CheetahString,
topic: Option<CheetahString>,
cluster_name: Option<CheetahString>,
broker_addr: Option<CheetahString>,
timeout_millis: Option<u64>,
) -> impl Future<Output = RocketMQResult<ConsumeStats>> + Send;
fn examine_broker_cluster_info(
&self,
) -> impl Future<Output = RocketMQResult<ClusterInfo>> + Send;
fn examine_topic_route_info(
&self,
topic: CheetahString,
) -> impl Future<Output = RocketMQResult<Option<TopicRouteData>>> + Send;
fn examine_consumer_connection_info(
&self,
consumer_group: CheetahString,
broker_addr: Option<CheetahString>,
) -> impl Future<Output = RocketMQResult<ConsumerConnection>> + Send;
fn examine_producer_connection_info(
&self,
producer_group: CheetahString,
topic: CheetahString,
) -> impl Future<Output = RocketMQResult<ProducerConnection>> + Send;
fn get_name_server_address_list(
&self,
) -> impl Future<Output = Vec<CheetahString>> + Send;
fn wipe_write_perm_of_broker(
&self,
namesrv_addr: CheetahString,
broker_name: CheetahString,
) -> impl Future<Output = RocketMQResult<i32>> + Send;
fn add_write_perm_of_broker(
&self,
namesrv_addr: CheetahString,
broker_name: CheetahString,
) -> impl Future<Output = RocketMQResult<i32>> + Send;
fn put_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
value: CheetahString,
) -> impl Future<Output = ()> + Send;
fn get_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
) -> impl Future<Output = RocketMQResult<CheetahString>> + Send;
fn get_kv_list_by_namespace(
&self,
namespace: CheetahString,
) -> impl Future<Output = RocketMQResult<KVTable>> + Send;
fn delete_topic(
&self,
topic_name: CheetahString,
cluster_name: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn delete_topic_in_broker(
&self,
addrs: HashSet<CheetahString>,
topic: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn delete_topic_in_name_server(
&self,
addrs: HashSet<CheetahString>,
cluster_name: Option<CheetahString>,
topic: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn delete_subscription_group(
&self,
addr: CheetahString,
group_name: CheetahString,
remove_offset: Option<bool>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn create_and_update_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
value: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn delete_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn reset_offset_by_timestamp(
&self,
cluster_name: Option<CheetahString>,
topic: CheetahString,
group: CheetahString,
timestamp: u64,
is_force: bool,
) -> impl Future<Output = RocketMQResult<HashMap<MessageQueue, u64>>> + Send;
fn reset_offset_new(
&self,
consumer_group: CheetahString,
topic: CheetahString,
timestamp: u64,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn get_consume_status(
&self,
topic: CheetahString,
group: CheetahString,
client_addr: CheetahString,
) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, HashMap<MessageQueue, u64>>>> + Send;
fn create_or_update_order_conf(
&self,
key: CheetahString,
value: CheetahString,
is_cluster: bool,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn query_topic_consume_by_who(
&self,
topic: CheetahString,
) -> impl Future<Output = RocketMQResult<GroupList>> + Send;
fn query_topics_by_consumer(
&self,
group: CheetahString,
) -> impl Future<Output = RocketMQResult<TopicList>> + Send;
fn query_topics_by_consumer_concurrent(
&self,
group: CheetahString,
) -> impl Future<Output = AdminToolResult<TopicList>> + Send;
fn query_subscription(
&self,
group: CheetahString,
topic: CheetahString,
) -> impl Future<Output = RocketMQResult<SubscriptionData>> + Send;
fn clean_expired_consumer_queue(
&self,
cluster: Option<CheetahString>,
addr: Option<CheetahString>,
) -> impl Future<Output = RocketMQResult<bool>> + Send;
fn delete_expired_commit_log(
&self,
cluster: Option<CheetahString>,
addr: Option<CheetahString>,
) -> impl Future<Output = RocketMQResult<bool>> + Send;
fn clean_unused_topic(
&self,
cluster: Option<CheetahString>,
addr: Option<CheetahString>,
) -> impl Future<Output = RocketMQResult<bool>> + Send;
fn get_consumer_running_info(
&self,
consumer_group: CheetahString,
client_id: CheetahString,
jstack: bool,
metrics: Option<bool>,
) -> impl Future<Output = RocketMQResult<ConsumerRunningInfo>> + Send;
fn consume_message_directly(
&self,
consumer_group: CheetahString,
client_id: CheetahString,
topic: CheetahString,
msg_id: CheetahString,
) -> impl Future<Output = RocketMQResult<ConsumeMessageDirectlyResult>> + Send;
fn consume_message_directly_ext(
&self,
cluster_name: CheetahString,
consumer_group: CheetahString,
client_id: CheetahString,
topic: CheetahString,
msg_id: CheetahString,
) -> impl Future<Output = RocketMQResult<ConsumeMessageDirectlyResult>> + Send;
fn clone_group_offset(
&self,
src_group: CheetahString,
dest_group: CheetahString,
topic: CheetahString,
is_offline: bool,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn get_cluster_list(
&self,
topic: String,
) -> impl Future<Output = RocketMQResult<HashSet<CheetahString>>> + Send;
fn get_topic_cluster_list(
&self,
topic: String,
) -> impl Future<Output = RocketMQResult<HashSet<CheetahString>>> + Send;
fn get_all_topic_config(
&self,
broker_addr: CheetahString,
timeout_millis: u64,
) -> impl Future<Output = RocketMQResult<TopicConfigSerializeWrapper>> + Send;
fn get_user_topic_config(
&self,
broker_addr: CheetahString,
special_topic: bool,
timeout_millis: u64,
) -> impl Future<Output = RocketMQResult<TopicConfigSerializeWrapper>> + Send;
fn update_consume_offset(
&self,
broker_addr: CheetahString,
consume_group: CheetahString,
mq: MessageQueue,
offset: u64,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn update_name_server_config(
&self,
properties: HashMap<CheetahString, CheetahString>,
name_servers: Vec<CheetahString>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn get_name_server_config(
&self,
name_servers: Vec<CheetahString>,
) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>> + Send;
fn resume_check_half_message(
&self,
topic: CheetahString,
msg_id: CheetahString,
) -> impl Future<Output = RocketMQResult<bool>> + Send;
fn set_message_request_mode(
&self,
broker_addr: CheetahString,
topic: CheetahString,
consumer_group: CheetahString,
mode: MessageRequestMode,
pop_work_group_size: i32,
timeout_millis: u64,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn reset_offset_by_queue_id(
&self,
broker_addr: CheetahString,
consumer_group: CheetahString,
topic_name: CheetahString,
queue_id: i32,
reset_offset: u64,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn examine_topic_config(
&self,
addr: CheetahString,
topic: CheetahString,
) -> impl Future<Output = RocketMQResult<TopicConfig>> + Send;
fn create_static_topic(
&self,
addr: CheetahString,
default_topic: CheetahString,
topic_config: TopicConfig,
mapping_detail: TopicQueueMappingDetail,
force: bool,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn reset_master_flush_offset(
&self,
broker_addr: CheetahString,
master_flush_offset: u64,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn get_controller_config(
&self,
controller_servers: Vec<CheetahString>,
) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>> + Send;
fn update_controller_config(
&self,
properties: HashMap<CheetahString, CheetahString>,
controllers: Vec<CheetahString>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
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,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn update_cold_data_flow_ctr_group_config(
&self,
broker_addr: CheetahString,
properties: HashMap<CheetahString, CheetahString>,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn remove_cold_data_flow_ctr_group_config(
&self,
broker_addr: CheetahString,
consumer_group: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn get_cold_data_flow_ctr_info(
&self,
broker_addr: CheetahString,
) -> impl Future<Output = RocketMQResult<CheetahString>> + Send;
fn set_commit_log_read_ahead_mode(
&self,
broker_addr: CheetahString,
mode: CheetahString,
) -> impl Future<Output = RocketMQResult<CheetahString>> + Send;
fn create_user(
&self,
broker_addr: CheetahString,
username: CheetahString,
password: CheetahString,
user_type: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn update_user(
&self,
broker_addr: CheetahString,
username: CheetahString,
password: CheetahString,
user_type: CheetahString,
user_status: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn delete_user(
&self,
broker_addr: CheetahString,
username: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn create_acl(
&self,
broker_addr: CheetahString,
subject: CheetahString,
resources: Vec<CheetahString>,
actions: Vec<CheetahString>,
source_ips: Vec<CheetahString>,
decision: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn update_acl(
&self,
broker_addr: CheetahString,
subject: CheetahString,
resources: Vec<CheetahString>,
actions: Vec<CheetahString>,
source_ips: Vec<CheetahString>,
decision: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
fn delete_acl(
&self,
broker_addr: CheetahString,
subject: CheetahString,
resource: CheetahString,
) -> impl Future<Output = RocketMQResult<()>> + Send;
}Required Methods§
fn start(&mut self) -> impl Future<Output = RocketMQResult<()>> + Send
fn shutdown(&mut self) -> impl Future<Output = ()> + Send
fn add_broker_to_container( &self, broker_container_addr: CheetahString, broker_config: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn remove_broker_from_container( &self, broker_container_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: u64, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn update_broker_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn get_broker_config( &self, broker_addr: CheetahString, ) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, CheetahString>>> + Send
fn create_and_update_topic_config( &self, addr: CheetahString, config: TopicConfig, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn create_and_update_topic_config_list( &self, addr: CheetahString, topic_config_list: Vec<TopicConfig>, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn create_and_update_plain_access_config( &self, addr: CheetahString, config: PlainAccessConfig, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn delete_plain_access_config( &self, addr: CheetahString, access_key: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn update_global_white_addr_config( &self, addr: CheetahString, global_white_addrs: CheetahString, acl_file_full_path: Option<CheetahString>, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn examine_broker_cluster_acl_version_info( &self, addr: CheetahString, ) -> impl Future<Output = RocketMQResult<CheetahString>> + Send
fn create_and_update_subscription_group_config( &self, addr: CheetahString, config: SubscriptionGroupConfig, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn create_and_update_subscription_group_config_list( &self, broker_addr: CheetahString, configs: Vec<SubscriptionGroupConfig>, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn examine_subscription_group_config( &self, addr: CheetahString, group: CheetahString, ) -> impl Future<Output = RocketMQResult<SubscriptionGroupConfig>> + Send
fn examine_topic_stats( &self, topic: CheetahString, broker_addr: Option<CheetahString>, ) -> impl Future<Output = RocketMQResult<TopicStatsTable>> + Send
fn examine_topic_stats_concurrent( &self, topic: CheetahString, ) -> impl Future<Output = AdminToolResult<TopicStatsTable>> + Send
fn fetch_all_topic_list( &self, ) -> impl Future<Output = RocketMQResult<TopicList>> + Send
fn fetch_topics_by_cluster( &self, cluster_name: CheetahString, ) -> impl Future<Output = RocketMQResult<TopicList>> + Send
fn fetch_broker_runtime_stats( &self, broker_addr: CheetahString, ) -> impl Future<Output = RocketMQResult<KVTable>> + Send
fn examine_consume_stats( &self, consumer_group: CheetahString, topic: Option<CheetahString>, cluster_name: Option<CheetahString>, broker_addr: Option<CheetahString>, timeout_millis: Option<u64>, ) -> impl Future<Output = RocketMQResult<ConsumeStats>> + Send
fn examine_broker_cluster_info( &self, ) -> impl Future<Output = RocketMQResult<ClusterInfo>> + Send
fn examine_topic_route_info( &self, topic: CheetahString, ) -> impl Future<Output = RocketMQResult<Option<TopicRouteData>>> + Send
fn examine_consumer_connection_info( &self, consumer_group: CheetahString, broker_addr: Option<CheetahString>, ) -> impl Future<Output = RocketMQResult<ConsumerConnection>> + Send
fn examine_producer_connection_info( &self, producer_group: CheetahString, topic: CheetahString, ) -> impl Future<Output = RocketMQResult<ProducerConnection>> + Send
fn get_name_server_address_list( &self, ) -> impl Future<Output = Vec<CheetahString>> + Send
fn wipe_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> impl Future<Output = RocketMQResult<i32>> + Send
fn add_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> impl Future<Output = RocketMQResult<i32>> + Send
fn put_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, ) -> impl Future<Output = ()> + Send
fn get_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> impl Future<Output = RocketMQResult<CheetahString>> + Send
fn get_kv_list_by_namespace( &self, namespace: CheetahString, ) -> impl Future<Output = RocketMQResult<KVTable>> + Send
fn delete_topic( &self, topic_name: CheetahString, cluster_name: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn delete_topic_in_broker( &self, addrs: HashSet<CheetahString>, topic: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn delete_topic_in_name_server( &self, addrs: HashSet<CheetahString>, cluster_name: Option<CheetahString>, topic: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn delete_subscription_group( &self, addr: CheetahString, group_name: CheetahString, remove_offset: Option<bool>, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn create_and_update_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn delete_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn reset_offset_by_timestamp( &self, cluster_name: Option<CheetahString>, topic: CheetahString, group: CheetahString, timestamp: u64, is_force: bool, ) -> impl Future<Output = RocketMQResult<HashMap<MessageQueue, u64>>> + Send
fn reset_offset_new( &self, consumer_group: CheetahString, topic: CheetahString, timestamp: u64, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn get_consume_status( &self, topic: CheetahString, group: CheetahString, client_addr: CheetahString, ) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, HashMap<MessageQueue, u64>>>> + Send
fn create_or_update_order_conf( &self, key: CheetahString, value: CheetahString, is_cluster: bool, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn query_topic_consume_by_who( &self, topic: CheetahString, ) -> impl Future<Output = RocketMQResult<GroupList>> + Send
fn query_topics_by_consumer( &self, group: CheetahString, ) -> impl Future<Output = RocketMQResult<TopicList>> + Send
fn query_topics_by_consumer_concurrent( &self, group: CheetahString, ) -> impl Future<Output = AdminToolResult<TopicList>> + Send
fn query_subscription( &self, group: CheetahString, topic: CheetahString, ) -> impl Future<Output = RocketMQResult<SubscriptionData>> + Send
fn clean_expired_consumer_queue( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> impl Future<Output = RocketMQResult<bool>> + Send
fn delete_expired_commit_log( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> impl Future<Output = RocketMQResult<bool>> + Send
fn clean_unused_topic( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> impl Future<Output = RocketMQResult<bool>> + Send
fn get_consumer_running_info( &self, consumer_group: CheetahString, client_id: CheetahString, jstack: bool, metrics: Option<bool>, ) -> impl Future<Output = RocketMQResult<ConsumerRunningInfo>> + Send
fn consume_message_directly( &self, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> impl Future<Output = RocketMQResult<ConsumeMessageDirectlyResult>> + Send
fn consume_message_directly_ext( &self, cluster_name: CheetahString, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> impl Future<Output = RocketMQResult<ConsumeMessageDirectlyResult>> + Send
fn clone_group_offset( &self, src_group: CheetahString, dest_group: CheetahString, topic: CheetahString, is_offline: bool, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn get_cluster_list( &self, topic: String, ) -> impl Future<Output = RocketMQResult<HashSet<CheetahString>>> + Send
fn get_topic_cluster_list( &self, topic: String, ) -> impl Future<Output = RocketMQResult<HashSet<CheetahString>>> + Send
fn get_all_topic_config( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> impl Future<Output = RocketMQResult<TopicConfigSerializeWrapper>> + Send
fn get_user_topic_config( &self, broker_addr: CheetahString, special_topic: bool, timeout_millis: u64, ) -> impl Future<Output = RocketMQResult<TopicConfigSerializeWrapper>> + Send
fn update_consume_offset( &self, broker_addr: CheetahString, consume_group: CheetahString, mq: MessageQueue, offset: u64, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn update_name_server_config( &self, properties: HashMap<CheetahString, CheetahString>, name_servers: Vec<CheetahString>, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn get_name_server_config( &self, name_servers: Vec<CheetahString>, ) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>> + Send
fn resume_check_half_message( &self, topic: CheetahString, msg_id: CheetahString, ) -> impl Future<Output = RocketMQResult<bool>> + Send
fn set_message_request_mode( &self, broker_addr: CheetahString, topic: CheetahString, consumer_group: CheetahString, mode: MessageRequestMode, pop_work_group_size: i32, timeout_millis: u64, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn reset_offset_by_queue_id( &self, broker_addr: CheetahString, consumer_group: CheetahString, topic_name: CheetahString, queue_id: i32, reset_offset: u64, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn examine_topic_config( &self, addr: CheetahString, topic: CheetahString, ) -> impl Future<Output = RocketMQResult<TopicConfig>> + Send
fn create_static_topic( &self, addr: CheetahString, default_topic: CheetahString, topic_config: TopicConfig, mapping_detail: TopicQueueMappingDetail, force: bool, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn reset_master_flush_offset( &self, broker_addr: CheetahString, master_flush_offset: u64, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn get_controller_config( &self, controller_servers: Vec<CheetahString>, ) -> impl Future<Output = RocketMQResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>> + Send
fn update_controller_config( &self, properties: HashMap<CheetahString, CheetahString>, controllers: Vec<CheetahString>, ) -> impl Future<Output = RocketMQResult<()>> + Send
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, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn update_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn remove_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn get_cold_data_flow_ctr_info( &self, broker_addr: CheetahString, ) -> impl Future<Output = RocketMQResult<CheetahString>> + Send
fn set_commit_log_read_ahead_mode( &self, broker_addr: CheetahString, mode: CheetahString, ) -> impl Future<Output = RocketMQResult<CheetahString>> + Send
fn create_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn update_user( &self, broker_addr: CheetahString, username: CheetahString, password: CheetahString, user_type: CheetahString, user_status: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn delete_user( &self, broker_addr: CheetahString, username: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn create_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn update_acl( &self, broker_addr: CheetahString, subject: CheetahString, resources: Vec<CheetahString>, actions: Vec<CheetahString>, source_ips: Vec<CheetahString>, decision: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
fn delete_acl( &self, broker_addr: CheetahString, subject: CheetahString, resource: CheetahString, ) -> impl Future<Output = RocketMQResult<()>> + Send
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.