Feat: cluster and extension

.github/workflows/github-actions.yml

@@ -6,9 +6,10 @@ on:
   push:
     branches: ["*"]
   pull_request:
-    branches: ["*"]
+    branches:
+    - '*'
+    - 'refact/*'
 
-  workflow_dispatch:
 
 jobs:
   check:
@@ -59,6 +60,13 @@ jobs:
           - 2181:2181
         env:
           ZOO_MY_ID: 1
+      nacos:
+        image: nacos/nacos-server:v2.3.1
+        ports:
+          - 8848:8848
+          - 9848:9848
+        env:
+          MODE: standalone
     steps:
       - uses: actions/checkout@main
       - uses: actions-rs/toolchain@v1

Cargo.toml

@@ -1,4 +1,5 @@
 [workspace]
+resolver = "2"
 members = [
   "common/logger",
   "common/utils",
@@ -59,5 +60,7 @@ itertools = "0.10.1"
 bytes = "1.0"
 prost-serde = "0.3.0"
 prost-serde-derive = "0.1.2"
+url = "2.5.0"
+
 
 

application.yaml

@@ -21,4 +21,9 @@ dubbo:
     references:
       GreeterClientImpl:
         url: tri://localhost:20000
-        protocol: tri
+        protocol: tri
+  routers:
+    consumer:
+      - service: "org.apache.dubbo.sample.tri.Greeter"
+        url: tri://127.0.0.1:20000
+        protocol: triple

common/base/Cargo.toml

@@ -6,6 +6,5 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-urlencoding.workspace = true
-http = "0.2"
-dubbo-logger.workspace = true
+dubbo-logger.workspace = true
+url.workspace = true

common/base/src/extension_param.rs

@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+use crate::{url::UrlParam, StdError};
+use std::{borrow::Cow, convert::Infallible, str::FromStr};
+
+pub struct ExtensionName(String);
+
+impl ExtensionName {
+    pub fn new(name: String) -> Self {
+        ExtensionName(name)
+    }
+}
+
+impl UrlParam for ExtensionName {
+    type TargetType = String;
+
+    fn name() -> &'static str {
+        "extension-name"
+    }
+
+    fn value(&self) -> Self::TargetType {
+        self.0.clone()
+    }
+
+    fn as_str(&self) -> Cow<str> {
+        self.0.as_str().into()
+    }
+}
+
+impl FromStr for ExtensionName {
+    type Err = StdError;
+
+    fn from_str(s: &str) -> Result<Self, Self::Err> {
+        Ok(ExtensionName::new(s.to_string()))
+    }
+}
+
+pub enum ExtensionType {
+    Registry,
+}
+
+impl UrlParam for ExtensionType {
+    type TargetType = String;
+
+    fn name() -> &'static str {
+        "extension-type"
+    }
+
+    fn value(&self) -> Self::TargetType {
+        match self {
+            ExtensionType::Registry => "registry".to_owned(),
+        }
+    }
+
+    fn as_str(&self) -> Cow<str> {
+        match self {
+            ExtensionType::Registry => Cow::Borrowed("registry"),
+        }
+    }
+}
+
+impl FromStr for ExtensionType {
+    type Err = Infallible;
+
+    fn from_str(s: &str) -> Result<Self, Self::Err> {
+        match s {
+            "registry" => Ok(ExtensionType::Registry),
+            _ => panic!("the extension type enum is not in range"),
+        }
+    }
+}

common/base/src/lib.rs

@@ -19,8 +19,12 @@
     allow(dead_code, unused_imports, unused_variables, unused_mut)
 )]
 pub mod constants;
+pub mod extension_param;
 pub mod node;
+pub mod registry_param;
 pub mod url;
 
 pub use node::Node;
 pub use url::Url;
+
+pub type StdError = Box<dyn std::error::Error + Send + Sync + 'static>;