Trait MQAdminReadExt 

pub trait MQAdminReadExt: Send {
    // Required methods
    async fn start(&mut self) -> ClientResult<()>;
    async fn shutdown(&mut self);
    async fn fetch_all_topic_list(&self) -> ClientResult<TopicList>;
    async fn fetch_broker_runtime_stats(
        &self,
        broker_addr: CheetahString,
    ) -> ClientResult<KVTable>;
    async fn get_broker_config_allowlisted(
        &self,
        broker_addr: CheetahString,
    ) -> ClientResult<BrokerConfigAllowlisted>;
    async fn proxy_drain_state(
        &self,
        proxy_addr: CheetahString,
    ) -> ClientResult<ProxyDrainStateResponseBody>;
    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_broker_cluster_info(&self) -> ClientResult<ClusterInfo>;
    async fn examine_topic_route_info(
        &self,
        topic: CheetahString,
    ) -> ClientResult<Option<TopicRouteData>>;
    async fn topic_config_with_version(
        &self,
        broker_addr: CheetahString,
        topic: CheetahString,
    ) -> ClientResult<TopicConfigVersioned>;
    async fn subscription_group_config_with_version(
        &self,
        broker_addr: CheetahString,
        group: CheetahString,
    ) -> ClientResult<SubscriptionGroupConfigVersioned>;
    async fn examine_consumer_connection_info(
        &self,
        consumer_group: CheetahString,
        broker_addr: Option<CheetahString>,
    ) -> ClientResult<ConsumerConnection>;
    async fn observe_consumer_connection_at(
        &self,
        consumer_group: CheetahString,
        broker_addr: CheetahString,
    ) -> ClientResult<ConsumerConnection>;
    async fn examine_producer_connection_info(
        &self,
        producer_group: CheetahString,
        topic: CheetahString,
    ) -> ClientResult<ProducerConnection>;
    async fn observe_producer_connection_info(
        &self,
        producer_group: CheetahString,
        topic: CheetahString,
    ) -> ClientResult<ProducerConnection>;
    async fn observe_producer_connection_at(
        &self,
        producer_group: CheetahString,
        broker_addr: CheetahString,
    ) -> ClientResult<ProducerConnection>;
    async fn get_all_producer_info(
        &self,
        broker_addr: CheetahString,
    ) -> ClientResult<ProducerTableInfo>;
    async fn query_topic_consume_by_who(
        &self,
        topic: CheetahString,
    ) -> ClientResult<GroupList>;

    // Provided method
    async fn examine_consume_stats_with_evidence(
        &self,
        consumer_group: CheetahString,
        topic: Option<CheetahString>,
        broker_addr: Option<CheetahString>,
        timeout_millis: Option<u64>,
    ) -> ClientResult<ConsumeStatsReadResult> { ... }
}

Required Methods

async fn start(&mut self) -> ClientResult<()>

async fn shutdown(&mut self)

async fn fetch_all_topic_list(&self) -> ClientResult<TopicList>

async fn fetch_broker_runtime_stats( &self, broker_addr: CheetahString, ) -> ClientResult<KVTable>

async fn get_broker_config_allowlisted( &self, broker_addr: CheetahString, ) -> ClientResult<BrokerConfigAllowlisted>

Reads only the fixed non-sensitive Broker fields evaluated by the SRE generation-CAS action.

async fn proxy_drain_state( &self, proxy_addr: CheetahString, ) -> ClientResult<ProxyDrainStateResponseBody>

Returns the authenticated, bounded drain state for one Proxy endpoint.

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_broker_cluster_info(&self) -> ClientResult<ClusterInfo>

async fn examine_topic_route_info( &self, topic: CheetahString, ) -> ClientResult<Option<TopicRouteData>>

async fn topic_config_with_version( &self, broker_addr: CheetahString, topic: CheetahString, ) -> ClientResult<TopicConfigVersioned>

Reads one Broker’s Topic configuration and metadata version atomically.

async fn subscription_group_config_with_version( &self, broker_addr: CheetahString, group: CheetahString, ) -> ClientResult<SubscriptionGroupConfigVersioned>

Reads one Broker’s Subscription Group configuration and metadata version atomically.

async fn examine_consumer_connection_info( &self, consumer_group: CheetahString, broker_addr: Option<CheetahString>, ) -> ClientResult<ConsumerConnection>

async fn observe_consumer_connection_at( &self, consumer_group: CheetahString, broker_addr: CheetahString, ) -> ClientResult<ConsumerConnection>

Reads one exact target without converting an authoritative empty connection set into a synthetic error or offline inference.

async fn examine_producer_connection_info( &self, producer_group: CheetahString, topic: CheetahString, ) -> ClientResult<ProducerConnection>

async fn observe_producer_connection_info( &self, producer_group: CheetahString, topic: CheetahString, ) -> ClientResult<ProducerConnection>

Reads producer connections without converting an authoritative empty set into a fabricated status or an unavailable observation.

async fn observe_producer_connection_at( &self, producer_group: CheetahString, broker_addr: CheetahString, ) -> ClientResult<ProducerConnection>

Reads producer connections from one exact broker address. An empty connection set is authoritative and is returned unchanged.

async fn get_all_producer_info( &self, broker_addr: CheetahString, ) -> ClientResult<ProducerTableInfo>

async fn query_topic_consume_by_who( &self, topic: CheetahString, ) -> ClientResult<GroupList>

Provided Methods

async fn examine_consume_stats_with_evidence( &self, consumer_group: CheetahString, topic: Option<CheetahString>, broker_addr: Option<CheetahString>, timeout_millis: Option<u64>, ) -> ClientResult<ConsumeStatsReadResult>

Reads consumer statistics without discarding an individual Broker failure. Broker addresses and backend error strings never enter the returned evidence.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl MQAdminReadExt for DefaultMQAdminExt