fix:polaris-rust clippy

Author: chuntaojun

src/core/plugin/plugins.rs

@@ -198,7 +198,6 @@ pub struct PluginContainer {
     load_balancers: HashMap<String, fn() -> Box<dyn LoadBalancer>>,
 }
 
-
 impl PluginContainer {
     pub fn register_all_plugin(&mut self) {
         self.register_resource_cache();
@@ -298,8 +297,6 @@ pub fn acquire_client_id(conf: Arc<Configuration>) -> String {
                 uuid::Uuid::new_v4().to_string()
             }
         }
-        Err(_err) => {
-            uuid::Uuid::new_v4().to_string()
-        }
+        Err(_err) => uuid::Uuid::new_v4().to_string(),
     }
 }

src/discovery/default.rs

@@ -201,7 +201,6 @@ impl ConsumerAPI for DefaultConsumerAPI {
         check_ret?;
 
         let engine = self.context.get_engine();
-        
 
         engine.get_service_instances(req, false).await
     }
@@ -225,9 +224,7 @@ impl ConsumerAPI for DefaultConsumerAPI {
         let mut watchers = self.watchers.watchers.write().await;
 
         let watch_key = req.get_key();
-        let items = watchers
-            .entry(watch_key.clone())
-            .or_insert_with(Vec::new);
+        let items = watchers.entry(watch_key.clone()).or_insert_with(Vec::new);
 
         items.push(InstanceWatcher { req });
         Ok(WatchInstanceResponse {})

src/plugins/cache/memory/memory.rs

@@ -30,7 +30,7 @@ use crate::core::plugin::cache::{
     Action, Filter, InitResourceCacheOption, ResourceCache, ResourceListener,
 };
 use crate::core::plugin::connector::{Connector, ResourceHandler};
-use crate::core::plugin::plugins::{Plugin};
+use crate::core::plugin::plugins::Plugin;
 use std::collections::HashMap;
 use std::sync::Arc;
 
@@ -419,7 +419,7 @@ impl ResourceCache for MemoryCache {
                 let waiter = {
                     let safe_map = self.handler.router_rules.read().await;
                     let cache_val = safe_map.get(&search_key).unwrap();
-                    
+
                     cache_val.wait_initialize(filter.timeout).await
                 };
                 waiter();
@@ -459,7 +459,7 @@ impl ResourceCache for MemoryCache {
                 let waiter = {
                     let safe_map = self.handler.ratelimit_rules.read().await;
                     let cache_val = safe_map.get(&search_key).unwrap();
-                    
+
                     cache_val.wait_initialize(filter.timeout).await
                 };
                 waiter();
@@ -495,7 +495,7 @@ impl ResourceCache for MemoryCache {
                 let waiter = {
                     let safe_map = self.handler.circuitbreaker_rules.read().await;
                     let cache_val = safe_map.get(&search_key).unwrap();
-                    
+
                     cache_val.wait_initialize(filter.timeout).await
                 };
                 waiter();
@@ -531,7 +531,7 @@ impl ResourceCache for MemoryCache {
                 let waiter = {
                     let safe_map = self.handler.faultdetect_rules.read().await;
                     let cache_val = safe_map.get(&search_key).unwrap();
-                    
+
                     cache_val.wait_initialize(filter.timeout).await
                 };
                 waiter();
@@ -576,7 +576,7 @@ impl ResourceCache for MemoryCache {
         let waiter = {
             let safe_map = self.handler.services.read().await;
             let cache_val = safe_map.get(&search_key).unwrap();
-            
+
             cache_val.wait_initialize(filter.timeout).await
         };
         waiter();
@@ -620,7 +620,7 @@ impl ResourceCache for MemoryCache {
         let waiter = {
             let safe_map = self.handler.instances.read().await;
             let cache_val = safe_map.get(&search_key).unwrap();
-            
+
             cache_val.wait_initialize(filter.timeout).await
         };
         waiter();
@@ -662,7 +662,7 @@ impl ResourceCache for MemoryCache {
         let waiter = {
             let safe_map = self.handler.config_files.read().await;
             let cache_val = safe_map.get(&search_key).unwrap();
-            
+
             cache_val.wait_initialize(filter.timeout).await
         };
         waiter();
@@ -712,7 +712,7 @@ impl ResourceCache for MemoryCache {
         let waiter = {
             let safe_map = self.handler.config_groups.read().await;
             let cache_val = safe_map.get(&search_key).unwrap();
-            
+
             cache_val.wait_initialize(filter.timeout).await
         };
         waiter();

src/plugins/connector/grpc/connector.rs

@@ -32,7 +32,7 @@ use std::collections::HashMap;
 use std::str::FromStr;
 use std::sync::Arc;
 use std::thread::sleep;
-use std::time::{Duration};
+use std::time::Duration;
 use tokio::runtime::Runtime;
 use tokio::sync::mpsc::{self, UnboundedReceiver, UnboundedSender};
 use tokio::sync::RwLock;
@@ -68,11 +68,6 @@ fn new_connector(opt: InitConnectorOption) -> Box<dyn Connector> {
     let conf = &opt.conf.global.server_connectors.clone();
     let (discover_channel, config_channel) = create_channel(conf);
 
-    let client_id = opt.client_id.clone();
-
-    let connect_timeout = conf.connect_timeout;
-    let server_switch_interval = conf.server_switch_interval;
-
     let discover_grpc_client = create_discover_grpc_client(discover_channel.clone());
     let config_grpc_client = create_config_grpc_client(config_channel.clone());
 
@@ -154,15 +149,9 @@ fn create_channel(conf: &ServerConnectorConfig) -> (Channel, Channel) {
 
     for ele in addresses {
         if ele.starts_with("discover://") {
-            discover_address.push(format!(
-                "http://{}",
-                ele.trim_start_matches("discover://")
-            ));
+            discover_address.push(format!("http://{}", ele.trim_start_matches("discover://")));
         } else if ele.starts_with("config://") {
-            config_address.push(format!(
-                "http://{}",
-                ele.trim_start_matches("config://")
-            ));
+            config_address.push(format!("http://{}", ele.trim_start_matches("config://")));
         }
     }
 

src/router/default.rs

@@ -52,12 +52,7 @@ impl RouterAPI for DefaultRouterAPI {
         let mut lb_policy = criteria.policy.clone();
 
         if lb_policy.is_empty() {
-            lb_policy.clone_from(&self
-                .context
-                .conf
-                .consumer
-                .load_balancer
-                .default_policy);
+            lb_policy.clone_from(&self.context.conf.consumer.load_balancer.default_policy);
         }
 
         let lb = self