Merge branch 'apache:master' into support_gracefully_offline_without_…

…registry

.github/dependabot.yml

@@ -16,5 +16,5 @@ updates:
     # default location of `.github/workflows`
     directory: "/"
     schedule:
-      interval: "weekly"
+      interval: "monthly"
     target-branch: "3.0"

CHANGELOG.md

@@ -1,5 +1,40 @@
 # Release Notes
 ---
+## 3.0.2
+
+### Features
+
+- [Support hessian java method java.lang param](https://github.com/apache/dubbo-go/pull/1783)
+- [Support istio xds](https://github.com/apache/dubbo-go/pull/1804)
+- [Support istio xds ring hash](https://github.com/apache/dubbo-go/pull/1828)
+- [Support otel trace](https://github.com/apache/dubbo-go/pull/1886)
+
+### Bugfixs
+
+- [Fix: where limitation not updates](https://github.com/apache/dubbo-go/pull/1784)
+- [Fix: rootConfig and getty-session-param](https://github.com/apache/dubbo-go/pull/1802)
+- [Fix: xds adsz empty metadata](https://github.com/apache/dubbo-go/pull/1813)
+- [Fix: decode net stream bytes as getty rule](https://github.com/apache/dubbo-go/pull/1820)
+- [Fix: ip register issue](https://github.com/apache/dubbo-go/pull/1821)
+- [Fix: getty unit test](https://github.com/apache/dubbo-go/pull/1829)
+- [Fix: remove HEADER_LENGTH in decode because of discard](https://github.com/apache/dubbo-go/pull/1831)
+- [Fix: xds log use dubbogo logger](https://github.com/apache/dubbo-go/pull/1846)
+- [Fix: limit rpc package data size by user's config rather than DEFAULT_LEN](https://github.com/apache/dubbo-go/pull/1848)
+- [Fix: complete grpc based protocol panic recover handle](https://github.com/apache/dubbo-go/pull/1866)
+
+### Enhancements
+
+- [Add req.Data to OnMessage panic error log](https://github.com/apache/dubbo-go/pull/1847)
+- [Add nacos updateCacheWhenEmpty options](https://github.com/apache/dubbo-go/pull/1852)
+- [Xds enhancement](https://github.com/apache/dubbo-go/pull/1853)
+- [Mock etcd and nacos in ut](https://github.com/apache/dubbo-go/pull/1873)
+- [Use summary type to observe p99](https://github.com/apache/dubbo-go/pull/1875)
+- [Remove gomonkey](https://github.com/apache/dubbo-go/pull/1881)
+- [Optimized load balancing algorithm](https://github.com/apache/dubbo-go/pull/1884)
+- [RandomLoadBalance code optimization](https://github.com/apache/dubbo-go/pull/1899)
+- [Export hessian type api](https://github.com/apache/dubbo-go/pull/1911)
+- [Export method getArgsTypeList for extension](https://github.com/apache/dubbo-go/pull/1913)
+
 
 ## 3.0.1
 

README.md

@@ -27,7 +27,7 @@ Dubbo-go has supported many RPC protocol, like Triple, Dubbo JSONRPC, gRPC, HTTP
 ![](https://dubbogo.github.io/img/devops.png)
 
 - **Registry**: Nacos, Zookeeper, ETCD, Polaris-mesh, Consul.
-- **ConfigCenter**: Nacos, Apollo, Zookeeper
+- **ConfigCenter**: Nacos, Zookeeper
 - **Cluster Strategy**: Failover, [Failfast](https://github.com/apache/dubbo-go/pull/140), [Failsafe/Failback](https://github.com/apache/dubbo-go/pull/136), [Available](https://github.com/apache/dubbo-go/pull/155), [Broadcast](https://github.com/apache/dubbo-go/pull/158), [Forking](https://github.com/apache/dubbo-go/pull/161)
 - **Load Balance**: [AdaptiveService](https://github.com/apache/dubbo-go/pull/1649), Random, [RoundRobin](https://github.com/apache/dubbo-go/pull/66), [LeastActive](https://github.com/apache/dubbo-go/pull/65), [ConsistentHash](https://github.com/apache/dubbo-go/pull/261)
 - [**Filter**](./filter): Echo, Hystrix, Token, AccessLog, TpsLimiter, ExecuteLimit, Generic, Auth/Sign, Metrics, Tracing, Active, Seata, Sentinel

README_CN.md

@@ -32,7 +32,7 @@ Dubbo-go 生态覆盖多种网络协议：Triple、Dubbo、JSONRPC、gRPC、HTTP
 
 - **配置中心**
 
-  开发者可以使用Nacos、Apollo（携程开源）、Zookeeper 进行框架/用户的配置的发布和拉取。
+  开发者可以使用Nacos、Zookeeper 进行框架/用户的配置的发布和拉取。
 
 - **集群策略**: Failover, [Failfast](https://github.com/apache/dubbo-go/pull/140), [Failsafe/Failback](https://github.com/apache/dubbo-go/pull/136), [Available](https://github.com/apache/dubbo-go/pull/155), [Broadcast](https://github.com/apache/dubbo-go/pull/158), [Forking](https://github.com/apache/dubbo-go/pull/161) 等
 

cluster/cluster/adaptivesvc/cluster_invoker.go

@@ -23,6 +23,8 @@ import (
 )
 
 import (
+	"github.com/dubbogo/gost/log/logger"
+
 	perrors "github.com/pkg/errors"
 )
 
@@ -33,7 +35,6 @@ import (
 	clsutils "dubbo.apache.org/dubbo-go/v3/cluster/utils"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
 	"dubbo.apache.org/dubbo-go/v3/common/extension"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/cluster/base/cluster_invoker.go

@@ -19,6 +19,8 @@
 package base
 
 import (
+	"github.com/dubbogo/gost/log/logger"
+
 	perrors "github.com/pkg/errors"
 
 	"go.uber.org/atomic"
@@ -30,7 +32,6 @@ import (
 	"dubbo.apache.org/dubbo-go/v3/common"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
 	"dubbo.apache.org/dubbo-go/v3/common/extension"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/cluster/broadcast/cluster_invoker.go

@@ -21,10 +21,13 @@ import (
 	"context"
 )
 
+import (
+	"github.com/dubbogo/gost/log/logger"
+)
+
 import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/cluster/base"
 	"dubbo.apache.org/dubbo-go/v3/cluster/directory"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/cluster/failback/cluster_invoker.go

@@ -26,6 +26,8 @@ import (
 
 import (
 	"github.com/Workiva/go-datastructures/queue"
+
+	"github.com/dubbogo/gost/log/logger"
 )
 
 import (
@@ -34,7 +36,6 @@ import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
 	"dubbo.apache.org/dubbo-go/v3/common/extension"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/cluster/failover/cluster_invoker.go

@@ -24,6 +24,8 @@ import (
 )
 
 import (
+	"github.com/dubbogo/gost/log/logger"
+
 	perrors "github.com/pkg/errors"
 )
 
@@ -32,7 +34,6 @@ import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/directory"
 	"dubbo.apache.org/dubbo-go/v3/common"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/cluster/failsafe/cluster_invoker.go

@@ -21,12 +21,15 @@ import (
 	"context"
 )
 
+import (
+	"github.com/dubbogo/gost/log/logger"
+)
+
 import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/cluster/base"
 	"dubbo.apache.org/dubbo-go/v3/cluster/directory"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
 	"dubbo.apache.org/dubbo-go/v3/common/extension"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/cluster/forking/cluster_invoker.go

@@ -25,13 +25,14 @@ import (
 
 import (
 	"github.com/Workiva/go-datastructures/queue"
+
+	"github.com/dubbogo/gost/log/logger"
 )
 
 import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/cluster/base"
 	"dubbo.apache.org/dubbo-go/v3/cluster/directory"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/cluster/mock.go

@@ -22,13 +22,14 @@ import (
 )
 
 import (
+	"github.com/dubbogo/gost/log/logger"
+
 	perrors "github.com/pkg/errors"
 )
 
 import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/directory"
 	"dubbo.apache.org/dubbo-go/v3/common"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/loadbalance/p2c/loadbalance.go

@@ -25,12 +25,15 @@ import (
 	"time"
 )
 
+import (
+	"github.com/dubbogo/gost/log/logger"
+)
+
 import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
 	"dubbo.apache.org/dubbo-go/v3/cluster/metrics"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
 	"dubbo.apache.org/dubbo-go/v3/common/extension"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

cluster/loadbalance/ringhash/ringhash.go

@@ -21,12 +21,15 @@ import (
 	"strconv"
 )
 
+import (
+	"github.com/dubbogo/gost/log/logger"
+)
+
 import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
 	"dubbo.apache.org/dubbo-go/v3/common"
 	"dubbo.apache.org/dubbo-go/v3/common/constant"
 	"dubbo.apache.org/dubbo-go/v3/common/extension"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 	"dubbo.apache.org/dubbo-go/v3/remoting/xds"
 )

cluster/router/chain/chain.go

@@ -23,6 +23,8 @@ import (
 )
 
 import (
+	"github.com/dubbogo/gost/log/logger"
+
 	perrors "github.com/pkg/errors"
 
 	"go.uber.org/atomic"
@@ -32,7 +34,6 @@ import (
 	"dubbo.apache.org/dubbo-go/v3/cluster/router"
 	"dubbo.apache.org/dubbo-go/v3/common"
 	"dubbo.apache.org/dubbo-go/v3/common/extension"
-	"dubbo.apache.org/dubbo-go/v3/common/logger"
 	"dubbo.apache.org/dubbo-go/v3/protocol"
 )
 

config_center/apollo/doc.go → cluster/router/meshrouter/factory.go

@@ -15,5 +15,27 @@
  * limitations under the License.
  */
 
-// Package apollo implements config center around Apollo.
-package apollo
+package meshrouter
+
+import (
+	"dubbo.apache.org/dubbo-go/v3/cluster/router"
+	"dubbo.apache.org/dubbo-go/v3/common/constant"
+	"dubbo.apache.org/dubbo-go/v3/common/extension"
+)
+
+func init() {
+	extension.SetRouterFactory(constant.MeshRouterFactoryKey, NewMeshRouterFactory)
+}
+
+// MeshRouterFactory is mesh router's factory
+type MeshRouterFactory struct{}
+
+// NewMeshRouterFactory constructs a new PriorityRouterFactory
+func NewMeshRouterFactory() router.PriorityRouterFactory {
+	return &MeshRouterFactory{}
+}
+
+// NewPriorityRouter construct a new UniformRouteFactory as PriorityRouter
+func (f *MeshRouterFactory) NewPriorityRouter() (router.PriorityRouter, error) {
+	return NewMeshRouter()
+}