feat:support polaris-rust sdk client

Author: chuntaojun

.gitignore

@@ -0,0 +1,2 @@
+/target
+Cargo.lock

.idea/.gitignore

@@ -0,0 +1,16 @@
+[package]
+name = "polaris-rust"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+[dependencies]
+serde = { version = "1.0.198", features = ["derive"] }
+serde_json = "1.0.116"
+serde-duration-ext = "0.1.0"
+schemars = "0.8.16"
+serde_yaml = "0.9.34"
+bytes = {version = "1.4.0"}
+prost = {version = "0.12.4" }
+prost-types = {version = "0.12.4" }
+prost-build = {version = "0.12.4" }

.idea/copyright/polarismesh.xml

@@ -0,0 +1,18 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+//
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+//
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// https://opensource.org/licenses/BSD-3-Clause
+//
+// 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.
+
+pub trait CircuitBreakerAPI {
+
+}

.idea/modules.xml

@@ -0,0 +1,17 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+//
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+//
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// https://opensource.org/licenses/BSD-3-Clause
+//
+// 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.
+
+mod api;
+mod req;

.idea/polaris-rust.iml

@@ -0,0 +1,15 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+//
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+//
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// https://opensource.org/licenses/BSD-3-Clause
+//
+// 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.
+

.idea/vcs.xml

@@ -0,0 +1,22 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+//
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+//
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// https://opensource.org/licenses/BSD-3-Clause
+//
+// 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.
+
+pub trait ConfigFileAPI {
+
+}
+
+pub trait ConfigGroupAPI {
+
+}

Cargo.toml

@@ -0,0 +1,17 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+//
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+//
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// https://opensource.org/licenses/BSD-3-Clause
+//
+// 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.
+
+pub mod api;
+pub mod req;

src/circuitbreaker/api.rs

@@ -0,0 +1,15 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+//
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+//
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// https://opensource.org/licenses/BSD-3-Clause
+//
+// 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.
+

src/circuitbreaker/mod.rs

@@ -0,0 +1,57 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+// 
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+// 
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// 
+// https://opensource.org/licenses/BSD-3-Clause
+// 
+// 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 std::{fs, io};
+use serde::Deserialize;
+use crate::core::config::config_file::ConfigFileConfig;
+use crate::core::config::consumer::ConsumerConfig;
+use crate::core::config::global::GlobalConfig;
+use crate::core::config::provider::ProviderConfig;
+
+#[derive(Deserialize)]
+#[serde(rename_all = "camelCase", deny_unknown_fields)]
+pub struct Configuration {
+    pub global: GlobalConfig,
+    pub consumer: ConsumerConfig,
+    pub provider: ProviderConfig,
+    pub config: ConfigFileConfig,
+}
+
+pub fn load(path: String) -> Result<*const Configuration, io::Error> {
+    let val = fs::read_to_string(path);
+    if val.is_ok() {
+        let data = val.ok().unwrap();
+        let config: Configuration = serde_yaml::from_str(&*data).expect(&format!("failure to format yaml str {}", &data));
+        return Ok(&config)
+    }
+    return Err(val.err().unwrap())
+}
+
+#[cfg(test)]
+mod tests {
+    use std::env;
+    use crate::core::config::config::load;
+
+    #[test]
+    fn test_load() {
+        let ret = load(env::var("TEST_LOAD_FILE").unwrap());
+        if ret.is_ok() {
+            let conf = ret.ok().unwrap();
+            println!("{:?}", conf)
+        } else {
+            println!("{:?}", ret.err().unwrap())
+        }
+    }
+}

src/circuitbreaker/req.rs

@@ -0,0 +1,23 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+// 
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+// 
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// 
+// https://opensource.org/licenses/BSD-3-Clause
+// 
+// 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 serde::Deserialize;
+
+#[derive(Deserialize)]
+#[serde(rename_all = "camelCase", deny_unknown_fields)]
+pub struct ConfigFileConfig {
+    pub properties_value_cache_size: u32,
+    pub properties_value_expire_time: u32,
+}

src/config/api.rs

@@ -0,0 +1,54 @@
+// Tencent is pleased to support the open source community by making Polaris available.
+// 
+// Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+// 
+// Licensed under the BSD 3-Clause License (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// 
+// https://opensource.org/licenses/BSD-3-Clause
+// 
+// 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 std::time::Duration;
+use schemars::Map;
+use serde::Deserialize;
+
+#[derive(Deserialize)]
+#[serde(rename_all = "camelCase", deny_unknown_fields)]
+pub struct ConsumerConfig {
+    pub service_router: ServiceRouterConfig,
+    pub circuit_breaker: CircuitBreakerConfig,
+    pub load_balancer: LoadBalancerConfig,
+}
+
+#[derive(Deserialize)]
+#[serde(rename_all = "camelCase", deny_unknown_fields)]
+pub struct ServiceRouterConfig {
+    pub before_chain: Vec<ServiceRouterPluginConfig>,
+    pub core_chain: Vec<ServiceRouterPluginConfig>,
+    pub after_chain: Vec<ServiceRouterPluginConfig>,
+}
+
+#[derive(Deserialize)]
+#[serde(rename_all = "camelCase", deny_unknown_fields)]
+pub struct ServiceRouterPluginConfig {
+    pub name: String,
+    pub options: Option<Map<String, String>>
+}
+
+#[derive(Deserialize)]
+#[serde(rename_all = "camelCase", deny_unknown_fields)]
+pub struct LoadBalancerConfig {
+    pub plugins: Option<Vec<String>>
+}
+
+#[derive(Deserialize)]
+#[serde(rename_all = "camelCase", deny_unknown_fields)]
+pub struct CircuitBreakerConfig {
+    pub enable: bool,
+    pub enable_remote_pull: bool,
+}