This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go-samples.git
The following commit(s) were added to refs/heads/main by this push:
new 2bae17fe impl: delete all polaris related content (#860)
2bae17fe is described below
commit 2bae17fefea2a0baa8f94fcb89a3254f6a3776d4
Author: Xuetao Li <[email protected]>
AuthorDate: Mon Jun 23 19:49:54 2025 +0800
impl: delete all polaris related content (#860)
* fix limit test
* delete polaris
---
README.md | 2 +-
README_CN.md | 2 +-
compatibility/polaris/limit/README-zh.md | 91 ----------------
compatibility/polaris/limit/README.md | 91 ----------------
compatibility/polaris/limit/go-client/cmd/main.go | 84 --------------
.../polaris/limit/go-client/conf/dubbogo.yml | 24 ----
.../polaris/limit/go-server/cmd/server.go | 111 -------------------
.../polaris/limit/go-server/conf/dubbogo.yml | 29 -----
.../limit/images/dubbogo-ratelimit-rule.png | Bin 113890 -> 0 bytes
compatibility/polaris/registry/README-zh.md | 62 -----------
compatibility/polaris/registry/README.md | 61 -----------
.../polaris/registry/go-client/cmd/main.go | 81 --------------
.../polaris/registry/go-client/conf/dubbogo.yml | 24 ----
.../polaris/registry/go-server/cmd/server.go | 110 -------------------
.../polaris/registry/go-server/conf/dubbogo.yml | 27 -----
compatibility/polaris/router/README-zh.md | 121 ---------------------
compatibility/polaris/router/README.md | 121 ---------------------
compatibility/polaris/router/go-client/cmd/main.go | 81 --------------
.../polaris/router/go-client/conf/dubbogo.yaml | 25 -----
.../router/go-server/server-dev/cmd/server.go | 111 -------------------
.../router/go-server/server-dev/conf/dubbogo.yaml | 28 -----
.../router/go-server/server-pre/cmd/server.go | 111 -------------------
.../router/go-server/server-pre/conf/dubbogo.yaml | 28 -----
.../router/go-server/server-prod/cmd/server.go | 111 -------------------
.../router/go-server/server-prod/conf/dubbogo.yaml | 28 -----
.../router/images/dubbogo-route-rule-dev.png | Bin 103117 -> 0 bytes
.../router/images/dubbogo-route-rule-pre.png | Bin 102704 -> 0 bytes
.../router/images/dubbogo-route-rule-prod.png | Bin 97770 -> 0 bytes
.../rpc/triple/tests/integration/main_test.go | 1 -
.../polaris/limit/tests/integration/limit_test.go | 45 --------
.../polaris/limit/tests/integration/main_test.go | 65 -----------
.../registry/tests/integration/main_test.go | 65 -----------
.../registry/tests/integration/registry_test.go | 41 -------
integrate_test/dockercompose/docker-compose.yml | 12 --
start_integrate_test.sh | 4 -
35 files changed, 2 insertions(+), 1795 deletions(-)
diff --git a/README.md b/README.md
index 2273f61a..45fbfd17 100644
--- a/README.md
+++ b/README.md
@@ -22,7 +22,7 @@
* compatibility/metrics: How to collect Dubbo-go Prometheus metrics
* compatibility/otel: How to use OpenTelemetry as Dubbo-go tracing tool
* compatibility/proxyless: Proxyless service mesh example for deploying
Dubbo-go services on Kubernetes
-* compatibility/registry: How to use etcd/nacos/polaris/zookeeper as Dubbo-go
registry
+* compatibility/registry: How to use etcd/nacos/zookeeper as Dubbo-go registry
* compatibility/rpc: Dubbo protocol communication examples
* compatibility/rpc/dubbo: Dubbo-go 3.0 RPC example between Java and Go
* compatibility/rpc/grpc: Dubbo-go RPC example based on gRPC
diff --git a/README_CN.md b/README_CN.md
index 45c98d11..919728bc 100644
--- a/README_CN.md
+++ b/README_CN.md
@@ -18,7 +18,7 @@
* compatibility/metrics：Prometheus 指标采集示例
* compatibility/otel：OpenTelemetry 链路追踪示例
* compatibility/proxyless：Kubernetes 下 proxyless 服务网格示例
-* compatibility/registry：多种注册中心（etcd/nacos/polaris/zookeeper）用法
+* compatibility/registry：多种注册中心（etcd/nacos/zookeeper）用法
* compatibility/rpc：Dubbo 协议通信示例
* compatibility/rpc/dubbo：Dubbo-go 3.0 Java/Go 跨语言 RPC 示例
* compatibility/rpc/grpc：基于 gRPC 的 Dubbo-go RPC 示例
diff --git a/compatibility/polaris/limit/README-zh.md
b/compatibility/polaris/limit/README-zh.md
deleted file mode 100644
index ea1cec86..00000000
--- a/compatibility/polaris/limit/README-zh.md
+++ /dev/null
@@ -1,91 +0,0 @@
-# Dubbo Go & Polaris TpsLimiter Example
-
-[English](README.md) | 中文
-
-## 使用服务限流功能
-
-在 dubbogo 中快速体验北极星的服务限流能力
-
-## 北极星服务端安装
-
-[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
-
-[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
-
-## 如何使用
-
-[北极星服务限流使用文档](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E8%AE%BF%E9%97%AE%E9%99%90%E6%B5%81)
-
-### dubbogo.yaml 配置文件
-
-在使用 PolarisMesh 的服务限流能力时，需要先启用 PolarisMesh 在 dubbogo 中的注册发现功能。
-
-```yaml
-dubbo:
- registries:
- polarisMesh:
- protocol: polaris
- address: ${北极星服务端IP}:8091
- namespace: ${北极星命名空间信息}
- token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
- tps.limiter: polaris-limit # 配置 tps.limiter 为 polaris-limiter 即可
-
-```
-
-注意：PolarisMesh 的服务限流能力是工作在 Provider 侧的。
-
-### 如何配置服务限流参数
-
-dubbogo 中的 PolarisMesh TpsLimiter 扩展点实现，能够根据用户配置的限流规则，自动的从当前 RPC
调用上下文以及请求信息中识别出需要参与限流的请求标签信息
-
-
-
-- 请求匹配规则为 **请求参数(QUERY)**
- - 标签来源: RPC 调用中方法的入参，即 Invoaction.Arguments()
- - 标签键规则
- - 方法仅有一个入参: param.$.${fieldName}, **param.** 为固定前缀，后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
- - 方法有多个参数: param[${index}].$.${fieldName}, **param[${index}].**
为固定前缀，${index} 代表是方法入参中的第几个参数，下标起始位置从 0 开始；后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
-- 请求匹配规则为 **请求头(HEADER)**:
- - 标签来源: RPC 调用的额外标签信息，即 Invoaction.Attachments()
-
-### 运行服务提供者
-
-进入 go-server 的 cmd 目录，执行以下命令
-
-```
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml"
- go run .
-```
-
-当看到以下日志时即表示 server 端启动成功
-
-```log
-INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
-```
-
-
-### 运行服务调用者
-
-进入 go-client 的 cmd 目录，执行以下命令
-
-
-```
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
- go run .
-```
-
-当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用
-
-```log
-INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19
12:52:38.092 +0800 CST}
-```
-
-当看到以下日志时即表示在 PolarisMesh 针对 go-server 配置的限流策略已生效
-
-```log
-ERROR handler/rejected_execution_handler_only_log.go:73 The invocation
was rejected
-```
diff --git a/compatibility/polaris/limit/README.md
b/compatibility/polaris/limit/README.md
deleted file mode 100644
index 11c2bb89..00000000
--- a/compatibility/polaris/limit/README.md
+++ /dev/null
@@ -1,91 +0,0 @@
-# Dubbo Go & Polaris TpsLimiter Example
-
-English | [中文](README-zh.md)
-
-## Use the service current limit function
-
-Quickly experience Polaris' service current limiting capabilities in dubbogo
-
-## Polaris server installation
-
-[Polaris Server Standalone Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
-
-[Polaris Server Cluster Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
-
-## how to use
-
-[Polaris Service Current Limitation
Documentation](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E8%AE%BF%E9%97%AE%E9%99%90%E6%B5%81)
-
-### dubbogo.yaml configuration file
-
-When using PolarisMesh's service current limiting capability, you need to
enable PolarisMesh's registration discovery function in dubbogo firstly.
-
-````yaml
-dubbo:
- registries:
- polarisMesh:
- protocol: polaris
- address: ${Polaris server IP}:8091
- namespace: ${Polaris namespace information}
- token: ${Polaris resource authentication token} # If the Polaris server
has enabled authentication for the client, you need to configure this parameter
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
- tps.limiter: polaris-limit # Configure tps.limiter as polaris-limiter
-
-````
-
-Note: The service current limiting capability of PolarisMesh works on the
Provider side.
-
-### How to configure service current limit parameters
-
-The implementation of the PolarisMesh TpsLimiter extension point in dubbogo
can automatically identify the request tag information that needs to
participate in current limiting from the current RPC call context and request
information according to the current limiting rules configured by the user.
-
-
-
-- The request matching rule is **Request parameter(QUERY)**
- - Tag source: the input parameter of the method in the RPC call, namely
Invoaction.Arguments()
- - Tag key rules
- - The method has only one input parameter: param.$.${fieldName},
**param.** is a fixed prefix, the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/ articles/JsonPath/)
- - The method has multiple parameters: param[${index}].$.${fieldName},
**param[${index}].** is a fixed prefix, ${index} represents the first parameter
in the method parameter Several parameters, the starting position of the
subscript starts from 0; the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/articles/JsonPath/)
-- The request matching rule is **request header (HEADER)**:
- - Tag source: Additional tag information for RPC calls, i.e.
Invoaction.Attachments()
-
-### Running the service provider
-
-Enter the cmd directory of go-server and execute the following command
-
-````
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
- go run .
-````
-
-When you see the following log, it means that the server side started
successfully
-
-````log
-INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
-````
-
-
-### Run the service caller
-
-Enter the cmd directory of go-client and execute the following command
-
-
-````
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
- go run .
-````
-
-When you see the following log, it means that go-client successfully
discovered go-server and made an RPC call
-
-````log
-INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092
+0800 CST}
-````
-
-When you see the following log, it means that the current limiting policy
configured for go-server in PolarisMesh has taken effect
-
-````log
-ERROR handler/rejected_execution_handler_only_log.go:73 The invocation was
rejected
-````
\ No newline at end of file
diff --git a/compatibility/polaris/limit/go-client/cmd/main.go
b/compatibility/polaris/limit/go-client/cmd/main.go
deleted file mode 100644
index 4acd43cb..00000000
--- a/compatibility/polaris/limit/go-client/cmd/main.go
+++ /dev/null
@@ -1,84 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "errors"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-type UserProviderWithCustomGroupAndVersion struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type UserProvider struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-func main() {
- var userProvider = &UserProvider{}
- var userProviderWithCustomRegistryGroupAndVersion =
&UserProviderWithCustomGroupAndVersion{}
- config.SetConsumerService(userProvider)
- config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion)
- hessian.RegisterPOJO(&User{})
- err := config.Load()
- if err != nil {
- panic(err)
- }
-
- logger.Infof("\n\n\nstart to test dubbo")
-
- var successCount, failCount int64
- for i := 0; i < 10; i++ {
- time.Sleep(50 * time.Millisecond)
- user, err := userProvider.GetUser(context.TODO(), &User{Name:
"Alex03"})
- if err != nil {
- failCount++
- logger.Infof("error: %v\n", err)
- } else {
- successCount++
- }
- logger.Infof("response: %v\n", user)
- }
- logger.Infof("successCount=%v, failCount=%v\n", successCount, failCount)
-
- if failCount == 0 {
- panic(errors.New("need failCount > 0"))
- }
-}
diff --git a/compatibility/polaris/limit/go-client/conf/dubbogo.yml
b/compatibility/polaris/limit/go-client/conf/dubbogo.yml
deleted file mode 100644
index 294de217..00000000
--- a/compatibility/polaris/limit/go-client/conf/dubbogo.yml
+++ /dev/null
@@ -1,24 +0,0 @@
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- consumer:
- references:
- UserProvider:
- protocol: dubbo
- interface: org.apache.dubbo.UserProvider.Test
- UserProviderWithCustomGroupAndVersion:
- protocol: dubbo
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with server
diff --git a/compatibility/polaris/limit/go-server/cmd/server.go
b/compatibility/polaris/limit/go-server/cmd/server.go
deleted file mode 100644
index 6272c16d..00000000
--- a/compatibility/polaris/limit/go-server/cmd/server.go
+++ /dev/null
@@ -1,111 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "fmt"
- "os"
- "os/signal"
- "syscall"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-var (
- survivalTimeout = int(3e9)
-)
-
-func init() {
- config.SetProviderService(&UserProvider{})
- config.SetProviderService(&UserProviderWithCustomGroupAndVersion{})
- // ------for hessian2------
- hessian.RegisterPOJO(&User{})
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-type UserProvider struct {
-}
-
-func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-type UserProviderWithCustomGroupAndVersion struct {
-}
-
-func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks from
UserProviderWithCustomGroupAndVersion", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to
"conf/server.yml" before run
-func main() {
- if err := config.Load(); err != nil {
- panic(err)
- }
-
- initSignal()
-}
-
-func initSignal() {
- signals := make(chan os.Signal, 1)
- // It is not possible to block SIGKILL or syscall.SIGSTOP
- signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT,
syscall.SIGTERM)
- for {
- sig := <-signals
- logger.Infof("get signal %s", sig.String())
- switch sig {
- case syscall.SIGHUP:
- // reload()
- default:
- time.AfterFunc(time.Duration(survivalTimeout), func() {
- logger.Warnf("app exit now by force...")
- os.Exit(1)
- })
-
- // The program exits normally or timeout forcibly exits.
- fmt.Println("provider app exit now...")
- return
- }
- }
-}
diff --git a/compatibility/polaris/limit/go-server/conf/dubbogo.yml
b/compatibility/polaris/limit/go-server/conf/dubbogo.yml
deleted file mode 100644
index 2aa7785d..00000000
--- a/compatibility/polaris/limit/go-server/conf/dubbogo.yml
+++ /dev/null
@@ -1,29 +0,0 @@
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- protocols:
- dubbo:
- name: dubbo
- port: 20000
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
- tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
- UserProviderWithCustomGroupAndVersion:
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
- tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
diff --git a/compatibility/polaris/limit/images/dubbogo-ratelimit-rule.png
b/compatibility/polaris/limit/images/dubbogo-ratelimit-rule.png
deleted file mode 100644
index efdd51ba..00000000
Binary files a/compatibility/polaris/limit/images/dubbogo-ratelimit-rule.png
and /dev/null differ
diff --git a/compatibility/polaris/registry/README-zh.md
b/compatibility/polaris/registry/README-zh.md
deleted file mode 100644
index a13c2aab..00000000
--- a/compatibility/polaris/registry/README-zh.md
+++ /dev/null
@@ -1,62 +0,0 @@
-# Dubbo Go & Polaris Registry Example
-
-English | [中文](README-zh.md)
-
-## 使用服务注册发现功能
-
-在 dubbogo 中快速体验北极星的服务注册以及服务发现能力
-
-## 北极星服务端安装
-
-[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
-
-[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
-
-## 如何使用
-
-### dubbogo.yaml 配置文件
-
-当前 PolarisMesh 已实现了 dubbogo 的注册发现扩展点，因此你只需要调整你的 dubbogo.yaml 文件中的 registries
配置项，新增 protocol 为 polaris 的注册中心配置即可，可以参考下面的样例。
-
-```yaml
-dubbo:
- registries:
- polarisMesh:
- protocol: polaris
- address: ${北极星服务端IP}:8091
- namespace: ${北极星命名空间信息}
- token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数
-```
-
-### 运行服务提供者
-
-进入 go-server 的 cmd 目录，执行以下命令
-
-```
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
- go run .
-```
-
-当看到以下日志时即表示 server 端启动成功
-
-```log
-INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
-```
-
-
-### 运行服务调用者
-
-进入 go-client 的 cmd 目录，执行以下命令
-
-
-```
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
- go run .
-```
-
-当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用
-
-```log
-INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19
12:52:38.092 +0800 CST}
-```
-
diff --git a/compatibility/polaris/registry/README.md
b/compatibility/polaris/registry/README.md
deleted file mode 100644
index e6ea563f..00000000
--- a/compatibility/polaris/registry/README.md
+++ /dev/null
@@ -1,61 +0,0 @@
-# Dubbo Go & Polaris Registry Example
-
-English | [中文](README-zh.md)
-
-## Using the service registration discovery function
-
-Quickly experience Polaris' service registration and service discovery
capabilities in dubbogo
-
-## Polaris server installation
-
-[Polaris Server Standalone Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
-
-[Polaris Server Cluster Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
-
-## how to use
-
-### dubbogo.yaml configuration file
-
-Currently PolarisMesh has implemented the registration discovery extension
point of dubbogo, so you only need to adjust the registries configuration item
in your dubbogo.yaml file, and add the registry configuration of polaris as the
protocol. You can refer to the following example.
-
-````yaml
-dubbo:
- registries:
- polarisMesh:
- protocol: polaris
- address: ${Polaris server IP}:8091
- namespace: ${Polaris namespace information}
- token: ${Polaris resource authentication token} # If the Polaris server
has enabled authentication for the client, you need to configure this parameter
-````
-
-### Running the service provider
-
-Enter the cmd directory of go-server and execute the following command
-
-````
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
- go run .
-````
-
-When you see the following log, it means that the server side started
successfully
-
-````log
-INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
-````
-
-
-### Run the service caller
-
-Enter the cmd directory of go-client and execute the following command
-
-
-````
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
- go run .
-````
-
-When you see the following log, it means that go-client successfully
discovered go-server and made an RPC call
-
-````log
-INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092
+0800 CST}
-````
\ No newline at end of file
diff --git a/compatibility/polaris/registry/go-client/cmd/main.go
b/compatibility/polaris/registry/go-client/cmd/main.go
deleted file mode 100644
index e685d8a4..00000000
--- a/compatibility/polaris/registry/go-client/cmd/main.go
+++ /dev/null
@@ -1,81 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "os"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-type UserProviderWithCustomGroupAndVersion struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type UserProvider struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-func main() {
- var userProvider = &UserProvider{}
- var userProviderWithCustomRegistryGroupAndVersion =
&UserProviderWithCustomGroupAndVersion{}
- config.SetConsumerService(userProvider)
- config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion)
- hessian.RegisterPOJO(&User{})
- err := config.Load()
- if err != nil {
- panic(err)
- }
-
- logger.Infof("\n\n\nstart to test dubbo")
- user, err := userProvider.GetUser(context.TODO(), &User{Name:
"Alex001"})
- if err != nil {
- logger.Errorf("error: %v\n", err)
- os.Exit(1)
- return
- }
- logger.Infof("response result: %v\n", user)
-
- user, err =
userProviderWithCustomRegistryGroupAndVersion.GetUser(context.TODO(),
&User{Name: "Alex001"})
- if err != nil {
- logger.Errorf("error: %v\n", err)
- os.Exit(1)
- return
- }
- logger.Infof("response result: %v\n", user)
-}
diff --git a/compatibility/polaris/registry/go-client/conf/dubbogo.yml
b/compatibility/polaris/registry/go-client/conf/dubbogo.yml
deleted file mode 100644
index 068e6dd4..00000000
--- a/compatibility/polaris/registry/go-client/conf/dubbogo.yml
+++ /dev/null
@@ -1,24 +0,0 @@
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- consumer:
- references:
- UserProvider:
- protocol: dubbo
- interface: org.apache.dubbo.UserProvider.Test
- UserProviderWithCustomGroupAndVersion:
- protocol: dubbo
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with server
\ No newline at end of file
diff --git a/compatibility/polaris/registry/go-server/cmd/server.go
b/compatibility/polaris/registry/go-server/cmd/server.go
deleted file mode 100644
index 55988678..00000000
--- a/compatibility/polaris/registry/go-server/cmd/server.go
+++ /dev/null
@@ -1,110 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "fmt"
- "os"
- "os/signal"
- "syscall"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-var (
- survivalTimeout = int(3e9)
-)
-
-func init() {
- config.SetProviderService(&UserProvider{})
- config.SetProviderService(&UserProviderWithCustomGroupAndVersion{})
- // ------for hessian2------
- hessian.RegisterPOJO(&User{})
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-type UserProvider struct {
-}
-
-func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-type UserProviderWithCustomGroupAndVersion struct {
-}
-
-func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "Alex Stocks from
UserProviderWithCustomGroupAndVersion", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to
"conf/server.yml" before run
-func main() {
- if err := config.Load(); err != nil {
- panic(err)
- }
-
- initSignal()
-}
-
-func initSignal() {
- signals := make(chan os.Signal, 1)
- // It is not possible to block SIGKILL or syscall.SIGSTOP
- signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT,
syscall.SIGTERM)
- for {
- sig := <-signals
- logger.Infof("get signal %s", sig.String())
- switch sig {
- case syscall.SIGHUP:
- // reload()
- default:
- time.AfterFunc(time.Duration(survivalTimeout), func() {
- logger.Warnf("app exit now by force...")
- os.Exit(1)
- })
-
- // The program exits normally or timeout forcibly exits.
- fmt.Println("provider app exit now...")
- return
- }
- }
-}
diff --git a/compatibility/polaris/registry/go-server/conf/dubbogo.yml
b/compatibility/polaris/registry/go-server/conf/dubbogo.yml
deleted file mode 100644
index 0c0c7f70..00000000
--- a/compatibility/polaris/registry/go-server/conf/dubbogo.yml
+++ /dev/null
@@ -1,27 +0,0 @@
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- protocols:
- dubbo:
- name: dubbo
- port: 20000
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
- UserProviderWithCustomGroupAndVersion:
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
\ No newline at end of file
diff --git a/compatibility/polaris/router/README-zh.md
b/compatibility/polaris/router/README-zh.md
deleted file mode 100644
index be48668d..00000000
--- a/compatibility/polaris/router/README-zh.md
+++ /dev/null
@@ -1,121 +0,0 @@
-# Dubbo Go & Polaris Router Example
-
-[English](README.md) | 中文
-
-## 使用服务路由功能
-
-在 dubbogo 中快速体验北极星的服务路由能力
-
-## 北极星服务端安装
-
-[北极星服务端单机版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
-
-[北极星服务端集群版本安装文档](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
-
-## 如何使用
-
-[北极星服务路由使用文档](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E5%8A%A8%E6%80%81%E8%B7%AF%E7%94%B1)
-
-### dubbogo.yaml 配置文件
-
-在使用 PolarisMesh 的服务路由能力时，需要先启用 PolarisMesh 在 dubbogo 中的注册发现功能。
-
-```yaml
-dubbo:
- registries:
- polarisMesh:
- protocol: polaris
- address: ${北极星服务端IP}:8091
- namespace: ${北极星命名空间信息}
- token: ${北极星资源鉴权 token} # 如果北极星服务端开启了针对客户端的鉴权，则需要配置该参数
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
-```
-
-### 如何配置服务路由参数
-
-dubbogo 中的 PolarisMesh PriorityRouter 扩展点实现，能够根据用户配置的服务路由规则，自动的从当前 RPC
调用上下文以及请求信息中识别出需要参与服务路由的请求标签信息
-
-
-
-
-
-- 请求匹配规则为 **请求参数(QUERY)**
- - 标签来源: RPC 调用中方法的入参，即 Invoaction.Arguments()
- - 标签键规则
- - 方法仅有一个入参: param.$.${fieldName}, **param.** 为固定前缀，后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
- - 方法有多个参数: param[${index}].$.${fieldName}, **param[${index}].**
为固定前缀，${index} 代表是方法入参中的第几个参数，下标起始位置从 0 开始；后面的表达式为标准的 JSONPath
expressions，[参考文档](https://goessner.net/articles/JsonPath/)
-- 请求匹配规则为 **请求头(HEADER)**:
- - 标签来源: RPC 调用的额外标签信息，即 Invoaction.Attachments()
-
-### 运行服务提供者
-
-分别进入 server-prod、server-pre、server-dev 的 cmd 目录，执行以下命令
-
-```
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml"
- go run .
-```
-
-当看到以下日志时即表示 server 端启动成功
-
-```log
-INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
-```
-
-
-### 运行服务调用者
-
-进入 go-client 的 cmd 目录，执行以下命令
-
-
-```
-export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
-export uid=user-1
-go run .
-```
-
-当看到以下日志时即表示 go-client 成功发现 go-server 并发起了 RPC 调用
-
-```log
-INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19
12:52:38.092 +0800 CST}
-```
-
-分别执行以下命令
-
-```bash
-export uid=
-go run .
-
-export uid=user-1
-go run .
-
-export uid=user-2
-```
-
-当看到以下日志时即表示在 PolarisMesh 配置的路由策略已生效
-
-```log
-# export uid=
-2022-11-26T13:39:31.637+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.637 +0800 CST}
-2022-11-26T13:39:31.842+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.841 +0800 CST}
-2022-11-26T13:39:32.043+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.043 +0800 CST}
-2022-11-26T13:39:32.247+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.247 +0800 CST}
-2022-11-26T13:39:32.452+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.452 +0800 CST}
-
-# export uid=user-1
-2022-11-26T13:39:51.053+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.053 +0800 CST}
-2022-11-26T13:39:51.257+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.257 +0800 CST}
-2022-11-26T13:39:51.459+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.459 +0800 CST}
-2022-11-26T13:39:51.662+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.662 +0800 CST}
-2022-11-26T13:39:51.866+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.866 +0800 CST}
-
-# export uid=user-2
-2022-11-26T13:42:39.351+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.351 +0800 CST}
-2022-11-26T13:42:39.555+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.555 +0800 CST}
-2022-11-26T13:42:39.760+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.76 +0800 CST}
-2022-11-26T13:42:39.962+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.961 +0800 CST}
-2022-11-26T13:42:40.165+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:40.165 +0800 CST}
-```
diff --git a/compatibility/polaris/router/README.md
b/compatibility/polaris/router/README.md
deleted file mode 100644
index a80804d8..00000000
--- a/compatibility/polaris/router/README.md
+++ /dev/null
@@ -1,121 +0,0 @@
-# Dubbo Go & Polaris Router Example
-
-English | [中文](README-zh.md)
-
-## Using the service routing function
-
-Quickly experience Polaris' service routing capabilities in dubbogo
-
-## Polaris server installation
-
-[Polaris Server Standalone Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E5%8D%95%E6%9C%BA%E7%89%88%E5%AE%89%E8%A3%85/)
-
-[Polaris Server Cluster Version Installation
Documentation](https://polarismesh.cn/docs/%E4%BD%BF%E7%94%A8%E6%8C%87%E5%8D%97/%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%AE%89%E8%A3%85/%E9%9B%86%E7%BE%A4%E7%89%88%E5%AE%89%E8%A3%85/)
-
-## how to use
-
-[Polaris Service Routing Usage
Document](https://polarismesh.cn/docs/%E5%8C%97%E6%9E%81%E6%98%9F%E6%98%AF%E4%BB%80%E4%B9%88/%E5%8A%9F%E8%83%BD%E7%89%B9%E6%80%A7/%E6%B5%81%E9%87%8F%E7%AE%A1%E7%90%86/#%E5%8A%A8%E6%80%81%E8%B7%AF%E7%94%B1)
-
-### dubbogo.yaml configuration file
-
-When using PolarisMesh's service route capability, you need to enable
PolarisMesh's registration discovery function in dubbogo firstly.
-
-````yaml
-dubbo:
- registries:
- polarisMesh:
- protocol: polaris
- address: ${Polaris server IP}:8091
- namespace: ${Polaris namespace information}
- token: ${Polaris resource authentication token} # If the Polaris server
has enabled authentication for the client, you need to configure this parameter
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
-````
-
-### How to configure service routing parameters
-
-The implementation of the PolarisMesh PriorityRouter extension point in
dubbogo can automatically identify the request label information that needs to
participate in service routing from the current RPC call context and request
information according to the service route rules configured by the user.
-
-
-
-
-
-- The request matching rule is **Request parameter(QUERY)**
- - Tag source: the input parameter of the method in the RPC call, namely
Invoaction.Arguments()
- - Tag key rules
- - The method has only one input parameter: param.$.${fieldName},
**param.** is a fixed prefix, the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/ articles/JsonPath/)
- - The method has multiple parameters: param[${index}].$.${fieldName},
**param[${index}].** is a fixed prefix, ${index} represents the first parameter
in the method parameter Several parameters, the starting position of the
subscript starts from 0; the following expressions are standard JSONPath
expressions, [reference document](https://goessner.net/articles/JsonPath/)
-- The request matching rule is **request header (HEADER)**:
- - Tag source: Additional tag information for RPC calls, i.e.
Invoaction.Attachments()
-
-### Running the service provider
-
-Enter the cmd directory of server-prod, server-pre, and server-dev
respectively, and execute the following commands
-
-````
- export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yaml"
- go run .
-````
-
-When you see the following log, it means that the server side started
successfully
-
-````log
-INFO dubbo/dubbo_protocol.go:84 [DUBBO Protocol] Export service:
-````
-
-
-### Running the service caller
-
-Enter the cmd directory of go-client and execute the following command
-
-
-````
-export DUBBO_GO_CONFIG_PATH="../conf/dubbogo.yml"
-export uid=user-1
-go run .
-````
-
-When you see the following log, it means that go-client successfully
discovered go-server and made an RPC call
-
-````log
-INFO cmd/main.go:75 response: &{A001 Alex Stocks 18 2022-11-19 12:52:38.092
+0800 CST}
-````
-
-Execute the following commands respectively
-
-```bash
-export uid=
-go run .
-
-export uid=user-1
-go run .
-
-export uid=user-2
-````
-
-When you see the following log, it means that the routing policy configured in
PolarisMesh has taken effect
-
-```log
-# export uid=
-2022-11-26T13:39:31.637+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.637 +0800 CST}
-2022-11-26T13:39:31.842+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:31.841 +0800 CST}
-2022-11-26T13:39:32.043+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.043 +0800 CST}
-2022-11-26T13:39:32.247+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.247 +0800 CST}
-2022-11-26T13:39:32.452+0800 INFO cmd/main.go:78 response: &{A001
[Prod] Alex Stocks 18 2022-11-26 13:39:32.452 +0800 CST}
-
-# export uid=user-1
-2022-11-26T13:39:51.053+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.053 +0800 CST}
-2022-11-26T13:39:51.257+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.257 +0800 CST}
-2022-11-26T13:39:51.459+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.459 +0800 CST}
-2022-11-26T13:39:51.662+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.662 +0800 CST}
-2022-11-26T13:39:51.866+0800 INFO cmd/main.go:78 response: &{A001 [Pre]
Alex Stocks 18 2022-11-26 13:39:51.866 +0800 CST}
-
-# export uid=user-2
-2022-11-26T13:42:39.351+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.351 +0800 CST}
-2022-11-26T13:42:39.555+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.555 +0800 CST}
-2022-11-26T13:42:39.760+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.76 +0800 CST}
-2022-11-26T13:42:39.962+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:39.961 +0800 CST}
-2022-11-26T13:42:40.165+0800 INFO cmd/main.go:78 response: &{A001 [Dev]
Alex Stocks 18 2022-11-26 13:42:40.165 +0800 CST}
-```
diff --git a/compatibility/polaris/router/go-client/cmd/main.go
b/compatibility/polaris/router/go-client/cmd/main.go
deleted file mode 100644
index 1e4f6b53..00000000
--- a/compatibility/polaris/router/go-client/cmd/main.go
+++ /dev/null
@@ -1,81 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "os"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/common/constant"
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-type UserProviderWithCustomGroupAndVersion struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type UserProvider struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-func main() {
- var userProvider = &UserProvider{}
- var userProviderWithCustomRegistryGroupAndVersion =
&UserProviderWithCustomGroupAndVersion{}
- config.SetConsumerService(userProvider)
- config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion)
- hessian.RegisterPOJO(&User{})
- err := config.Load()
- if err != nil {
- panic(err)
- }
-
- logger.Infof("\n\n\nstart to test dubbo")
-
- uid := os.Getenv("uid")
- atta := make(map[string]interface{})
- atta["uid"] = uid
- reqContext := context.WithValue(context.Background(),
constant.DubboCtxKey("attachment"), atta)
-
- for i := 0; i < 5; i++ {
- time.Sleep(200 * time.Millisecond)
- user, err := userProvider.GetUser(reqContext, &User{Name:
"Alex001"})
- if err != nil {
- panic(err)
- }
- logger.Infof("response: %v\n", user)
- }
-}
diff --git a/compatibility/polaris/router/go-client/conf/dubbogo.yaml
b/compatibility/polaris/router/go-client/conf/dubbogo.yaml
deleted file mode 100644
index b41630c6..00000000
--- a/compatibility/polaris/router/go-client/conf/dubbogo.yaml
+++ /dev/null
@@ -1,25 +0,0 @@
-
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: pro # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- consumer:
- references:
- UserProvider:
- protocol: dubbo
- interface: org.apache.dubbo.UserProvider.Test
- UserProviderWithCustomGroupAndVersion:
- protocol: dubbo
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with server
diff --git a/compatibility/polaris/router/go-server/server-dev/cmd/server.go
b/compatibility/polaris/router/go-server/server-dev/cmd/server.go
deleted file mode 100644
index 71eab8ac..00000000
--- a/compatibility/polaris/router/go-server/server-dev/cmd/server.go
+++ /dev/null
@@ -1,111 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "fmt"
- "os"
- "os/signal"
- "syscall"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-var (
- survivalTimeout = int(3e9)
-)
-
-func init() {
- config.SetProviderService(&UserProvider{})
- config.SetProviderService(&UserProviderWithCustomGroupAndVersion{})
- // ------for hessian2------
- hessian.RegisterPOJO(&User{})
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-type UserProvider struct {
-}
-
-func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "[Dev] Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-type UserProviderWithCustomGroupAndVersion struct {
-}
-
-func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "[Dev] Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to
"conf/server.yml" before run
-func main() {
- if err := config.Load(); err != nil {
- panic(err)
- }
-
- initSignal()
-}
-
-func initSignal() {
- signals := make(chan os.Signal, 1)
- // It is not possible to block SIGKILL or syscall.SIGSTOP
- signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT,
syscall.SIGTERM)
- for {
- sig := <-signals
- logger.Infof("get signal %s", sig.String())
- switch sig {
- case syscall.SIGHUP:
- // reload()
- default:
- time.AfterFunc(time.Duration(survivalTimeout), func() {
- logger.Warnf("app exit now by force...")
- os.Exit(1)
- })
-
- // The program exits normally or timeout forcibly exits.
- fmt.Println("provider app exit now...")
- return
- }
- }
-}
diff --git
a/compatibility/polaris/router/go-server/server-dev/conf/dubbogo.yaml
b/compatibility/polaris/router/go-server/server-dev/conf/dubbogo.yaml
deleted file mode 100644
index 557ea4c4..00000000
--- a/compatibility/polaris/router/go-server/server-dev/conf/dubbogo.yaml
+++ /dev/null
@@ -1,28 +0,0 @@
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: dev # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- protocols:
- dubbo:
- name: dubbo
- port: 20000
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
- tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
- UserProviderWithCustomGroupAndVersion:
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
diff --git a/compatibility/polaris/router/go-server/server-pre/cmd/server.go
b/compatibility/polaris/router/go-server/server-pre/cmd/server.go
deleted file mode 100644
index 46ef833e..00000000
--- a/compatibility/polaris/router/go-server/server-pre/cmd/server.go
+++ /dev/null
@@ -1,111 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "fmt"
- "os"
- "os/signal"
- "syscall"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-var (
- survivalTimeout = int(3e9)
-)
-
-func init() {
- config.SetProviderService(&UserProvider{})
- config.SetProviderService(&UserProviderWithCustomGroupAndVersion{})
- // ------for hessian2------
- hessian.RegisterPOJO(&User{})
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-type UserProvider struct {
-}
-
-func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "[Pre] Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-type UserProviderWithCustomGroupAndVersion struct {
-}
-
-func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "[Pre] Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to
"conf/server.yml" before run
-func main() {
- if err := config.Load(); err != nil {
- panic(err)
- }
-
- initSignal()
-}
-
-func initSignal() {
- signals := make(chan os.Signal, 1)
- // It is not possible to block SIGKILL or syscall.SIGSTOP
- signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT,
syscall.SIGTERM)
- for {
- sig := <-signals
- logger.Infof("get signal %s", sig.String())
- switch sig {
- case syscall.SIGHUP:
- // reload()
- default:
- time.AfterFunc(time.Duration(survivalTimeout), func() {
- logger.Warnf("app exit now by force...")
- os.Exit(1)
- })
-
- // The program exits normally or timeout forcibly exits.
- fmt.Println("provider app exit now...")
- return
- }
- }
-}
diff --git
a/compatibility/polaris/router/go-server/server-pre/conf/dubbogo.yaml
b/compatibility/polaris/router/go-server/server-pre/conf/dubbogo.yaml
deleted file mode 100644
index 1ef24dfc..00000000
--- a/compatibility/polaris/router/go-server/server-pre/conf/dubbogo.yaml
+++ /dev/null
@@ -1,28 +0,0 @@
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: pre # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- protocols:
- dubbo:
- name: dubbo
- port: 21000
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
- tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
- UserProviderWithCustomGroupAndVersion:
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
diff --git a/compatibility/polaris/router/go-server/server-prod/cmd/server.go
b/compatibility/polaris/router/go-server/server-prod/cmd/server.go
deleted file mode 100644
index 56dc89a0..00000000
--- a/compatibility/polaris/router/go-server/server-prod/cmd/server.go
+++ /dev/null
@@ -1,111 +0,0 @@
-/*
- * 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.
- */
-
-package main
-
-import (
- "context"
- "fmt"
- "os"
- "os/signal"
- "syscall"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/filter/tps/strategy"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-
- "github.com/dubbogo/gost/log/logger"
-)
-
-var (
- survivalTimeout = int(3e9)
-)
-
-func init() {
- config.SetProviderService(&UserProvider{})
- config.SetProviderService(&UserProviderWithCustomGroupAndVersion{})
- // ------for hessian2------
- hessian.RegisterPOJO(&User{})
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-type UserProvider struct {
-}
-
-func (u *UserProvider) GetUser(ctx context.Context, req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "[Prod] Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-type UserProviderWithCustomGroupAndVersion struct {
-}
-
-func (u *UserProviderWithCustomGroupAndVersion) GetUser(ctx context.Context,
req *User) (*User, error) {
- logger.Infof("req:%#v", req)
- rsp := User{"A001", "[Prod] Alex Stocks", 18, time.Now()}
- logger.Infof("rsp:%#v", rsp)
- return &rsp, nil
-}
-
-// need to setup environment variable "CONF_PROVIDER_FILE_PATH" to
"conf/server.yml" before run
-func main() {
- if err := config.Load(); err != nil {
- panic(err)
- }
-
- initSignal()
-}
-
-func initSignal() {
- signals := make(chan os.Signal, 1)
- // It is not possible to block SIGKILL or syscall.SIGSTOP
- signal.Notify(signals, os.Interrupt, syscall.SIGHUP, syscall.SIGQUIT,
syscall.SIGTERM)
- for {
- sig := <-signals
- logger.Infof("get signal %s", sig.String())
- switch sig {
- case syscall.SIGHUP:
- // reload()
- default:
- time.AfterFunc(time.Duration(survivalTimeout), func() {
- logger.Warnf("app exit now by force...")
- os.Exit(1)
- })
-
- // The program exits normally or timeout forcibly exits.
- fmt.Println("provider app exit now...")
- return
- }
- }
-}
diff --git
a/compatibility/polaris/router/go-server/server-prod/conf/dubbogo.yaml
b/compatibility/polaris/router/go-server/server-prod/conf/dubbogo.yaml
deleted file mode 100644
index cd623867..00000000
--- a/compatibility/polaris/router/go-server/server-prod/conf/dubbogo.yaml
+++ /dev/null
@@ -1,28 +0,0 @@
-dubbo:
- application:
- name: myApp # metadata: application=myApp; name=myApp
- module: opensource #metadata: module=opensource
- group: myAppGroup # no metadata record
- organization: dubbo # metadata: organization=dubbo
- owner: laurence # metadata: owner=laurence
- version: myversion # metadata: app.version=myversion
- environment: prod # metadata: environment=pro
- registries:
- polarisMesh:
- protocol: polaris
- address: 127.0.0.1:8091
- namespace: dubbogo
- registry-type: interface
- protocols:
- dubbo:
- name: dubbo
- port: 22000
- provider:
- services:
- UserProvider:
- interface: org.apache.dubbo.UserProvider.Test
- tps.limiter: polaris-limit # the Limiter that judge if the TPS overs
the threshold, such as method-service or default
- UserProviderWithCustomGroupAndVersion:
- interface: org.apache.dubbo.UserProvider.Test2
- version: myInterfaceVersion # dubbo interface version must be same
with client
- group: myInterfaceGroup # dubbo interface group must be same with
client
diff --git a/compatibility/polaris/router/images/dubbogo-route-rule-dev.png
b/compatibility/polaris/router/images/dubbogo-route-rule-dev.png
deleted file mode 100644
index b61ed0eb..00000000
Binary files a/compatibility/polaris/router/images/dubbogo-route-rule-dev.png
and /dev/null differ
diff --git a/compatibility/polaris/router/images/dubbogo-route-rule-pre.png
b/compatibility/polaris/router/images/dubbogo-route-rule-pre.png
deleted file mode 100644
index 61eb8977..00000000
Binary files a/compatibility/polaris/router/images/dubbogo-route-rule-pre.png
and /dev/null differ
diff --git a/compatibility/polaris/router/images/dubbogo-route-rule-prod.png
b/compatibility/polaris/router/images/dubbogo-route-rule-prod.png
deleted file mode 100644
index 0fd28f07..00000000
Binary files a/compatibility/polaris/router/images/dubbogo-route-rule-prod.png
and /dev/null differ
diff --git
a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go
b/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go
index 818b0e6b..0ca9cbc4 100644
---
a/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go
+++
b/integrate_test/compatibility/config-api/rpc/triple/tests/integration/main_test.go
@@ -48,5 +48,4 @@ func TestMain(m *testing.M) {
panic(err)
}
os.Exit(m.Run())
-
}
diff --git
a/integrate_test/compatibility/polaris/limit/tests/integration/limit_test.go
b/integrate_test/compatibility/polaris/limit/tests/integration/limit_test.go
deleted file mode 100644
index 7c68bd8f..00000000
--- a/integrate_test/compatibility/polaris/limit/tests/integration/limit_test.go
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- * 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.
- */
-
-package integration
-
-import (
- "context"
- "testing"
- "time"
-)
-
-import (
- "github.com/stretchr/testify/assert"
-)
-
-func TestPolarisLimit(t *testing.T) {
-
- var successCount, failCount int64
- for i := 0; i < 10; i++ {
- time.Sleep(50 * time.Millisecond)
- _, err := userProvider.GetUser(context.TODO(), &User{Name:
"Alex03"})
- if err != nil {
- failCount++
- } else {
- successCount++
- }
- }
- //current limiting effect
- assert.Equal(t, true, failCount > 0)
-
-}
diff --git
a/integrate_test/compatibility/polaris/limit/tests/integration/main_test.go
b/integrate_test/compatibility/polaris/limit/tests/integration/main_test.go
deleted file mode 100644
index 5db1c648..00000000
--- a/integrate_test/compatibility/polaris/limit/tests/integration/main_test.go
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * 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.
- */
-
-package integration
-
-import (
- "context"
- "testing"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-)
-
-type UserProviderWithCustomGroupAndVersion struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type UserProvider struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-var userProvider = &UserProvider{}
-var userProviderWithCustomRegistryGroupAndVersion =
&UserProviderWithCustomGroupAndVersion{}
-
-func TestMain(m *testing.M) {
-
- config.SetConsumerService(userProvider)
- config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion)
- hessian.RegisterPOJO(&User{})
- err := config.Load()
- if err != nil {
- panic(err)
- }
-
-}
diff --git
a/integrate_test/compatibility/polaris/registry/tests/integration/main_test.go
b/integrate_test/compatibility/polaris/registry/tests/integration/main_test.go
deleted file mode 100644
index 5db1c648..00000000
---
a/integrate_test/compatibility/polaris/registry/tests/integration/main_test.go
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * 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.
- */
-
-package integration
-
-import (
- "context"
- "testing"
- "time"
-)
-
-import (
- "dubbo.apache.org/dubbo-go/v3/config"
- _ "dubbo.apache.org/dubbo-go/v3/imports"
-
- hessian "github.com/apache/dubbo-go-hessian2"
-)
-
-type UserProviderWithCustomGroupAndVersion struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type UserProvider struct {
- GetUser func(ctx context.Context, req *User) (rsp *User, err error)
-}
-
-type User struct {
- ID string
- Name string
- Age int32
- Time time.Time
-}
-
-func (u *User) JavaClassName() string {
- return "org.apache.dubbo.User"
-}
-
-var userProvider = &UserProvider{}
-var userProviderWithCustomRegistryGroupAndVersion =
&UserProviderWithCustomGroupAndVersion{}
-
-func TestMain(m *testing.M) {
-
- config.SetConsumerService(userProvider)
- config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion)
- hessian.RegisterPOJO(&User{})
- err := config.Load()
- if err != nil {
- panic(err)
- }
-
-}
diff --git
a/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
b/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
deleted file mode 100644
index 76251f2c..00000000
---
a/integrate_test/compatibility/polaris/registry/tests/integration/registry_test.go
+++ /dev/null
@@ -1,41 +0,0 @@
-/*
- * 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.
- */
-
-package integration
-
-import (
- "context"
- "testing"
-)
-
-import (
- "github.com/stretchr/testify/assert"
-)
-
-func TestPolarisRegistry(t *testing.T) {
- user, err := userProvider.GetUser(context.TODO(), &User{Name:
"Alex001"})
- assert.Nil(t, err)
- assert.NotNil(t, user)
- assert.Equal(t, user.ID, "A001")
- assert.Equal(t, user.Name, "Alex Stocks")
- assert.Equal(t, user.Age, 18)
-
- user, err =
userProviderWithCustomRegistryGroupAndVersion.GetUser(context.TODO(),
&User{Name: "Alex001"})
- assert.Nil(t, err)
- assert.Equal(t, user.Name, "Alex Stocks from
UserProviderWithCustomGroupAndVersion")
- assert.Equal(t, user.Age, 18)
-}
diff --git a/integrate_test/dockercompose/docker-compose.yml
b/integrate_test/dockercompose/docker-compose.yml
index e71f7c9b..c4dc34cc 100644
--- a/integrate_test/dockercompose/docker-compose.yml
+++ b/integrate_test/dockercompose/docker-compose.yml
@@ -22,18 +22,6 @@ services:
test: "curl --fail
http://127.0.0.1:8848/nacos/v1/console/health/liveness || exit 1"
interval: 5s
- polaris:
- image: polarismesh/polaris-standalone:latest
- container_name: polaris-standalone
- privileged: true
- ports:
- - "8090:8090"
- - "8091:8091"
- - "8093:8093"
- healthcheck:
- test: "curl --fail http://127.0.0.1:8090 || exit 1"
- interval: 5s
-
etcd:
image: "quay.io/coreos/etcd:v3.4.28"
container_name: etcd
diff --git a/start_integrate_test.sh b/start_integrate_test.sh
index 49b2f46b..b5201565 100755
--- a/start_integrate_test.sh
+++ b/start_integrate_test.sh
@@ -94,10 +94,6 @@ array+=("rpc/multi-protocols")
# async
array+=("compatibility/async")
-# polaris
-array+=("compatibility/polaris/registry")
-array+=("compatibility/polaris/limit")
-
# error
array+=("error")
