Fix: cargo fix

dubbo/src/directory/mod.rs

@@ -32,7 +32,6 @@ use crate::{
 };
 use dubbo_base::Url;
 use dubbo_logger::tracing::{debug, error};
-use futures_core::ready;
 use futures_util::future;
 use tokio::sync::mpsc::channel;
 use tokio_stream::wrappers::ReceiverStream;

dubbo/src/extension/registry_extension.rs

@@ -180,7 +180,7 @@ pub mod proxy {
     use thiserror::Error;
     use tokio::sync::oneshot;
 
-    use crate::extension::Extension;
+
     use dubbo_base::Url;
     use dubbo_logger::tracing::error;
 

dubbo/src/framework.rs

@@ -19,12 +19,11 @@ use std::{
     collections::HashMap,
     error::Error,
     pin::Pin,
-    sync::{Arc, Mutex},
 };
 
 use crate::{
     extension,
-    extension::registry_extension::{proxy::RegistryProxy, Registry},
+    extension::registry_extension::{Registry},
     protocol::{BoxExporter, Protocol},
     registry::protocol::RegistryProtocol,
 };

dubbo/src/invoker/mod.rs

@@ -1,4 +1,3 @@
-use dubbo_base::Url;
 
 use crate::{codegen::TripleInvoker, invoker::clone_invoker::CloneInvoker, svc::NewService};
 

dubbo/src/registry/protocol.rs

@@ -22,7 +22,6 @@ use std::{
     sync::{Arc, RwLock},
 };
 
-use super::n_registry::StaticRegistry;
 use crate::{
     extension::registry_extension::{proxy::RegistryProxy, InterfaceName, Registry},
     protocol::{

dubbo/src/registry/types.rs

@@ -15,12 +15,7 @@
  * limitations under the License.
  */
 
-use std::{
-    collections::HashMap,
-    sync::{Arc, Mutex},
-};
 
-use itertools::Itertools;
 
 //
 // pub type Registries = Arc<Mutex<HashMap<String, ArcRegistry>>>;

examples/greeter/src/greeter/server.rs

@@ -18,9 +18,8 @@
 use std::{io::ErrorKind, pin::Pin};
 
 use async_trait::async_trait;
-use dubbo_base::Url;
 use futures_util::{Stream, StreamExt};
-use registry_nacos::{NacosRegistry, NacosRegistryExtensionLoader};
+use registry_nacos::NacosRegistry;
 use tokio::sync::mpsc;
 use tokio_stream::wrappers::ReceiverStream;
 
@@ -34,8 +33,6 @@ use protos::{
     greeter_server::{register_server, Greeter},
     GreeterReply, GreeterRequest,
 };
-use registry_zookeeper::ZookeeperRegistry;
-
 pub mod protos {
     #![allow(non_camel_case_types)]
     include!(concat!(env!("OUT_DIR"), "/org.apache.dubbo.sample.tri.rs"));

registry/nacos/src/lib.rs

@@ -19,30 +19,26 @@ mod utils;
 use async_trait::async_trait;
 use dubbo_base::Url;
 use std::{collections::HashMap, sync::Arc};
-use tokio::{select, sync::mpsc};
+use tokio::{sync::mpsc};
 
-use anyhow::anyhow;
 use dubbo::{
     extension::{
         registry_extension::{
-            proxy::RegistryProxy, AppName, Category, DiscoverStream, Group, InterfaceName,
+            AppName, Category, DiscoverStream, Group, InterfaceName,
             Registry, RegistryUrl, ServiceChange, ServiceNamespace, Version,
         },
         Extension,
     },
     StdError,
 };
 use dubbo_base::url::UrlParam;
-use dubbo_logger::tracing::{debug, error, info};
+use dubbo_logger::tracing::info;
 use nacos_sdk::api::{
     naming::{NamingEventListener, NamingService, NamingServiceBuilder, ServiceInstance},
     props::ClientProps,
 };
 use tokio::sync::{watch, Notify};
 
-use crate::utils::{build_nacos_client_props, is_concrete_str, is_wildcard_str, match_range};
-
-pub struct NacosRegistryExtensionLoader;
 
 pub struct NacosRegistry {
     url: Url,
@@ -418,6 +414,7 @@ pub mod tests {
 
     use core::time;
     use std::thread;
+    use tracing::error;
 
     use dubbo::extension::{registry_extension::Side, ExtensionName};
     use tracing::metadata::LevelFilter;