Skip to main content

MQAdminInfrastructureObservationReadExt

rocketmq_client_rust

Trait MQAdminInfrastructureObservationReadExt 

Source 
pub trait MQAdminInfrastructureObservationReadExt: Send {
    // Required methods
    async fn broker_ha_runtime_at(
        &self,
        broker_endpoint: CheetahString,
    ) -> Result<HARuntimeInfo, InfrastructureObservationReadError>;
    async fn controller_sync_state_at(
        &self,
        controller_endpoint: CheetahString,
        broker_names: Vec<CheetahString>,
    ) -> Result<BrokerReplicasInfo, InfrastructureObservationReadError>;
    async fn controller_metadata_at(
        &self,
        controller_endpoint: CheetahString,
    ) -> Result<GetMetaDataResponseHeader, InfrastructureObservationReadError>;
    async fn nameserver_config_at(
        &self,
        nameserver_endpoint: CheetahString,
    ) -> Result<HashMap<CheetahString, CheetahString>, InfrastructureObservationReadError>;
}
Expand description

Additive read-only access to four existing exact-target admin RPCs.

Target endpoints are accepted only from trusted adapters. Neither returned errors nor their Debug representation retain endpoint or remote detail.

Required Methods§

Source

async fn broker_ha_runtime_at( &self, broker_endpoint: CheetahString, ) -> Result<HARuntimeInfo, InfrastructureObservationReadError>

Source

async fn controller_sync_state_at( &self, controller_endpoint: CheetahString, broker_names: Vec<CheetahString>, ) -> Result<BrokerReplicasInfo, InfrastructureObservationReadError>

Source

async fn controller_metadata_at( &self, controller_endpoint: CheetahString, ) -> Result<GetMetaDataResponseHeader, InfrastructureObservationReadError>

Source

async fn nameserver_config_at( &self, nameserver_endpoint: CheetahString, ) -> Result<HashMap<CheetahString, CheetahString>, InfrastructureObservationReadError>

Dyn Compatibility§

This trait is not dyn compatible.

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

Implementors§