Skip to main content

MQAdminConsumerObservationReadExt

rocketmq_client_rust

Trait MQAdminConsumerObservationReadExt 

Source 
pub trait MQAdminConsumerObservationReadExt: Send {
    // Required methods
    async fn consumer_group_config_at(
        &self,
        broker_addr: CheetahString,
        consumer_group: CheetahString,
    ) -> ClientResult<ConsumerGroupConfigRead>;
    async fn consumer_connection_at(
        &self,
        broker_addr: CheetahString,
        consumer_group: CheetahString,
    ) -> ClientResult<ConsumerConnectionRead>;
    async fn consumer_progress_at(
        &self,
        broker_addr: CheetahString,
        consumer_group: CheetahString,
    ) -> ClientResult<ConsumerProgressRead>;
}

Required Methods§

Source

async fn consumer_group_config_at( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> ClientResult<ConsumerGroupConfigRead>

Source

async fn consumer_connection_at( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> ClientResult<ConsumerConnectionRead>

Source

async fn consumer_progress_at( &self, broker_addr: CheetahString, consumer_group: CheetahString, ) -> ClientResult<ConsumerProgressRead>

Dyn Compatibility§

This trait is not dyn compatible.

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

Implementors§