pub trait RouteAdmin: Send {
// Required methods
async fn examine_broker_cluster_info(&self) -> ClientResult<ClusterInfo>;
async fn get_name_server_address_list(&self) -> Vec<CheetahString>;
async fn put_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
value: CheetahString,
);
async fn get_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
) -> ClientResult<CheetahString>;
async fn get_kv_list_by_namespace(
&self,
namespace: CheetahString,
) -> ClientResult<KVTable>;
async fn create_and_update_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
value: CheetahString,
) -> ClientResult<()>;
async fn delete_kv_config(
&self,
namespace: CheetahString,
key: CheetahString,
) -> ClientResult<()>;
async fn get_cluster_list(
&self,
topic: String,
) -> ClientResult<HashSet<CheetahString>>;
async fn update_name_server_config(
&self,
properties: HashMap<CheetahString, CheetahString>,
name_servers: Option<Vec<CheetahString>>,
) -> ClientResult<()>;
async fn get_name_server_config(
&self,
name_servers: Vec<CheetahString>,
) -> ClientResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>;
async fn probe_name_server(
&self,
name_server: CheetahString,
) -> ClientResult<()>;
}Required Methods§
async fn examine_broker_cluster_info(&self) -> ClientResult<ClusterInfo>
async fn get_name_server_address_list(&self) -> Vec<CheetahString>
async fn put_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, )
async fn get_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> ClientResult<CheetahString>
async fn get_kv_list_by_namespace( &self, namespace: CheetahString, ) -> ClientResult<KVTable>
async fn create_and_update_kv_config( &self, namespace: CheetahString, key: CheetahString, value: CheetahString, ) -> ClientResult<()>
async fn delete_kv_config( &self, namespace: CheetahString, key: CheetahString, ) -> ClientResult<()>
async fn get_cluster_list( &self, topic: String, ) -> ClientResult<HashSet<CheetahString>>
async fn update_name_server_config( &self, properties: HashMap<CheetahString, CheetahString>, name_servers: Option<Vec<CheetahString>>, ) -> ClientResult<()>
async fn get_name_server_config( &self, name_servers: Vec<CheetahString>, ) -> ClientResult<HashMap<CheetahString, HashMap<CheetahString, CheetahString>>>
async fn probe_name_server( &self, name_server: CheetahString, ) -> ClientResult<()>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".