You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2022/07/23 14:44:37 UTC
[dubbo-rust] 35/38: style: add license header
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-rust.git
commit 891b189e56deabb413962367c3eb5e2b22d0a5d2
Author: yangyang <96...@qq.com>
AuthorDate: Thu Jul 21 21:47:51 2022 +0800
style: add license header
---
dubbo/src/echo/helloworld.rs | 7 +-
dubbo/src/init.rs | 110 ---------------------------
dubbo/src/protocol/triple/mod.rs | 17 +++++
dubbo/src/protocol/triple/triple_exporter.rs | 17 +++++
dubbo/src/protocol/triple/triple_invoker.rs | 17 +++++
dubbo/src/protocol/triple/triple_protocol.rs | 17 +++++
dubbo/src/protocol/triple/triple_server.rs | 17 +++++
triple/src/codec/prost.rs | 17 +++++
8 files changed, 103 insertions(+), 116 deletions(-)
diff --git a/dubbo/src/echo/helloworld.rs b/dubbo/src/echo/helloworld.rs
index 9497f4b..039ac43 100644
--- a/dubbo/src/echo/helloworld.rs
+++ b/dubbo/src/echo/helloworld.rs
@@ -15,11 +15,6 @@
* limitations under the License.
*/
-
-
-
-
-
/// The request message containing the user's name.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HelloRequest {
@@ -38,7 +33,7 @@ pub mod greeter_client {
use triple::client::TripleClient;
use triple::codec::prost::ProstCodec;
use triple::invocation::*;
-
+
/// The greeting service definition.
#[derive(Debug, Clone)]
pub struct GreeterClient {
diff --git a/dubbo/src/init.rs b/dubbo/src/init.rs
deleted file mode 100644
index e0d738c..0000000
--- a/dubbo/src/init.rs
+++ /dev/null
@@ -1,110 +0,0 @@
-// /// Server 启动的入口。业务侧需要调用该函数进行初始化
-// ///
-// use std::collections::HashMap;
-
-// use crate::common::url::Url;
-// use config::{BusinessConfig, RootConfig};
-
-// pub fn init() {
-// let _root_config = RootConfig::new().load();
-// let service_config = ServiceConfig::default()
-// .group("helloworld".to_string())
-// .serializer("json".to_string())
-// .version("1.0".to_string())
-// .name("echo".to_string());
-
-// let triple_config = ProtocolConfig::default()
-// .name("triple".to_string())
-// .ip("0.0.0.0".to_string())
-// .port("8888".to_string());
-
-// let _service_config = service_config.add_protocol_configs(triple_config);
-// // 根据不同的协议，加载不同的配置
-// // 初始化全局的services
-// // let server = DubboServer::init();
-// // let server = server.add_service("echo".to_string(), service);
-// }
-
-// #[derive(Default)]
-// pub struct ServiceConfig {
-// version: String,
-// group: String,
-// name: String,
-// protocol_names: Vec<String>,
-// registry_names: Vec<String>,
-// serializer: String,
-// protocol_configs: HashMap<String, ProtocolConfig>,
-// }
-
-// impl ServiceConfig {
-// pub fn name(self, name: String) -> Self {
-// Self { name, ..self }
-// }
-
-// pub fn version(self, version: String) -> Self {
-// Self { version, ..self }
-// }
-
-// pub fn group(self, group: String) -> Self {
-// Self { group, ..self }
-// }
-
-// pub fn protocol_names(self, protocol_names: Vec<String>) -> Self {
-// Self {
-// protocol_names,
-// ..self
-// }
-// }
-
-// pub fn serializer(self, serializer: String) -> Self {
-// Self { serializer, ..self }
-// }
-
-// pub fn add_protocol_configs(mut self, protocol_config: ProtocolConfig) -> Self {
-// self.protocol_configs
-// .insert(protocol_config.name.clone(), protocol_config);
-// Self { ..self }
-// }
-
-// pub fn get_url(&self) -> Vec<Url> {
-// let mut urls = Vec::new();
-// for (_, conf) in self.protocol_configs.iter() {
-// urls.push(Url {
-// url: conf.to_owned().to_url(),
-// service_key: "".to_string(),
-// });
-// }
-
-// urls
-// }
-// }
-
-// #[derive(Default, Debug, Clone)]
-// pub struct ProtocolConfig {
-// ip: String,
-// port: String,
-// name: String,
-// params: HashMap<String, String>,
-// }
-
-// impl ProtocolConfig {
-// pub fn name(self, name: String) -> Self {
-// Self { name, ..self }
-// }
-
-// pub fn ip(self, ip: String) -> Self {
-// Self { ip, ..self }
-// }
-
-// pub fn port(self, port: String) -> Self {
-// Self { port, ..self }
-// }
-
-// pub fn params(self, params: HashMap<String, String>) -> Self {
-// Self { params, ..self }
-// }
-
-// pub fn to_url(self) -> String {
-// format!("{}://{}:{}", self.name, self.ip, self.port).to_string()
-// }
-// }
diff --git a/dubbo/src/protocol/triple/mod.rs b/dubbo/src/protocol/triple/mod.rs
index 32728c3..0e84907 100644
--- a/dubbo/src/protocol/triple/mod.rs
+++ b/dubbo/src/protocol/triple/mod.rs
@@ -1,3 +1,20 @@
+/*
+ * 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.
+ */
+
pub mod triple_exporter;
pub mod triple_invoker;
pub mod triple_protocol;
diff --git a/dubbo/src/protocol/triple/triple_exporter.rs b/dubbo/src/protocol/triple/triple_exporter.rs
index fcddf79..48ceab3 100644
--- a/dubbo/src/protocol/triple/triple_exporter.rs
+++ b/dubbo/src/protocol/triple/triple_exporter.rs
@@ -1,3 +1,20 @@
+/*
+ * 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 super::triple_invoker::TripleInvoker;
use crate::protocol::Exporter;
diff --git a/dubbo/src/protocol/triple/triple_invoker.rs b/dubbo/src/protocol/triple/triple_invoker.rs
index 9f064ab..a7d0587 100644
--- a/dubbo/src/protocol/triple/triple_invoker.rs
+++ b/dubbo/src/protocol/triple/triple_invoker.rs
@@ -1,3 +1,20 @@
+/*
+ * 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::common::url::Url;
use crate::protocol::Invoker;
diff --git a/dubbo/src/protocol/triple/triple_protocol.rs b/dubbo/src/protocol/triple/triple_protocol.rs
index e3abb48..ba517bb 100644
--- a/dubbo/src/protocol/triple/triple_protocol.rs
+++ b/dubbo/src/protocol/triple/triple_protocol.rs
@@ -1,3 +1,20 @@
+/*
+ * 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 std::collections::HashMap;
use async_trait::async_trait;
diff --git a/dubbo/src/protocol/triple/triple_server.rs b/dubbo/src/protocol/triple/triple_server.rs
index b596bb9..e49694b 100644
--- a/dubbo/src/protocol/triple/triple_server.rs
+++ b/dubbo/src/protocol/triple/triple_server.rs
@@ -1,3 +1,20 @@
+/*
+ * 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 std::{net::ToSocketAddrs, str::FromStr};
use triple::transport::DubboServer;
diff --git a/triple/src/codec/prost.rs b/triple/src/codec/prost.rs
index 162ac51..fb52e39 100644
--- a/triple/src/codec/prost.rs
+++ b/triple/src/codec/prost.rs
@@ -1,3 +1,20 @@
+/*
+ * 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 super::{Codec, DecodeBuf, Decoder, EncodeBuf, Encoder};
use prost::Message;
use std::marker::PhantomData;