balancer: rename MonolithDiscovery to MonolithDiscoverer (dyc3#1172)

Author: dyc3

crates/ott-balancer-bin/src/discovery.rs

@@ -71,7 +71,7 @@ impl<'de> Deserialize<'de> for HostOrIp {
 }
 
 #[async_trait]
-pub trait MonolithDiscovery {
+pub trait MonolithDiscoverer {
     /// In polling mode, this function should immediately return the current list of monoliths. In continuous mode, this function should wait until the list of monoliths changes, then return the new list.
     async fn discover(&mut self) -> anyhow::Result<Vec<MonolithConnectionConfig>>;
     fn mode(&self) -> DiscoveryMode;
@@ -83,15 +83,15 @@ pub enum DiscoveryMode {
 }
 
 pub struct DiscoveryTask {
-    discovery: Box<dyn MonolithDiscovery + Send + Sync>,
+    discovery: Box<dyn MonolithDiscoverer + Send + Sync>,
 
     monoliths: HashSet<MonolithConnectionConfig>,
     discovery_tx: tokio::sync::mpsc::Sender<MonolithDiscoveryMsg>,
 }
 
 impl DiscoveryTask {
     pub fn new(
-        discovery: impl MonolithDiscovery + Send + Sync + 'static,
+        discovery: impl MonolithDiscoverer + Send + Sync + 'static,
         discovery_tx: tokio::sync::mpsc::Sender<MonolithDiscoveryMsg>,
     ) -> Self {
         Self {
@@ -148,7 +148,7 @@ fn build_discovery_msg(
 }
 
 pub fn start_discovery_task(
-    discovery: impl MonolithDiscovery + Send + Sync + 'static,
+    discovery: impl MonolithDiscoverer + Send + Sync + 'static,
     discovery_tx: tokio::sync::mpsc::Sender<MonolithDiscoveryMsg>,
 ) -> JoinHandle<()> {
     tokio::task::Builder::new()

crates/ott-balancer-bin/src/discovery/fly.rs

@@ -28,7 +28,7 @@ impl FlyMonolithDiscoverer {
 }
 
 #[async_trait]
-impl MonolithDiscovery for FlyMonolithDiscoverer {
+impl MonolithDiscoverer for FlyMonolithDiscoverer {
     async fn discover(&mut self) -> anyhow::Result<Vec<MonolithConnectionConfig>> {
         let resolver =
             TokioAsyncResolver::tokio_from_system_conf().expect("failed to create resolver");

crates/ott-balancer-bin/src/discovery/harness.rs

@@ -82,7 +82,7 @@ impl HarnessMonolithDiscoverer {
 }
 
 #[async_trait]
-impl MonolithDiscovery for HarnessMonolithDiscoverer {
+impl MonolithDiscoverer for HarnessMonolithDiscoverer {
     async fn discover(&mut self) -> anyhow::Result<Vec<MonolithConnectionConfig>> {
         self.updated_rx.recv().await;
         Ok(self

crates/ott-balancer-bin/src/discovery/manual.rs

@@ -23,7 +23,7 @@ impl ManualMonolithDiscoverer {
 }
 
 #[async_trait]
-impl MonolithDiscovery for ManualMonolithDiscoverer {
+impl MonolithDiscoverer for ManualMonolithDiscoverer {
     async fn discover(&mut self) -> anyhow::Result<Vec<MonolithConnectionConfig>> {
         #[allow(clippy::while_immutable_condition)]
         while self.discovered {