pub trait TopicAdmin: Send {
Show 36 methods
// Required methods
async fn create_and_update_topic_config(
&self,
addr: CheetahString,
config: TopicConfig,
) -> ClientResult<()>;
async fn create_and_update_topic_config_list(
&self,
addr: CheetahString,
topic_config_list: Vec<TopicConfig>,
) -> ClientResult<()>;
async fn examine_topic_stats(
&self,
topic: CheetahString,
broker_addr: Option<CheetahString>,
) -> ClientResult<TopicStatsTable>;
async fn examine_topic_stats_concurrent(
&self,
topic: CheetahString,
) -> AdminToolResult<TopicStatsTable>;
async fn fetch_all_topic_list(&self) -> ClientResult<TopicList>;
async fn fetch_topics_by_cluster(
&self,
cluster_name: CheetahString,
) -> ClientResult<TopicList>;
async fn examine_topic_route_info(
&self,
topic: CheetahString,
) -> ClientResult<Option<TopicRouteData>>;
async fn delete_topic(
&self,
topic_name: CheetahString,
cluster_name: CheetahString,
) -> ClientResult<()>;
async fn delete_topic_in_broker(
&self,
addrs: HashSet<CheetahString>,
topic: CheetahString,
) -> ClientResult<()>;
async fn delete_topic_in_broker_list(
&self,
addrs: HashSet<CheetahString>,
topics: Vec<CheetahString>,
) -> ClientResult<()>;
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,
) -> ClientResult<()>;
async fn create_or_update_order_conf(
&self,
key: CheetahString,
value: CheetahString,
is_cluster: bool,
) -> ClientResult<()>;
async fn query_topic_consume_by_who(
&self,
topic: CheetahString,
) -> ClientResult<GroupList>;
async fn query_topics_by_consumer(
&self,
group: CheetahString,
) -> ClientResult<TopicList>;
async fn query_topics_by_consumer_concurrent(
&self,
group: CheetahString,
) -> AdminToolResult<TopicList>;
async fn clean_unused_topic(
&self,
cluster: Option<CheetahString>,
addr: Option<CheetahString>,
) -> ClientResult<bool>;
async fn clean_unused_topic_by_addr(
&self,
addr: CheetahString,
) -> ClientResult<bool>;
async fn get_topic_cluster_list(
&self,
topic: String,
) -> ClientResult<HashSet<CheetahString>>;
async fn get_all_topic_config(
&self,
broker_addr: CheetahString,
timeout_millis: u64,
) -> ClientResult<TopicConfigSerializeWrapper>;
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,
) -> ClientResult<()>;
async fn examine_topic_config(
&self,
addr: CheetahString,
topic: CheetahString,
) -> ClientResult<TopicConfig>;
async fn create_static_topic(
&self,
addr: CheetahString,
default_topic: CheetahString,
topic_config: TopicConfig,
mapping_detail: TopicQueueMappingDetail,
force: bool,
) -> ClientResult<()>;
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,
) -> ClientResult<()>;
async fn update_lite_pull_topic(
&self,
addr: CheetahString,
topic: CheetahString,
read_queue_nums: i32,
write_queue_nums: i32,
) -> ClientResult<()>;
async fn get_lite_pull_topic(
&self,
addr: CheetahString,
topic: CheetahString,
) -> ClientResult<TopicConfig>;
async fn delete_lite_pull_topic(
&self,
addr: CheetahString,
cluster_name: CheetahString,
topic: CheetahString,
) -> ClientResult<()>;
async fn query_lite_pull_topic_list(
&self,
addr: CheetahString,
) -> ClientResult<TopicList>;
async fn query_lite_pull_topic_by_cluster(
&self,
cluster_name: CheetahString,
) -> ClientResult<TopicList>;
async fn get_topic_config_by_topic_name(
&self,
broker_addr: CheetahString,
topic_name: CheetahString,
) -> ClientResult<TopicConfig>;
async fn get_topic_stats_info(
&self,
broker_addr: CheetahString,
topic: CheetahString,
) -> ClientResult<TopicStatsTable>;
async fn query_broker_has_topic(
&self,
broker_addr: CheetahString,
topic: CheetahString,
) -> ClientResult<bool>;
async fn get_system_topic_list_from_broker(
&self,
broker_addr: CheetahString,
) -> ClientResult<TopicList>;
async fn examine_topic_route_info_with_timeout(
&self,
topic: CheetahString,
timeout_millis: u64,
) -> ClientResult<Option<TopicRouteData>>;
async fn get_parent_topic_info(
&self,
broker_addr: CheetahString,
topic: CheetahString,
) -> ClientResult<GetParentTopicInfoResponseBody>;
async fn get_lite_topic_info(
&self,
broker_addr: CheetahString,
parent_topic: CheetahString,
lite_topic: CheetahString,
) -> ClientResult<GetLiteTopicInfoResponseBody>;
}Required Methods§
async fn create_and_update_topic_config( &self, addr: CheetahString, config: TopicConfig, ) -> ClientResult<()>
async fn create_and_update_topic_config_list( &self, addr: CheetahString, topic_config_list: Vec<TopicConfig>, ) -> ClientResult<()>
async fn examine_topic_stats( &self, topic: CheetahString, broker_addr: Option<CheetahString>, ) -> ClientResult<TopicStatsTable>
async fn examine_topic_stats_concurrent( &self, topic: CheetahString, ) -> AdminToolResult<TopicStatsTable>
async fn fetch_all_topic_list(&self) -> ClientResult<TopicList>
async fn fetch_topics_by_cluster( &self, cluster_name: CheetahString, ) -> ClientResult<TopicList>
async fn examine_topic_route_info( &self, topic: CheetahString, ) -> ClientResult<Option<TopicRouteData>>
async fn delete_topic( &self, topic_name: CheetahString, cluster_name: CheetahString, ) -> ClientResult<()>
async fn delete_topic_in_broker( &self, addrs: HashSet<CheetahString>, topic: CheetahString, ) -> ClientResult<()>
async fn delete_topic_in_broker_list( &self, addrs: HashSet<CheetahString>, topics: Vec<CheetahString>, ) -> ClientResult<()>
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, ) -> ClientResult<()>
async fn create_or_update_order_conf( &self, key: CheetahString, value: CheetahString, is_cluster: bool, ) -> ClientResult<()>
async fn query_topic_consume_by_who( &self, topic: CheetahString, ) -> ClientResult<GroupList>
async fn query_topics_by_consumer( &self, group: CheetahString, ) -> ClientResult<TopicList>
async fn query_topics_by_consumer_concurrent( &self, group: CheetahString, ) -> AdminToolResult<TopicList>
async fn clean_unused_topic( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> ClientResult<bool>
async fn clean_unused_topic_by_addr( &self, addr: CheetahString, ) -> ClientResult<bool>
async fn get_topic_cluster_list( &self, topic: String, ) -> ClientResult<HashSet<CheetahString>>
async fn get_all_topic_config( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> ClientResult<TopicConfigSerializeWrapper>
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, ) -> ClientResult<()>
async fn examine_topic_config( &self, addr: CheetahString, topic: CheetahString, ) -> ClientResult<TopicConfig>
async fn create_static_topic( &self, addr: CheetahString, default_topic: CheetahString, topic_config: TopicConfig, mapping_detail: TopicQueueMappingDetail, force: bool, ) -> ClientResult<()>
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, ) -> ClientResult<()>
async fn update_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, read_queue_nums: i32, write_queue_nums: i32, ) -> ClientResult<()>
async fn get_lite_pull_topic( &self, addr: CheetahString, topic: CheetahString, ) -> ClientResult<TopicConfig>
async fn delete_lite_pull_topic( &self, addr: CheetahString, cluster_name: CheetahString, topic: CheetahString, ) -> ClientResult<()>
async fn query_lite_pull_topic_list( &self, addr: CheetahString, ) -> ClientResult<TopicList>
async fn query_lite_pull_topic_by_cluster( &self, cluster_name: CheetahString, ) -> ClientResult<TopicList>
async fn get_topic_config_by_topic_name( &self, broker_addr: CheetahString, topic_name: CheetahString, ) -> ClientResult<TopicConfig>
async fn get_topic_stats_info( &self, broker_addr: CheetahString, topic: CheetahString, ) -> ClientResult<TopicStatsTable>
async fn query_broker_has_topic( &self, broker_addr: CheetahString, topic: CheetahString, ) -> ClientResult<bool>
async fn get_system_topic_list_from_broker( &self, broker_addr: CheetahString, ) -> ClientResult<TopicList>
async fn examine_topic_route_info_with_timeout( &self, topic: CheetahString, timeout_millis: u64, ) -> ClientResult<Option<TopicRouteData>>
async fn get_parent_topic_info( &self, broker_addr: CheetahString, topic: CheetahString, ) -> ClientResult<GetParentTopicInfoResponseBody>
async fn get_lite_topic_info( &self, broker_addr: CheetahString, parent_topic: CheetahString, lite_topic: CheetahString, ) -> ClientResult<GetLiteTopicInfoResponseBody>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".