pub trait BrokerAdmin: Send {
Show 28 methods
// Required methods
async fn start(&mut self) -> ClientResult<()>;
async fn shutdown(&mut self);
async fn add_broker_to_container(
&self,
broker_container_addr: CheetahString,
broker_config: CheetahString,
) -> ClientResult<()>;
async fn remove_broker_from_container(
&self,
broker_container_addr: CheetahString,
cluster_name: CheetahString,
broker_name: CheetahString,
broker_id: u64,
) -> ClientResult<()>;
async fn update_broker_config(
&self,
broker_addr: CheetahString,
properties: HashMap<CheetahString, CheetahString>,
) -> ClientResult<()>;
async fn get_broker_config(
&self,
broker_addr: CheetahString,
) -> ClientResult<HashMap<CheetahString, CheetahString>>;
async fn fetch_broker_runtime_stats(
&self,
broker_addr: CheetahString,
) -> ClientResult<KVTable>;
async fn check_rocksdb_cq_write_progress(
&self,
broker_addr: CheetahString,
topic: CheetahString,
check_store_time: i64,
) -> ClientResult<CheckRocksdbCqWriteResult>;
async fn wipe_write_perm_of_broker(
&self,
namesrv_addr: CheetahString,
broker_name: CheetahString,
) -> ClientResult<i32>;
async fn add_write_perm_of_broker(
&self,
namesrv_addr: CheetahString,
broker_name: CheetahString,
) -> ClientResult<i32>;
async fn view_broker_stats_data(
&self,
broker_addr: CheetahString,
stats_name: CheetahString,
stats_key: CheetahString,
) -> ClientResult<BrokerStatsData>;
async fn resume_check_half_message(
&self,
topic: CheetahString,
msg_id: CheetahString,
) -> ClientResult<bool>;
async fn get_broker_ha_status(
&self,
broker_addr: CheetahString,
) -> ClientResult<HARuntimeInfo>;
async fn get_in_sync_state_data(
&self,
controller_address: CheetahString,
brokers: Vec<CheetahString>,
) -> ClientResult<BrokerReplicasInfo>;
async fn get_broker_epoch_cache(
&self,
broker_addr: CheetahString,
) -> ClientResult<EpochEntryCache>;
async fn get_controller_meta_data(
&self,
controller_addr: CheetahString,
) -> ClientResult<GetMetaDataResponseHeader>;
async fn get_controller_config(
&self,
controller_servers: Vec<CheetahString>,
) -> ClientResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>;
async fn update_controller_config(
&self,
properties: HashMap<CheetahString, CheetahString>,
controllers: Vec<CheetahString>,
) -> ClientResult<()>;
async fn elect_master(
&self,
controller_addr: CheetahString,
cluster_name: CheetahString,
broker_name: CheetahString,
broker_id: Option<u64>,
) -> ClientResult<(ElectMasterResponseHeader, BrokerMemberGroup)>;
async fn clean_controller_broker_data(
&self,
controller_addr: CheetahString,
cluster_name: CheetahString,
broker_name: CheetahString,
broker_controller_ids_to_clean: Option<CheetahString>,
is_clean_living_broker: bool,
) -> ClientResult<()>;
async fn get_cold_data_flow_ctr_info(
&self,
broker_addr: CheetahString,
) -> ClientResult<CheetahString>;
async fn notify_min_broker_id_changed(
&self,
cluster_name: CheetahString,
broker_name: CheetahString,
min_broker_id: u64,
min_broker_addr: CheetahString,
offline_broker_addr: Option<CheetahString>,
ha_broker_addr: Option<CheetahString>,
) -> ClientResult<()>;
async fn export_pop_records(
&self,
broker_addr: CheetahString,
timeout: u64,
) -> ClientResult<()>;
async fn switch_timer_engine(
&self,
broker_addr: CheetahString,
des_timer_engine: CheetahString,
) -> ClientResult<()>;
async fn get_broker_lite_info(
&self,
broker_addr: CheetahString,
) -> ClientResult<GetBrokerLiteInfoResponseBody>;
async fn get_lite_client_info(
&self,
broker_addr: CheetahString,
parent_topic: CheetahString,
group: CheetahString,
client_id: CheetahString,
) -> ClientResult<GetLiteClientInfoResponseBody>;
async fn trigger_lite_dispatch(
&self,
broker_addr: CheetahString,
group: CheetahString,
client_id: CheetahString,
) -> ClientResult<()>;
async fn export_rocksdb_config_to_json(
&self,
broker_addr: CheetahString,
config_types: Vec<CheetahString>,
) -> ClientResult<()>;
}Required Methods§
async fn start(&mut self) -> ClientResult<()>
async fn shutdown(&mut self)
async fn add_broker_to_container( &self, broker_container_addr: CheetahString, broker_config: CheetahString, ) -> ClientResult<()>
async fn remove_broker_from_container( &self, broker_container_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: u64, ) -> ClientResult<()>
async fn update_broker_config( &self, broker_addr: CheetahString, properties: HashMap<CheetahString, CheetahString>, ) -> ClientResult<()>
async fn get_broker_config( &self, broker_addr: CheetahString, ) -> ClientResult<HashMap<CheetahString, CheetahString>>
async fn fetch_broker_runtime_stats( &self, broker_addr: CheetahString, ) -> ClientResult<KVTable>
async fn check_rocksdb_cq_write_progress( &self, broker_addr: CheetahString, topic: CheetahString, check_store_time: i64, ) -> ClientResult<CheckRocksdbCqWriteResult>
async fn wipe_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> ClientResult<i32>
async fn add_write_perm_of_broker( &self, namesrv_addr: CheetahString, broker_name: CheetahString, ) -> ClientResult<i32>
async fn view_broker_stats_data( &self, broker_addr: CheetahString, stats_name: CheetahString, stats_key: CheetahString, ) -> ClientResult<BrokerStatsData>
async fn resume_check_half_message( &self, topic: CheetahString, msg_id: CheetahString, ) -> ClientResult<bool>
async fn get_broker_ha_status( &self, broker_addr: CheetahString, ) -> ClientResult<HARuntimeInfo>
async fn get_in_sync_state_data( &self, controller_address: CheetahString, brokers: Vec<CheetahString>, ) -> ClientResult<BrokerReplicasInfo>
async fn get_broker_epoch_cache( &self, broker_addr: CheetahString, ) -> ClientResult<EpochEntryCache>
async fn get_controller_meta_data( &self, controller_addr: CheetahString, ) -> ClientResult<GetMetaDataResponseHeader>
async fn get_controller_config( &self, controller_servers: Vec<CheetahString>, ) -> ClientResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>
async fn update_controller_config( &self, properties: HashMap<CheetahString, CheetahString>, controllers: Vec<CheetahString>, ) -> ClientResult<()>
async fn elect_master( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_id: Option<u64>, ) -> ClientResult<(ElectMasterResponseHeader, BrokerMemberGroup)>
async fn clean_controller_broker_data( &self, controller_addr: CheetahString, cluster_name: CheetahString, broker_name: CheetahString, broker_controller_ids_to_clean: Option<CheetahString>, is_clean_living_broker: bool, ) -> ClientResult<()>
async fn get_cold_data_flow_ctr_info( &self, broker_addr: CheetahString, ) -> ClientResult<CheetahString>
async fn notify_min_broker_id_changed( &self, cluster_name: CheetahString, broker_name: CheetahString, min_broker_id: u64, min_broker_addr: CheetahString, offline_broker_addr: Option<CheetahString>, ha_broker_addr: Option<CheetahString>, ) -> ClientResult<()>
async fn export_pop_records( &self, broker_addr: CheetahString, timeout: u64, ) -> ClientResult<()>
async fn switch_timer_engine( &self, broker_addr: CheetahString, des_timer_engine: CheetahString, ) -> ClientResult<()>
async fn get_broker_lite_info( &self, broker_addr: CheetahString, ) -> ClientResult<GetBrokerLiteInfoResponseBody>
async fn get_lite_client_info( &self, broker_addr: CheetahString, parent_topic: CheetahString, group: CheetahString, client_id: CheetahString, ) -> ClientResult<GetLiteClientInfoResponseBody>
async fn trigger_lite_dispatch( &self, broker_addr: CheetahString, group: CheetahString, client_id: CheetahString, ) -> ClientResult<()>
async fn export_rocksdb_config_to_json( &self, broker_addr: CheetahString, config_types: Vec<CheetahString>, ) -> ClientResult<()>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".