pub trait ConsumerAdmin: Send {
Show 31 methods
// Required methods
async fn create_and_update_subscription_group_config(
&self,
addr: CheetahString,
config: SubscriptionGroupConfig,
) -> ClientResult<()>;
async fn create_and_update_subscription_group_config_list(
&self,
broker_addr: CheetahString,
configs: Vec<SubscriptionGroupConfig>,
) -> ClientResult<()>;
async fn examine_subscription_group_config(
&self,
addr: CheetahString,
group: CheetahString,
) -> ClientResult<SubscriptionGroupConfig>;
async fn examine_consume_stats(
&self,
consumer_group: CheetahString,
topic: Option<CheetahString>,
cluster_name: Option<CheetahString>,
broker_addr: Option<CheetahString>,
timeout_millis: Option<u64>,
) -> ClientResult<ConsumeStats>;
async fn examine_consumer_connection_info(
&self,
consumer_group: CheetahString,
broker_addr: Option<CheetahString>,
) -> ClientResult<ConsumerConnection>;
async fn examine_producer_connection_info(
&self,
producer_group: CheetahString,
topic: CheetahString,
) -> ClientResult<ProducerConnection>;
async fn get_all_producer_info(
&self,
broker_addr: CheetahString,
) -> ClientResult<ProducerTableInfo>;
async fn delete_subscription_group(
&self,
addr: CheetahString,
group_name: CheetahString,
remove_offset: Option<bool>,
) -> ClientResult<()>;
async fn delete_subscription_group_list(
&self,
addr: CheetahString,
group_names: Vec<CheetahString>,
clean_offset: bool,
) -> ClientResult<()>;
async fn get_consume_status(
&self,
topic: CheetahString,
group: CheetahString,
client_addr: CheetahString,
) -> ClientResult<HashMap<CheetahString, HashMap<MessageQueue, u64>>>;
async fn query_subscription(
&self,
group: CheetahString,
topic: CheetahString,
) -> ClientResult<SubscriptionData>;
async fn clean_expired_consumer_queue(
&self,
cluster: Option<CheetahString>,
addr: Option<CheetahString>,
) -> ClientResult<bool>;
async fn clean_expired_consumer_queue_by_addr(
&self,
addr: CheetahString,
) -> ClientResult<bool>;
async fn get_consumer_running_info(
&self,
consumer_group: CheetahString,
client_id: CheetahString,
jstack: bool,
metrics: Option<bool>,
) -> ClientResult<ConsumerRunningInfo>;
async fn consume_message_directly(
&self,
consumer_group: CheetahString,
client_id: CheetahString,
topic: CheetahString,
msg_id: CheetahString,
) -> ClientResult<ConsumeMessageDirectlyResult>;
async fn consume_message_directly_ext(
&self,
cluster_name: CheetahString,
consumer_group: CheetahString,
client_id: CheetahString,
topic: CheetahString,
msg_id: CheetahString,
) -> ClientResult<ConsumeMessageDirectlyResult>;
async fn message_track_detail(
&self,
msg: MessageExt,
) -> ClientResult<Vec<MessageTrack>>;
async fn message_track_detail_concurrent(
&self,
msg: MessageExt,
) -> AdminToolResult<Vec<MessageTrack>>;
async fn fetch_consume_stats_in_broker(
&self,
broker_addr: CheetahString,
is_order: bool,
timeout_millis: u64,
) -> ClientResult<ConsumeStatsList>;
async fn get_all_subscription_group(
&self,
broker_addr: CheetahString,
timeout_millis: u64,
) -> ClientResult<SubscriptionGroupWrapper>;
async fn query_consume_queue(
&self,
broker_addr: CheetahString,
topic: CheetahString,
queue_id: i32,
index: u64,
count: i32,
consumer_group: CheetahString,
) -> ClientResult<QueryConsumeQueueResponseBody>;
async fn update_and_get_group_read_forbidden(
&self,
broker_addr: CheetahString,
group_name: CheetahString,
topic_name: CheetahString,
readable: Option<bool>,
) -> ClientResult<GroupForbidden>;
async fn query_message(
&self,
cluster_name: CheetahString,
topic: CheetahString,
msg_id: CheetahString,
) -> ClientResult<MessageExt>;
async fn update_cold_data_flow_ctr_group_config(
&self,
broker_addr: CheetahString,
properties: HashMap<CheetahString, CheetahString>,
) -> ClientResult<()>;
async fn remove_cold_data_flow_ctr_group_config(
&self,
broker_addr: CheetahString,
consumer_group: CheetahString,
) -> ClientResult<()>;
async fn query_lite_pull_subscription_list(
&self,
addr: CheetahString,
topic: CheetahString,
) -> ClientResult<GroupList>;
async fn examine_consume_stats_with_queue(
&self,
consumer_group: CheetahString,
topic: Option<CheetahString>,
queue_id: Option<i32>,
) -> ClientResult<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 sync_broker_member_group(
&self,
controller_addr: CheetahString,
cluster_name: CheetahString,
broker_name: CheetahString,
) -> ClientResult<()>;
async fn get_lite_group_info(
&self,
broker_addr: CheetahString,
group: CheetahString,
lite_topic: CheetahString,
top_k: i32,
) -> ClientResult<GetLiteGroupInfoResponseBody>;
}Required Methods§
async fn create_and_update_subscription_group_config( &self, addr: CheetahString, config: SubscriptionGroupConfig, ) -> ClientResult<()>
async fn create_and_update_subscription_group_config_list( &self, broker_addr: CheetahString, configs: Vec<SubscriptionGroupConfig>, ) -> ClientResult<()>
async fn examine_subscription_group_config( &self, addr: CheetahString, group: CheetahString, ) -> ClientResult<SubscriptionGroupConfig>
async fn examine_consume_stats( &self, consumer_group: CheetahString, topic: Option<CheetahString>, cluster_name: Option<CheetahString>, broker_addr: Option<CheetahString>, timeout_millis: Option<u64>, ) -> ClientResult<ConsumeStats>
async fn examine_consumer_connection_info( &self, consumer_group: CheetahString, broker_addr: Option<CheetahString>, ) -> ClientResult<ConsumerConnection>
async fn examine_producer_connection_info( &self, producer_group: CheetahString, topic: CheetahString, ) -> ClientResult<ProducerConnection>
async fn get_all_producer_info( &self, broker_addr: CheetahString, ) -> ClientResult<ProducerTableInfo>
async fn delete_subscription_group( &self, addr: CheetahString, group_name: CheetahString, remove_offset: Option<bool>, ) -> ClientResult<()>
async fn delete_subscription_group_list( &self, addr: CheetahString, group_names: Vec<CheetahString>, clean_offset: bool, ) -> ClientResult<()>
async fn get_consume_status( &self, topic: CheetahString, group: CheetahString, client_addr: CheetahString, ) -> ClientResult<HashMap<CheetahString, HashMap<MessageQueue, u64>>>
async fn query_subscription( &self, group: CheetahString, topic: CheetahString, ) -> ClientResult<SubscriptionData>
async fn clean_expired_consumer_queue( &self, cluster: Option<CheetahString>, addr: Option<CheetahString>, ) -> ClientResult<bool>
async fn clean_expired_consumer_queue_by_addr( &self, addr: CheetahString, ) -> ClientResult<bool>
async fn get_consumer_running_info( &self, consumer_group: CheetahString, client_id: CheetahString, jstack: bool, metrics: Option<bool>, ) -> ClientResult<ConsumerRunningInfo>
async fn consume_message_directly( &self, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> ClientResult<ConsumeMessageDirectlyResult>
async fn consume_message_directly_ext( &self, cluster_name: CheetahString, consumer_group: CheetahString, client_id: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> ClientResult<ConsumeMessageDirectlyResult>
async fn message_track_detail( &self, msg: MessageExt, ) -> ClientResult<Vec<MessageTrack>>
async fn message_track_detail_concurrent( &self, msg: MessageExt, ) -> AdminToolResult<Vec<MessageTrack>>
async fn fetch_consume_stats_in_broker( &self, broker_addr: CheetahString, is_order: bool, timeout_millis: u64, ) -> ClientResult<ConsumeStatsList>
async fn get_all_subscription_group( &self, broker_addr: CheetahString, timeout_millis: u64, ) -> ClientResult<SubscriptionGroupWrapper>
async fn query_consume_queue( &self, broker_addr: CheetahString, topic: CheetahString, queue_id: i32, index: u64, count: i32, consumer_group: CheetahString, ) -> ClientResult<QueryConsumeQueueResponseBody>
async fn update_and_get_group_read_forbidden( &self, broker_addr: CheetahString, group_name: CheetahString, topic_name: CheetahString, readable: Option<bool>, ) -> ClientResult<GroupForbidden>
async fn query_message( &self, cluster_name: CheetahString, topic: CheetahString, msg_id: CheetahString, ) -> ClientResult<MessageExt>
async fn update_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> ClientResult<()>
async fn remove_cold_data_flow_ctr_group_config( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> ClientResult<()>
async fn query_lite_pull_subscription_list( &self, addr: CheetahString, topic: CheetahString, ) -> ClientResult<GroupList>
async fn examine_consume_stats_with_queue( &self, consumer_group: CheetahString, topic: Option<CheetahString>, queue_id: Option<i32>, ) -> ClientResult<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 sync_broker_member_group( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, ) -> ClientResult<()>
async fn get_lite_group_info( &self, broker_addr: CheetahString, group: CheetahString, lite_topic: CheetahString, top_k: i32, ) -> ClientResult<GetLiteGroupInfoResponseBody>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".