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 2021/12/13 05:16:39 UTC

[dubbo-go] branch develop updated (891357a -> 9a12e99)

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 891357a  Merge branch '3.0' into develop
     add 7b3c4c8  build(deps): bump github.com/hashicorp/vault/sdk from 0.2.1 to 0.3.0 (#1552)
     add a4641f5  delete useless codes (#1551)
     add bbd2bda  Update CHANGELOG.md
     add 1d2647d  [#1559]: adjust the startup process of the configuration center (#1560)
     add 35d27b4  [#1276]modify the name of the receiver to a single character (#1561)
     add 27aaaa9  style(common): rename constants in camel-case style (#1563)
     add 0b33524  register not use metadata configuration.
     add 5b74bf6  fix: registry param
     add ff58c2a  fix: #1558: Set root config to global ptr in Init() function. (#1564)
     add cbb502f  Triple upgrade to grpc (#1566)
     add b275568  build(deps): bump github.com/go-resty/resty/v2 from 2.3.0 to 2.7.0 (#1579)
     add 85ee27d  build(deps): bump google.golang.org/grpc from 1.41.0 to 1.42.0 (#1578)
     add 6fe0c94  build(deps): bump github.com/knadh/koanf from 1.3.0 to 1.3.2 (#1577)
     add 268e072  Merge branch '3.0'
     add 7802cca  Merge branch 'develop'
     add 42ef7fe  fix: CONTRIBUTING.md url error. (#1303)
     add a109967  add lock (#1304)
     add 808862e  Revert "add lock (#1304)" (#1329)
     add 343ba6a  Merge branch 'master' of https://github.com/apache/dubbo-go
     add d32db09  Merge branch 'develop'
     add 481eb47  Merge branch 'develop'
     add bfca099  Merge remote-tracking branch 'apache/develop'
     add cc7af11  Merge branch 'develop'
     add ebaa5b6  fix: in the Consumer service, the Reference config property ‘check’ use the Consumer config when omitted
     add f56cb86  Merge remote-tracking branch 'upstream/3.0' into fix/consumer_check
     add eb6010c  Merge pull request #1568 from PhilYue/fix/consumer_check
     add 8a011a9  Merge remote-tracking branch 'upstream/3.0' into 20211102_nacos
     add 8f41bd1  fix: fix ns and group
     add 94434b4  fix: integrate test
     add 2ebc38b  Fix: integrate test
     add 001f95c  fix: url fmt
     add 0c85c55  Merge pull request #1565 from sanxun0325/20211102_nacos
     add f38a0c2  fix: nacos servicediscovery group
     add b02124d  Fix: enhance zk
     add fce2f73  Merge pull request #1581 from apache/fix/nacos-2.0
     add 3182c7a  start application (#1571)
     add 4185062  graceful shutdwon filter (#1585)
     add 1fdd429  Fix: some bugs and features for 3.0 (#1586)
     add b90089d  hessian encode attachments return error (#1588)
     add 2ae0b3e  upgrade hessian to v1.9.5 (#1595)
     add 19c0bb9  refactor listenDirEvent 1. remove CLEAR label; 2. remove register/unregister logic for watch children; 3. reorder the zk dynamic configuration code 4. adapt the gost
     add 4d780a9  upgrade gost dependency version
     add a812919  Merge pull request #1589 from Mulavar/3.0
     add cc201e9  build(deps): bump k8s.io/apimachinery from 0.16.9 to 0.22.4 (#1600)
     add 5c115cb  ftr: triple tracing (#1596)
     add 7b6ec92  add:go imports tool
     add 39552b2  up:go version
     add d1d8c84  up:go path
     add 3692b68  up:imports version
     add ceabbc6  rm cache
     add 39026d6  add improts fmt
     add 16d0915  fmt
     add 34f2d44  fmt
     add 0d942ff  fmt path
     add 47be96e  fmt
     add 1ed602f  up imports version
     add df9f3f9  [fix #1590] filter single instance (#1591)
     add 7d08891  Ftr/triple reflect support (#1603)
     add 03cf5fd  fix: nacos method key (#1608)
     add 89d6043  Merge remote-tracking branch 'upstream/3.0' into imports-ci
     add a9a43e1  fmt
     add 1c92dde  Merge pull request #1602 from zhaoyunxing92/imports-ci
     add fe19465  fix: fix service group and version key (#1612)
     add 938e7bf  local mode, metadata mapping is reported using registration information (#1611)
     add 70deec6  feat: change log to dubbo go logger
     add a6aa373  Merge pull request #1617 from cjphaha/feature/cjphaha_use_dubbo_logger
     add d1530fe  build(deps): bump github.com/knadh/koanf from 1.3.2 to 1.3.3 (#1622)
     add 8903514  build(deps): bump github.com/emicklei/go-restful/v3 from 3.7.1 to 3.7.2 (#1623)
     add a7bbf32  build(deps): bump actions/cache from 2.1.6 to 2.1.7 (#1621)
     add 1bd06c1  nacos support UnRegister and  UnSubscribe (#1616)
     add a8fba70  [ISSUE #1601] polarismesh registry center (#1620)
     add f7f1581  add:support file extension (#1626)
     add 4748b93  fix(dubbo): fix issus where result.attrs is not sent (#1636)
     add 78ca361  fix: attachments maybe nil or empty string (#1631)
     add db09e49  FIX:Array boundary problem (#1630)
     add a2c0731  fix a logic bug (#1639)
     add 44f7911  add Readme ecosystem (#1641)
     add ec43e22  avoid the problem of cpu idling & fix wrong definition of error (#1629)
     add a56b342  build(deps): bump github.com/jinzhu/copier from 0.3.2 to 0.3.4 (#1628)
     add 0603eed  update copier version 0.3.2 (#1647)
     add 6523e3d  build(deps): bump github.com/mitchellh/mapstructure from 1.4.2 to 1.4.3 (#1642)
     add 87dd52c  unified nacos user and password obtaining path (#1645)
     add 7bb88bf  build(deps): bump github.com/apache/dubbo-go-hessian2 (#1643)
     add 30b5e18  hessian2 support setting type of Java method parameters (#1625)
     add 22ec041  build(deps): bump github.com/polarismesh/polaris-go from 1.0.0 to 1.0.1 (#1652)
     add e4fa5df  Add: user define config (#1640)
     add 8f8cf96  feat(adasvc): add infrastructure for adaptive service
     add 4dfc01e  feat(adasvc): reference config support adaptive service
     add 2ca1018  feat(adasvc): add p2c load balance
     add e83a8a6  feat(cluster): add capacity evaluator interface
     add f0c64e6  feat(cluster): add capacity updater
     add 69dd9d3  feat(cluster): add capacity updater
     add 2db43f7  feat(cluster): add fields to vegas capeva
     add 588f392  feat(cluster): refactor capeva interface
     add e0a4d1a  feat(cluster): add more fields to vegas capeva
     add 9af855a  feat(cluster): vegas evaupdater done
     add 785c74c  Merge branch '3.0' into feat/adasvc
     add 1d5fca1  fix(common): fix typo
     add 7a537ff  fix(common): fix typo
     add 6d866b5  fix(cluster): add apache license
     add 865c058  feat(cluster): define limiter & update interface
     add 9d26e68  Merge branch '3.0' into feat/adasvc
     add c3f9dbe  feat(cluster): remove cpu stat temporarily
     add ff4e60b  feat(cluster): update hill climbing limiter
     add 0472bf1  feat(cluster): hill climbing done
     add 7e98a27  Merge branch '3.0' into feat/adasvc
     add 70ca487  fix(cluster): fix issue where init limitation is 0
     add c949cef  Merge branch '3.0' into feat/adasvc
     add ece019f  feat(cluster): provder-side filter done
     add bf43b0b  fix(cluster): fix uint64 subtraction issue
     add d8ca7f1  fix(cluster): add adaptivesvc filter to default service filters
     add 30dcb14  style: go fmt
     add 5b48b40  fix(filter): import adaptivesvc
     add 99f6919  Merge branch '3.0' into feat/adasvc
     add f906714  Merge branch '3.0' into feat/adasvc
     add c7edac5  fix(imports): import adaptivesvc cluster and p2c loadbalance
     add 73b4f70  fix(config): fix unexpectedly panic
     add 1fa48ca  feat(adasvc): add debug logs
     add 0acc52e  fix(adasvc): pass attachements with string
     add e5de62f  feat(adasvc): detail debug logs
     add 6f1d7bf  fix(adasvc): fix log info
     add 4a04d4a  feat: detail dubbo logs
     add 4ed7505  feat: remove useless logs
     add 8b12eac  fix(adasvc): fix incorrect type
     add 9ac6763  Merge branch '3.0' into feat-adasvc
     add c23612b  style: go fmt & dubbofmt
     add 0f7459b  fix: rpc result attrs is not initialized
     add 429a336  fix(protocol): fix result panic when attrs is not initialized
     add bfc336e  Merge branch '3.0' into feat-adasvc
     add 55e9fdf  Merge pull request #1649 from apache/feat-adasvc
     add 0ff42ce  Ftr: add triple max size configuration (#1654)
     add 8f207c3  build(deps): bump github.com/emicklei/go-restful/v3 from 3.7.2 to 3.7.3 (#1651)
     add d411e11  support set nacos ContextPath (#1656)
     add d4d6e42  fix: update changelog and readme
     add 36d8d83  fix: update changelog and readme
     add 9a12e99  Fix: doc conflict

No new revisions were added by this update.

Summary of changes:
 .github/workflows/github-actions.yml               |  16 +-
 CHANGELOG.md                                       | 185 ++++
 README.md                                          |  56 +-
 README_CN.md                                       |  70 +-
 .../cluster/{failfast => adaptivesvc}/cluster.go   |  34 +-
 cluster/cluster/adaptivesvc/cluster_invoker.go     |  85 ++
 cluster/cluster/available/cluster_invoker.go       |   6 +-
 cluster/cluster/available/cluster_invoker_test.go  |   4 +-
 cluster/cluster/base/cluster_invoker.go            |  14 +-
 cluster/cluster/broadcast/cluster_invoker_test.go  |   2 +-
 cluster/cluster/failback/cluster_invoker.go        |  12 +-
 cluster/cluster/failback/cluster_test.go           |   2 +-
 cluster/cluster/failfast/cluster_test.go           |   2 +-
 cluster/cluster/failover/cluster_invoker.go        |   8 +-
 cluster/cluster/failover/cluster_test.go           |   6 +-
 cluster/cluster/failsafe/cluster_invoker.go        |   4 +-
 cluster/cluster/failsafe/cluster_test.go           |   2 +-
 cluster/cluster/forking/cluster_invoker.go         |   4 +-
 cluster/cluster/forking/cluster_test.go            |  10 +-
 cluster/cluster/zoneaware/cluster_interceptor.go   |   2 +-
 cluster/cluster/zoneaware/cluster_invoker.go       |   6 +-
 cluster/cluster/zoneaware/cluster_invoker_test.go  |  30 +-
 cluster/cluster_impl/import.go                     |   3 +-
 cluster/directory/base/directory.go                |   6 +-
 cluster/directory/base/directory_test.go           |  34 +-
 .../loadbalance/consistenthashing/loadbalance.go   |   2 +-
 .../loadbalance/leastactive/loadbalance_test.go    |   2 +-
 cluster/loadbalance/p2c/loadbalance.go             | 129 +++
 cluster/loadbalance/random/loadbalance_test.go     |   4 +-
 cluster/loadbalance/roundrobin/loadbalance_test.go |   2 +-
 cluster/loadbalance/util.go                        |  10 +-
 .../doc.go => cluster/metrics/constants.go         |   6 +-
 cluster/metrics/local_metrics.go                   |  80 ++
 cluster/metrics/metrics.go                         |  49 ++
 .../facade.go => cluster/metrics/utils.go          |  16 +-
 .../v3router/judger/attachment_match_judger.go     |   6 +-
 .../router/v3router/judger/bool_match_judger.go    |   4 +-
 .../router/v3router/judger/double_match_judger.go  |  12 +-
 .../v3router/judger/double_range_match_judger.go   |   4 +-
 .../v3router/judger/list_double_match_judger.go    |   4 +-
 .../v3router/judger/list_string_match_judger.go    |   4 +-
 .../router/v3router/judger/method_match_judger.go  |  16 +-
 .../router/v3router/judger/string_match_judger.go  |  18 +-
 cluster/router/v3router/router_chain.go            |   7 +-
 cluster/router/v3router/uniform_rule.go            |  16 +-
 common/config/environment_test.go                  |   1 +
 common/constant/cluster.go                         |  17 +-
 common/constant/default.go                         |  97 ++-
 common/constant/env.go                             |   8 +-
 common/constant/key.go                             | 386 +++++----
 common/constant/loadbalance.go                     |   1 +
 common/constant/serialization.go                   |  10 +-
 common/extension/metadata_service.go               |   2 +-
 common/extension/metadata_service_exporter.go      |   2 +-
 common/extension/metadata_service_proxy_factory.go |   2 +-
 common/extension/service_discovery.go              |  11 +-
 common/{constant/version.go => file/suffix.go}     |  20 +-
 common/metadata_info.go                            |  32 +-
 common/proxy/proxy.go                              |  37 +-
 common/proxy/proxy_factory/default.go              |   2 +-
 common/proxy/proxy_factory/pass_through.go         |   4 +-
 common/proxy/proxy_test.go                         |   4 +-
 common/rpc_service.go                              |  16 +-
 common/url.go                                      |  54 +-
 common/url_test.go                                 |  46 +-
 config/config_center_config.go                     |  70 +-
 config/config_loader.go                            |  27 +-
 config/config_loader_options.go                    |  74 +-
 config/config_loader_options_test.go               |  39 +-
 config/config_resolver.go                          |   9 +-
 config/config_utils.go                             |   6 +-
 config/consumer_config.go                          |  30 +-
 config/custom_config.go                            |  80 ++
 config/custom_config_test.go                       |  68 ++
 config/graceful_shutdown.go                        |   2 +-
 ...adata_report.go => registry_metadata_report.go} |  42 +-
 config/instance/registry_metadata_report_test.go   |  64 ++
 config/metadata_report_config.go                   |  26 +-
 config/method_config.go                            |   4 +-
 config/provider_config.go                          |  66 +-
 config/reference_config.go                         | 122 +--
 config/registry_config.go                          |  68 +-
 config/registry_config_test.go                     |   1 +
 config/remote_config.go                            |   6 +-
 config/root_config.go                              |  37 +-
 config/service_config.go                           | 124 +--
 .../{logger/empty_log.yaml => custom/custom.yaml}  |   6 +-
 .../application.yaml => custom/empty.yaml}         |   3 +-
 .../serialization.go => config/tracing_config.go   |  38 +-
 config_center/apollo/impl.go                       |  14 +-
 config_center/apollo/impl_test.go                  |   1 +
 config_center/apollo/mockDubbogo.yaml.json         |   1 +
 config_center/configurator/mock.go                 |   6 +-
 config_center/configurator/override.go             |  46 +-
 config_center/configurator/override_test.go        |   9 +-
 config_center/dynamic_configuration.go             |   8 +-
 config_center/file/factory.go                      |   2 +-
 config_center/file/impl.go                         |   2 +-
 config_center/nacos/impl.go                        |  20 +-
 config_center/nacos/listener.go                    |   4 +-
 config_center/parser/configuration_parser.go       |  18 +-
 config_center/zookeeper/impl.go                    |  29 +-
 config_center/zookeeper/listener.go                |  12 +-
 filter/accesslog/filter.go                         |  78 +-
 filter/accesslog/filter_test.go                    |   4 +-
 filter/active/filter.go                            |  26 +-
 filter/active/filter_test.go                       |   4 +-
 filter/adaptivesvc/filter.go                       | 125 +++
 filter/adaptivesvc/limiter/hill_climbing.go        | 315 +++++++
 .../adaptivesvc/limiter/limiter.go                 |  25 +-
 .../adaptivesvc/limiter/utils.go                   |  55 +-
 filter/adaptivesvc/limiter_mapper.go               |  85 ++
 filter/auth/accesskey_storage.go                   |  32 +-
 filter/auth/accesskey_storage_test.go              |   6 +-
 filter/auth/consumer_sign_filter.go                |  32 +-
 filter/auth/consumer_sign_filter_test.go           |   8 +-
 filter/auth/default_authenticator.go               |  55 +-
 filter/auth/default_authenticator_test.go          |  58 +-
 filter/auth/provider_auth_filter.go                |  30 +-
 filter/auth/provider_auth_filter_test.go           |  16 +-
 filter/echo/filter.go                              |  29 +-
 filter/echo/filter_test.go                         |   2 +-
 filter/{execlmt => exec_limit}/filter.go           |  48 +-
 filter/{execlmt => exec_limit}/filter_test.go      |  12 +-
 filter/filter_impl/import.go                       |   5 +-
 filter/generic/filter.go                           |  35 +-
 filter/generic/filter_test.go                      |  18 +-
 filter/generic/service_filter.go                   |  30 +-
 filter/generic/service_filter_test.go              |  34 +-
 filter/generic/util.go                             |  10 +-
 filter/gshutdown/filter.go                         |  10 +-
 filter/gshutdown/filter_test.go                    |   2 +-
 .../handler/rejected_execution_handler_only_log.go |   2 +-
 .../rejected_execution_handler_only_log_test.go    |   2 +-
 filter/hystrix/filter_test.go                      |   9 +-
 filter/seata/filter.go                             |  30 +-
 filter/seata/filter_test.go                        |   4 +-
 filter/sentinel/filter.go                          |  58 +-
 filter/sentinel/filter_test.go                     |   6 +-
 filter/token/filter.go                             |  31 +-
 filter/token/filter_test.go                        |  20 +-
 filter/tps/filter.go                               |  29 +-
 filter/tps/filter_test.go                          |  18 +-
 filter/tps/limiter/method_service.go               |  18 +-
 filter/tps/limiter/method_service_test.go          |  36 +-
 filter/tps/strategy/fix_window.go                  |   2 +-
 filter/tracing/filter.go                           |   2 +-
 filter/tracing/filter_test.go                      |   2 +-
 go.mod                                             |  26 +-
 go.sum                                             | 261 +++---
 imports/imports.go                                 |   7 +-
 metadata/definition/definition.go                  |   4 +-
 metadata/identifier/base_metadata_identifier.go    |  22 +-
 metadata/identifier/service_metadata_identifier.go |  10 +-
 .../identifier/subscribe_metadata_identifier.go    |   2 +-
 metadata/mapping/metadata/service_name_mapping.go  |  26 +-
 metadata/report/delegate/delegate_report.go        |   8 +-
 metadata/report/delegate/delegate_report_test.go   |   4 +-
 metadata/report/etcd/report.go                     |  20 +-
 metadata/report/etcd/report_test.go                |   8 +-
 metadata/report/nacos/report.go                    |   9 +-
 metadata/report/nacos/report_test.go               |   4 +-
 metadata/report/zookeeper/report.go                |  21 +-
 metadata/service/exporter/configurable/exporter.go |  20 +-
 .../local/metadata_service_proxy_factory.go        |  16 +-
 .../local/metadata_service_proxy_factory_test.go   |   6 +-
 metadata/service/local/service.go                  |  30 +-
 metadata/service/local/service_proxy.go            |  17 +-
 metadata/service/local/service_proxy_test.go       |   8 +-
 metadata/service/local_service.go                  |  10 +-
 metadata/service/remote/service.go                 |  20 +-
 metrics/prometheus/reporter.go                     |  16 +-
 protocol/dubbo/dubbo_codec.go                      |  25 +-
 protocol/dubbo/dubbo_exporter.go                   |   2 +-
 protocol/dubbo/dubbo_invoker.go                    |  23 +-
 protocol/dubbo/dubbo_protocol.go                   |   7 +-
 protocol/dubbo/hessian2/hessian_response.go        |   1 +
 protocol/dubbo/impl/codec.go                       |   2 +-
 protocol/dubbo/impl/codec_test.go                  |   6 +-
 protocol/dubbo/impl/hessian.go                     |  24 +-
 .../dubbo/impl/hessian_test.go                     |  42 +-
 protocol/dubbo/impl/serialization.go               |   4 +-
 protocol/dubbo/impl/serialize.go                   |   3 +-
 protocol/dubbo3/common_test.go                     |   2 +-
 protocol/dubbo3/dubbo3_exporter.go                 |   4 +-
 protocol/dubbo3/dubbo3_invoker.go                  |  72 +-
 protocol/dubbo3/dubbo3_protocol.go                 |  67 +-
 protocol/dubbo3/internal/helloworld_triple.pb.go   |  10 +-
 protocol/dubbo3/internal/server.go                 |   4 +-
 protocol/dubbo3/reflection/serverreflection.go     | 497 +++++++++++
 .../triple_reflection_v1alpha/reflection.pb.go     | 960 +++++++++++++++++++++
 .../triple_reflection_v1alpha/reflection.proto     | 141 +++
 .../reflection_triple.pb.go                        | 197 +++++
 protocol/grpc/client.go                            |   4 +-
 protocol/grpc/grpc_exporter.go                     |   2 +-
 protocol/grpc/grpc_protocol.go                     |   6 +-
 protocol/grpc/internal/helloworld/server.go        |   7 +-
 protocol/grpc/internal/routeguide/client.go        |  10 +-
 protocol/grpc/internal/routeguide/server.go        |   5 +-
 protocol/invocation/rpcinvocation.go               |   4 +-
 protocol/invocation/rpcinvocation_test.go          |  17 +-
 protocol/invoker.go                                |   9 +
 protocol/jsonrpc/http.go                           |   6 +-
 protocol/jsonrpc/jsonrpc_exporter.go               |   2 +-
 protocol/jsonrpc/jsonrpc_invoker.go                |   2 +-
 protocol/jsonrpc/jsonrpc_protocol.go               |   4 +-
 protocol/jsonrpc/server.go                         |   6 +-
 .../protocolwrapper/protocol_filter_wrapper.go     |  13 +-
 .../protocol_filter_wrapper_test.go                |   6 +-
 protocol/rest/client/client_impl/resty_client.go   |   2 +-
 protocol/rest/config/reader/rest_config_reader.go  |   4 +-
 protocol/rest/rest_exporter.go                     |   2 +-
 protocol/rest/rest_protocol.go                     |   6 +-
 .../rest/server/server_impl/go_restful_server.go   |   2 +-
 protocol/result.go                                 |  26 +
 protocol/rpc_status.go                             |   2 +-
 registry/base_configuration_listener.go            |   6 +-
 registry/base_registry.go                          |  33 +-
 registry/directory/directory.go                    |  24 +-
 registry/directory/directory_test.go               |  40 +-
 registry/etcdv3/registry.go                        |   4 +-
 registry/etcdv3/registry_test.go                   |  14 +-
 registry/etcdv3/service_discovery.go               |  42 +-
 registry/event/base_configuration_listener.go      |   6 +-
 .../metadata_service_url_params_customizer.go      |  22 +-
 .../event/protocol_ports_metadata_customizer.go    |   6 +-
 .../service_instances_changed_listener_impl.go     |  12 +-
 registry/event/service_revision_customizer.go      |  10 +-
 registry/event_test.go                             |   1 +
 registry/file/listener.go                          |  29 -
 registry/file/service_discovery.go                 | 270 ------
 registry/file/service_discovery_test.go            |  91 --
 registry/kubernetes/listener.go                    | 127 ---
 registry/kubernetes/listener_test.go               |  53 --
 registry/kubernetes/registry.go                    | 241 ------
 registry/kubernetes/registry_test.go               | 344 --------
 registry/mock_registry.go                          |   2 +-
 registry/nacos/listener.go                         |  36 +-
 registry/nacos/registry.go                         |  90 +-
 registry/nacos/registry_test.go                    |  66 +-
 registry/nacos/service_discovery.go                |  34 +-
 registry/nacos/service_discovery_test.go           | 182 ----
 registry/polaris/core.go                           | 133 +++
 registry/polaris/listener.go                       | 118 +++
 registry/polaris/registry.go                       | 323 +++++++
 registry/polaris/service_discovery.go              | 368 ++++++++
 registry/polaris/utils.go                          |  72 ++
 registry/protocol/protocol.go                      |  76 +-
 registry/protocol/protocol_test.go                 |  26 +-
 registry/service_instance.go                       |   2 +-
 .../servicediscovery/service_discovery_registry.go |  19 +-
 .../rest/rest_subscribed_urls_synthesizer.go       |   8 +-
 .../rest/rest_subscribed_urls_synthesizer_test.go  |  12 +-
 registry/zookeeper/listener.go                     |  17 +-
 registry/zookeeper/registry.go                     |  21 +-
 registry/zookeeper/service_discovery.go            |  25 +-
 remoting/codec.go                                  |   2 +
 remoting/etcdv3/listener.go                        |   6 +-
 remoting/exchange.go                               |   7 +
 remoting/exchange_client.go                        |   4 +
 remoting/exchange_server.go                        |   1 +
 remoting/getty/dubbo_codec_for_test.go             |  25 +-
 remoting/getty/getty_client.go                     |   4 +-
 remoting/getty/getty_client_test.go                |  24 +-
 remoting/getty/getty_server.go                     |   6 +-
 remoting/getty/listener.go                         |  17 +-
 remoting/getty/listener_test.go                    |  10 +-
 remoting/getty/readwriter_test.go                  |   7 +-
 remoting/kubernetes/client.go                      | 213 -----
 remoting/kubernetes/client_test.go                 | 455 ----------
 remoting/kubernetes/facade_test.go                 |  78 --
 remoting/kubernetes/listener.go                    | 212 -----
 remoting/kubernetes/listener_test.go               | 103 ---
 remoting/kubernetes/registry_controller.go         | 633 --------------
 remoting/kubernetes/watch.go                       | 320 -------
 remoting/kubernetes/watch_test.go                  |  96 ---
 remoting/nacos/builder.go                          |  51 +-
 remoting/nacos/builder_test.go                     |  84 +-
 remoting/polaris/builder.go                        | 106 +++
 remoting/polaris/builder_test.go                   | 106 +++
 remoting/polaris/polaris.yaml                      |  95 ++
 remoting/zookeeper/client.go                       |   9 +-
 .../curator_discovery/service_discovery.go         |   4 +-
 remoting/zookeeper/listener.go                     | 150 ++--
 284 files changed, 7405 insertions(+), 5631 deletions(-)
 copy cluster/cluster/{failfast => adaptivesvc}/cluster.go (63%)
 create mode 100644 cluster/cluster/adaptivesvc/cluster_invoker.go
 create mode 100644 cluster/loadbalance/p2c/loadbalance.go
 copy protocol/grpc/internal/doc.go => cluster/metrics/constants.go (93%)
 create mode 100644 cluster/metrics/local_metrics.go
 create mode 100644 cluster/metrics/metrics.go
 rename remoting/kubernetes/facade.go => cluster/metrics/utils.go (81%)
 copy common/{constant/version.go => file/suffix.go} (82%)
 create mode 100644 config/custom_config.go
 create mode 100644 config/custom_config_test.go
 copy config/instance/{metadata_report.go => registry_metadata_report.go} (56%)
 create mode 100644 config/instance/registry_metadata_report_test.go
 copy config/testdata/config/{logger/empty_log.yaml => custom/custom.yaml} (66%)
 copy config/testdata/config/{registry/application.yaml => custom/empty.yaml} (79%)
 copy protocol/dubbo/impl/serialization.go => config/tracing_config.go (54%)
 create mode 100644 config_center/apollo/mockDubbogo.yaml.json
 create mode 100644 filter/adaptivesvc/filter.go
 create mode 100644 filter/adaptivesvc/limiter/hill_climbing.go
 copy config/application_config_test.go => filter/adaptivesvc/limiter/limiter.go (74%)
 copy common/extension/proxy_factory.go => filter/adaptivesvc/limiter/utils.go (51%)
 create mode 100644 filter/adaptivesvc/limiter_mapper.go
 rename filter/{execlmt => exec_limit}/filter.go (85%)
 rename filter/{execlmt => exec_limit}/filter_test.go (88%)
 copy config_center/dynamic_configuration_test.go => protocol/dubbo/impl/hessian_test.go (61%)
 create mode 100644 protocol/dubbo3/reflection/serverreflection.go
 create mode 100644 protocol/dubbo3/reflection/triple_reflection_v1alpha/reflection.pb.go
 create mode 100644 protocol/dubbo3/reflection/triple_reflection_v1alpha/reflection.proto
 create mode 100644 protocol/dubbo3/reflection/triple_reflection_v1alpha/reflection_triple.pb.go
 delete mode 100644 registry/file/listener.go
 delete mode 100644 registry/file/service_discovery.go
 delete mode 100644 registry/file/service_discovery_test.go
 delete mode 100644 registry/kubernetes/listener.go
 delete mode 100644 registry/kubernetes/listener_test.go
 delete mode 100644 registry/kubernetes/registry.go
 delete mode 100644 registry/kubernetes/registry_test.go
 delete mode 100644 registry/nacos/service_discovery_test.go
 create mode 100644 registry/polaris/core.go
 create mode 100644 registry/polaris/listener.go
 create mode 100644 registry/polaris/registry.go
 create mode 100644 registry/polaris/service_discovery.go
 create mode 100644 registry/polaris/utils.go
 delete mode 100644 remoting/kubernetes/client.go
 delete mode 100644 remoting/kubernetes/client_test.go
 delete mode 100644 remoting/kubernetes/facade_test.go
 delete mode 100644 remoting/kubernetes/listener.go
 delete mode 100644 remoting/kubernetes/listener_test.go
 delete mode 100644 remoting/kubernetes/registry_controller.go
 delete mode 100644 remoting/kubernetes/watch.go
 delete mode 100644 remoting/kubernetes/watch_test.go
 create mode 100644 remoting/polaris/builder.go
 create mode 100644 remoting/polaris/builder_test.go
 create mode 100644 remoting/polaris/polaris.yaml