Refactor: refactor Cluster component (#165)

* Refactor: refactor Cluster component

- add p2c loadbalance component
- add simple router component
- add replay body component
- add failover component
- add service directory compoent

* Enhance: add cache for routers

Author: onewe

Cargo.toml

@@ -1,4 +1,5 @@
 [workspace]
+resolver = "2"
 members = [
   "common/logger",
   "common/utils",

common/base/src/lib.rs

@@ -23,4 +23,4 @@ pub mod node;
 pub mod url;
 
 pub use node::Node;
-pub use url::Url;
+pub use url::Url;

dubbo-build/src/client.rs

@@ -78,12 +78,6 @@ pub fn generate<T: Service>(
                     }
                 }
 
-                // pub fn build(builder: ClientBuilder) -> Self {
-                //     Self {
-                //         inner: TripleClient::new(builder),
-                //     }
-                // }
-
                 pub fn new(builder: ClientBuilder) -> Self {
                     Self {
                         inner: TripleClient::new(builder),

dubbo/Cargo.toml

@@ -14,13 +14,15 @@ hyper = { version = "0.14.26", features = ["full"] }
 http = "0.2"
 tower-service.workspace = true
 http-body = "0.4.4"
-tower = { workspace = true, features = ["timeout", "ready-cache","discover"] }
+tower = { workspace = true, features = ["timeout", "ready-cache","discover","retry"] }
 futures-util = "0.3.23"
 futures-core ="0.3.23"
 argh = "0.1"
 rustls-pemfile = "1.0.0"
 tokio-rustls="0.23.4"
 tokio = { version = "1.0", features = [ "rt-multi-thread", "time", "fs", "macros", "net", "signal",  "full" ] }
+tokio-util = "0.7.9"
+tokio-stream = "0.1"
 prost = "0.10.4"
 async-trait = "0.1.56"
 tower-layer.workspace = true