You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2022/05/20 02:29:19 UTC
[dubbo-go] branch develop updated (d72ec8978 -> f6405fa79)
This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
from d72ec8978 Merge branch 'master' into develop
add 8e0902b64 godoc (#1755)
add 8eb68a613 Merge branch 'apache:3.0' into 3.0
add 2aabad5e9 update package comment (#1755)
add 0bd51f5b8 imports formatter (#1755)
add 3fc6fc3ea Merge branch '3.0' into 3.0
add e0bfc0166 filter/graceful_shutdown license (#1755)
add caa87ada7 filter/graceful_shutdown license (#1755)
add a0a1051be update some comment (#1755)
add 088b380aa gofmt (#1755)
add 3cb45bb10 Update version.go
add be7b3ff09 comment for blank (#1755)
add a926315e5 comment (#1755)
add ec1c81c4e Merge branch 'apache:3.0' into 3.0
add b427fcb90 Merge branch 'apache:3.0' into 3.0
add cd8eb96a7 Merge branch 'apache:3.0' into 3.0
add ced9e219a Merge branch 'apache:3.0' into 3.0
add 60d1c2a94 revert prometheus rename pr
add d8014bdc2 Fix: xds enhancement
add 6838e2a55 Merge remote-tracking branch 'upstream/3.0' into xds-feat-enhancement
add dde8baa6f fix: comment
add 84a131cb4 Merge pull request #1853 from LaurenceLiZhixin/xds-feat-enhancement
add e18914ce9 Merge branch 'apache:3.0' into 3.0
add 182bbd1cd build(deps): bump github.com/fsnotify/fsnotify from 1.5.1 to 1.5.3 (#1864)
add 2374989ef build(deps): bump github.com/mitchellh/mapstructure from 1.4.3 to 1.5.0 (#1863)
add 406f8013f build(deps): bump go.etcd.io/etcd/server/v3 from 3.5.2 to 3.5.4 (#1861)
add dcded418c Merge branch 'apache:3.0' into 3.0
add b04354549 ut mock nacos and etcd (#1774)
add d9d98c98d mock nacos nolint
add 03155c978 mock etcd nolint
add a866e01ca ut mock update (#1774)
add 6d7462ad6 build(deps): bump github.com/google/go-cmp from 0.5.7 to 0.5.8 (#1871)
add 8b3b71ec2 xds ring hash (#1828)
add e92d63592 add nacos updateCacheWhenEmpty (#1852)
add 7d4af3b08 Tst:mock etcd and nacos in ut (#1873)
add 2b928aaca build(deps): bump github.com/fsnotify/fsnotify from 1.5.3 to 1.5.4 (#1872)
add 65943004f build(deps): bump github.com/go-playground/validator/v10 (#1877)
add a24957d5e build(deps): bump github/codeql-action from 1 to 2 (#1876)
add 82cfcf624 Merge branch 'apache:3.0' into 3.0
add 6d178b148 gomonkey delete (#1774)
add ea02d8ad1 Merge pull request #1881 from pherzheyu/feature/monkey-move
add 8dc50cc72 Rem:remove meshrouter and v3router (#1882)
add bd9806c9c fix: limit rpc package data size by user's config rather than DEFAULT_LEN. (#1848)
add b27ec53b7 Use summary type to observe p99 (#1875)
add c7bab46a2 build(deps): bump github.com/polarismesh/polaris-go from 1.0.2 to 1.1.0 (#1885)
add 4a62aa28e Merge branch 'develop'
add 6e2c29003 feat: leastActiveLoadBalance code optimization, according to dubbo-java optimization records. For example: https://github.com/apache/dubbo/pull/2962 https://github.com/apache/dubbo/pull/5909
add a463b2a01 Merge pull request #1884 from Codeprh/OptimizedLoadBalancingAlgorithm
add dba1d8e51 fix: complete grpc based protocol panic recover handle. (#1866)
add 6017b2bee Fix: typo, rename procider_filter_test.go to provider_filter_test.go (#1887) (#1888)
add 90336d981 Ftr:otel trace (#1886)
add 01de5d587 feat: RandomLoadBalance code optimization, update that how to judge the same weight
add f6405fa79 Merge pull request #1899 from Codeprh/feture/loadBalancingAlgorithmUpdate
No new revisions were added by this update.
Summary of changes:
.github/workflows/codeql-analysis.yml | 6 +-
.github/workflows/github-actions.yml | 2 +
cluster/cluster/zoneaware/cluster_invoker_test.go | 4 +-
cluster/loadbalance/leastactive/loadbalance.go | 29 +-
cluster/loadbalance/random/loadbalance.go | 23 +-
cluster/loadbalance/ringhash/ring.go | 174 ++++++
cluster/loadbalance/ringhash/ringhash.go | 87 +++
cluster/loadbalance/ringhash/ringhash_test.go | 98 ++++
cluster/router/meshrouter/factory.go | 41 --
cluster/router/meshrouter/meshrouter.go | 187 ------
cluster/router/v3router/factory.go | 41 --
.../v3router/judger/attachment_match_judger.go | 67 ---
.../judger/attachment_match_judger_test.go | 54 --
.../router/v3router/judger/bool_match_judger.go | 39 --
.../v3router/judger/bool_match_judger_test.go | 48 --
.../router/v3router/judger/double_match_judger.go | 49 --
.../v3router/judger/double_match_judger_test.go | 61 --
.../v3router/judger/double_range_match_judger.go | 39 --
.../judger/double_range_match_judger_test.go | 47 --
.../v3router/judger/list_double_match_judger.go | 44 --
.../judger/list_double_match_judger_test.go | 100 ----
.../v3router/judger/list_string_match_judger.go | 44 --
.../judger/list_string_match_judger_test.go | 40 --
.../router/v3router/judger/method_match_judger.go | 90 ---
.../v3router/judger/method_match_judger_test.go | 77 ---
.../router/v3router/judger/string_match_judger.go | 60 --
.../v3router/judger/string_match_judger_test.go | 56 --
.../v3router/judger/url_label_match_judge.go | 32 --
.../v3router/judger/url_label_match_judge_test.go | 41 --
cluster/router/v3router/k8s_api/k8s.go | 41 --
.../v3router/k8s_api/listener_handler_impl.go | 200 -------
cluster/router/v3router/k8s_crd/client.go | 137 -----
.../v3router/k8s_crd/deploy/unifom_router_crd.yml | 43 --
.../router/v3router/k8s_crd/listener_handler.go | 36 --
cluster/router/v3router/router_chain.go | 259 ---------
cluster/router/v3router/router_chain_test.go | 247 --------
cluster/router/v3router/test_file/dest_rule.yml | 17 -
.../router/v3router/test_file/virtual_service.yml | 158 ------
cluster/router/v3router/uniform_route.go | 83 ---
cluster/router/v3router/uniform_rule.go | 258 ---------
common/constant/key.go | 5 +-
common/constant/loadbalance.go | 1 +
common/constant/xds.go | 4 +
common/proxy/proxy_factory/default.go | 26 +-
common/proxy/proxy_factory/pass_through.go | 16 +-
.../proxy/proxy_factory/utils.go | 52 +-
config/metric_config.go | 2 +
config/uniform_router_config.go | 218 -------
config/uniform_router_config_test.go | 42 --
config_center/nacos/impl_test.go | 262 +++++++--
...ider_filter_test.go => provider_filter_test.go} | 0
filter/otel/trace/attachment.go | 84 +++
filter/otel/trace/attachment_test.go | 131 +++++
.../adaptivesvc => filter/otel/trace}/doc.go | 5 +-
filter/otel/trace/filter.go | 144 +++++
filter/otel/trace/filter_test.go | 631 +++++++++++++++++++++
.../otel/trace/semconv.go | 29 +-
.../utils.go => filter/otel/trace/version.go | 18 +-
.../otel/trace/version_test.go | 53 +-
go.mod | 23 +-
go.sum | 222 ++------
imports/imports.go | 2 +-
metadata/report/etcd/report_test.go | 408 +++++++++----
metadata/report/nacos/report_test.go | 489 ++++++++++++++--
metrics/prometheus/reporter.go | 28 +-
metrics/reporter.go | 4 +
protocol/dubbo/hessian2/hessian_request.go | 5 +-
protocol/dubbo/hessian2/hessian_response.go | 5 +-
protocol/dubbo/impl/codec.go | 10 +-
registry/directory/directory_test.go | 4 +-
registry/etcdv3/listener_test.go | 101 ++--
registry/etcdv3/registry_test.go | 173 +++---
registry/nacos/registry_test.go | 450 +++++++++------
registry/xds/registry.go | 9 +-
remoting/etcdv3/listener_test.go | 132 +----
remoting/getty/listener.go | 23 +-
remoting/getty/readwriter.go | 23 +
remoting/nacos/builder.go | 33 +-
remoting/nacos/builder_test.go | 271 +++++----
remoting/xds/client.go | 26 +
remoting/xds/ewatcher/ewatcher.go | 2 +
remoting/xds/mocks/client.go | 76 +++
82 files changed, 3276 insertions(+), 4125 deletions(-)
create mode 100644 cluster/loadbalance/ringhash/ring.go
create mode 100644 cluster/loadbalance/ringhash/ringhash.go
create mode 100644 cluster/loadbalance/ringhash/ringhash_test.go
delete mode 100644 cluster/router/meshrouter/factory.go
delete mode 100644 cluster/router/meshrouter/meshrouter.go
delete mode 100644 cluster/router/v3router/factory.go
delete mode 100644 cluster/router/v3router/judger/attachment_match_judger.go
delete mode 100644 cluster/router/v3router/judger/attachment_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/bool_match_judger.go
delete mode 100644 cluster/router/v3router/judger/bool_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/double_match_judger.go
delete mode 100644 cluster/router/v3router/judger/double_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/double_range_match_judger.go
delete mode 100644 cluster/router/v3router/judger/double_range_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/list_double_match_judger.go
delete mode 100644 cluster/router/v3router/judger/list_double_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/list_string_match_judger.go
delete mode 100644 cluster/router/v3router/judger/list_string_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/method_match_judger.go
delete mode 100644 cluster/router/v3router/judger/method_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/string_match_judger.go
delete mode 100644 cluster/router/v3router/judger/string_match_judger_test.go
delete mode 100644 cluster/router/v3router/judger/url_label_match_judge.go
delete mode 100644 cluster/router/v3router/judger/url_label_match_judge_test.go
delete mode 100644 cluster/router/v3router/k8s_api/k8s.go
delete mode 100644 cluster/router/v3router/k8s_api/listener_handler_impl.go
delete mode 100644 cluster/router/v3router/k8s_crd/client.go
delete mode 100644 cluster/router/v3router/k8s_crd/deploy/unifom_router_crd.yml
delete mode 100644 cluster/router/v3router/k8s_crd/listener_handler.go
delete mode 100644 cluster/router/v3router/router_chain.go
delete mode 100644 cluster/router/v3router/router_chain_test.go
delete mode 100644 cluster/router/v3router/test_file/dest_rule.yml
delete mode 100644 cluster/router/v3router/test_file/virtual_service.yml
delete mode 100644 cluster/router/v3router/uniform_route.go
delete mode 100644 cluster/router/v3router/uniform_rule.go
copy config/ssl_config_test.go => common/proxy/proxy_factory/utils.go (55%)
delete mode 100644 config/uniform_router_config.go
delete mode 100644 config/uniform_router_config_test.go
rename filter/graceful_shutdown/{procider_filter_test.go => provider_filter_test.go} (100%)
create mode 100644 filter/otel/trace/attachment.go
create mode 100644 filter/otel/trace/attachment_test.go
copy {cluster/cluster/adaptivesvc => filter/otel/trace}/doc.go (86%)
create mode 100644 filter/otel/trace/filter.go
create mode 100644 filter/otel/trace/filter_test.go
copy registry/servicediscovery/synthesizer/subscribed_urls_synthesizer_factory.go => filter/otel/trace/semconv.go (61%)
copy cluster/metrics/utils.go => filter/otel/trace/version.go (71%)
copy protocol/dubbo/impl/serialization.go => filter/otel/trace/version_test.go (57%)
create mode 100644 remoting/xds/mocks/client.go