You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by fa...@apache.org on 2021/09/27 15:38:28 UTC
[dubbo-go] branch master updated (481eb47 -> bfca099)
This is an automated email from the ASF dual-hosted git repository.
fangyc pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 481eb47 Merge branch 'develop'
add 044d22c config file enhance
add 9388db1 set Koanf
add 0c4d749 add:registry config
add fa807b5 add:config center config
add 639e01c up:default config name
add fa700d8 up:调整结构
add 7b269ed up:set config
add d7f3e7c add validate
add c707ca7 add check genre
add c2a0aa9 修改配置目录
add 4513152 add registry config
add 590b338 add protocol
add ffc64cd add provider config
add 737ec30 add comments
add 80c72a0 up:service config
add 5e20c9f 修改解析tag
add 02b535b registries:
add b7863d7 配置中心配置
add 6118ef2 添加registry
add aba8707 移除冗余代码
add e4af389 fix: make new config struct runnable
add c7767d6 merge
add bb43b9f up:配置文件
add 48c615d add:修改参数
add e291fc1 add config
add cf25e75 添加配置
add d93df44 添加配置模块
add ddca022 up:更新配置
add 94d6aa8 更新配置
add fadf717 修改方法
add 40ae505 修改配置
add 4338699 fix:注册失败问题
add f1e8378 修改配置
add 35ef293 add:配置中心模块代码
add 6c511dd 添加注释
add 8e32515 up:移除冗余代码
add 1ecc7eb Config refactor (#1358)
add de72761 merge
add 45143a8 up:router为数组
add a648a96 参数优化
add 3a407f1 Merge pull request #1327 from zhaoyunxing92/config-enhance
add c9d58c0 Merge pull request #1365 from zhaoyunxing92/config-enhance
add 87614c4 Merge branch 'apache:config-enhance' into config-enhance
add 1461fbd add:duration func
add 7d77755 add: license
add 9a845c6 Merge pull request #1366 from zhaoyunxing92/config-enhance
add 641fce7 Merge branch 'apache:config-enhance' into config-enhance
add 4e2a0ed Merge pull request #1367 from zhaoyunxing92/config-enhance
add 2f9c1cd up:更新配置
add 3fe3c5a merge
add 56068b2 fix:nacos registry 添加group支持
add b78debda add:添加配置中心代码
add 2411e31 删除nacos registry group set
add 9cc1dad Merge pull request #1369 from zhaoyunxing92/config-enhance
add 10b5b91 修改panic的日志
add 1e912e8 修改panic的日志，打印了错误的详细原因，提醒用户需要添加的配置
add 9844b0b fix: metadata report config
add d5d1554 fix: fix conflict
add 4b6cec3 fix: fix conflict
add 2b4c477 Merge pull request #2 from LaurenceLiZhixin/config-enhance
add 3add3b6 up:更新配置
add 5f050e2 Merge pull request #1379 from zhaoyunxing92/config-enhance
add fb27e5a fix: prepare to refactor samples
add 8cb9393 fix: prepare to refactor samples (#1407)
add 5a89a48 Merge remote-tracking branch 'upstream/config-enhance' into config-enhance
add 06db69b fix: config-center init two times bug
add eb56cfb fix: some bugs of 3.0 config samples
add 1bfface fix: run tidy
add 8ef173e merge 3.0 to ensure samples runnable (#1414)
add da318d3 fix apollo config center parse bug (#1411)
add ddabb2e fix: support no registry (#1426)
add 384e130 add logger config
add 7379c14 feat: add getUrlMap & replace hump to underscore
add c636de3 Merge branch 'config-enhance' into config-enhance-log
add f6c81ae fix: delete the init func in common/logger
add 599ddd6 fix: replace '_' to '-' & delete test file in common/logger
add 89be3e7 fix: delete "" in yaml file
add 299cac4 Merge pull request #1419 from cjphaha/config-enhance-log
add 82e825c fix logger panic (#1430)
add 7206057 feat(config): add new protocol config (#1425)
add 202ad43 fix metadata bug (#1431)
add b3340bc fix: config enchance ci (#1432)
add a8a5019 Fix: app level metadata bug (#1433)
add 2e0b0e4 Fix: no log output error (#1434)
add 94c1e66 Fix apollo config center cli test fail (#1435)
add 3e0412e fix: add triple attachment (#1436)
add 4f8417d fix: remove k8s ut to enhance stablility of ci (#1438)
add d7e5177 fix(getty): fix nil panic when set default getty config (#1437)
add cb29fbc fix: add get dynamic configuration api (#1439)
add 90348d8 store zk value with base64. (#1440)
add a1e4548 Fix: metadataService port conflict (#1441)
add 78ca90e Fixes : grpc client init problem #1416 (#1418)
add f556336 Add get consumer service by InterfaceName api. (#1443)
add 552c973 Merge remote-tracking branch 'upstream/config-enhance' into config-enhance
add 0f8de5a add logs
add f914a30 Merge pull request #1449 from jasondeng1997/config-enhance
add 8d727d6 feat(generic-inv): align generic inv interface with java (#1452)
add 8c0b664 Fix: metrics、k8s、pprof (#1459)
add e17a87a #1458 delete useless log (#1468)
add ecd6529 Fix the name mapping incompatibility (#1465)
add 526ea1a Feat: config enhance (service discovery) (#1469)
add 0697950 feat(*): add graceful shutdown (#1470)
add 2072171 Config enhance (#1467)
add 26aa12b Ftr: add fatal method for logger(config-enhance branch) (#1482)
add 1397e8b Fix: merge config-enhance
add 4314ba8 fix: remove old integrate test
add 91ebda2 fix: integrate test script
add aa7a12d fix: gitlab action
add 732b695 fix: remove caceh
add c164f38 fix: remove cache and log
add efe12a0 Merge remote-tracking branch 'apache/3.0' into develop
new bfca099 Merge remote-tracking branch 'apache/develop'
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 3 +-
Makefile | 11 +-
.../cluster_impl/available_cluster_invoker_test.go | 1 +
cluster/cluster_impl/base_cluster_invoker.go | 1 +
.../cluster_impl/broadcast_cluster_invoker_test.go | 1 +
cluster/cluster_impl/failback_cluster_test.go | 2 +
cluster/cluster_impl/failfast_cluster_test.go | 2 +
cluster/cluster_impl/failover_cluster_test.go | 1 +
cluster/cluster_impl/failsafe_cluster_test.go | 2 +
cluster/cluster_impl/forking_cluster_test.go | 1 +
.../zone_aware_cluster_invoker_test.go | 1 +
cluster/router/chain/chain.go | 3 +-
.../v3router/k8s_api/listener_handler_impl.go | 2 +
cluster/router/v3router/k8s_crd/client.go | 3 +
.../router/v3router/k8s_crd/listener_handler.go | 1 +
cluster/router/v3router/router_chain_test.go | 1 +
common/constant/default.go | 3 +-
common/constant/env.go | 12 +-
common/constant/key.go | 97 +-
.../facade.go => common/extension/config.go | 16 +-
common/extension/config_center_factory.go | 4 +-
common/extension/proxy_factory.go | 4 +-
common/extension/registry.go | 8 +-
common/extension/service_discovery.go | 8 +-
common/logger/log.yml | 27 -
common/logger/logger.go | 76 +-
common/logger/logger_test.go | 137 ---
common/logger/logging.go | 10 +
common/metadata_info.go | 2 +-
common/proxy/proxy.go | 31 +-
common/proxy/proxy_factory/default.go | 9 +-
common/proxy/proxy_test.go | 1 +
common/url.go | 5 +-
common/yaml/yaml.go | 1 +
config/application_config.go | 95 +-
...c_config_test.go => application_config_test.go} | 10 +-
config/base_config.go | 312 ------
config/base_config_test.go | 303 ------
config/config_api.go | 545 ----------
config/config_api_test.go | 283 +++--
config/config_center_config.go | 325 ++++--
config/config_center_config_test.go | 75 --
config/config_loader.go | 437 ++------
config/config_loader_options.go | 166 +--
config/config_loader_options_test.go | 63 ++
config/config_loader_test.go | 1115 ++++++++++----------
config/config_setter.go | 4 -
config/config_utils.go | 47 +
config/consumer_config.go | 291 +++--
config/dubbo_bootstrap.go | 110 ++
config/{ => generic}/generic_service.go | 8 +-
config/graceful_shutdown.go | 103 +-
config/graceful_shutdown_config.go | 6 +-
config/graceful_shutdown_test.go | 184 ++--
config/instance/metadata_report_test.go | 14 +-
.../interfaces/config.go | 16 +-
config/logger_config.go | 155 +++
config/logger_config_test.go | 72 ++
config/metadata_report_config.go | 115 +-
config/metadata_report_config_test.go | 52 -
config/method_config.go | 44 +-
config/metric_config.go | 4 +
config/metric_config_test.go | 8 +-
config/protocol_config.go | 90 +-
...down_config_test.go => protocol_config_test.go} | 42 +-
config/provider_config.go | 145 ++-
config/provider_config_test.go | 48 +-
config/reference_config.go | 284 +++--
config/reference_config_test.go | 777 +++++++-------
config/registry_config.go | 281 +++--
config/registry_config_test.go | 38 +-
config/root_config.go | 280 +++++
config/router_config.go | 77 +-
config/router_config_test.go | 10 +-
config/service.go | 40 +-
config/service_config.go | 432 ++++++--
config/service_config_test.go | 215 ----
config/service_discovery_config.go | 6 +-
config/testdata/application.yaml | 35 +
config/testdata/config/app/application.yaml | 21 +
.../testdata/config/application/application.yaml | 4 +
.../testdata/config/center/conf-application.yaml | 13 +
config/testdata/config/logger/empty_log.yaml | 11 +
config/testdata/config/logger/file_log.yaml | 44 +
config/testdata/config/logger/log.yaml | 36 +
config/testdata/config/protocol/application.yaml | 7 +
.../config/protocol/empty_application.yaml | 7 +
config/testdata/config/provider/application.yaml | 17 +
.../provider/empty_registry_application.yaml | 8 +
.../config/provider/registry_application.yaml | 13 +
config/testdata/config/registry/application.yaml | 10 +
.../config/registry/empty_application.yaml | 2 +
config/uniform_router_config.go | 1 +
config_center/apollo/impl.go | 19 +-
config_center/apollo/impl_test.go | 109 +-
config_center/apollo/listener.go | 1 +
config_center/dynamic_configuration.go | 2 +
config_center/file/impl.go | 1 +
config_center/mock_dynamic_config.go | 1 +
config_center/nacos/client.go | 1 +
config_center/nacos/impl.go | 2 +
config_center/parser/configuration_parser.go | 2 +
config_center/zookeeper/impl.go | 13 +-
filter/accesslog/filter_test.go | 1 +
filter/active/filter_test.go | 1 +
filter/auth/consumer_sign_filter_test.go | 1 +
filter/auth/provider_auth_filter_test.go | 1 +
filter/echo/filter.go | 1 -
filter/generic/filter_test.go | 2 +
filter/generic/generalizer/example.pb.go | 1 +
filter/generic/generalizer/gson.go | 1 +
filter/generic/generalizer/map.go | 2 +
filter/generic/generalizer/protobuf_json.go | 2 +
filter/generic/service_filter.go | 1 +
filter/generic/service_filter_test.go | 3 +
filter/gshutdown/filter.go | 4 +-
filter/gshutdown/filter_test.go | 10 +-
filter/hystrix/filter.go | 8 +-
filter/hystrix/filter_test.go | 2 +
filter/metrics/filter.go | 8 +-
filter/metrics/filter_test.go | 1 +
filter/seata/filter.go | 3 +-
filter/sentinel/filter_test.go | 3 +
filter/tps/filter_test.go | 1 +
filter/tps/limiter/method_service_test.go | 1 +
go.mod | 14 +-
go.sum | 215 +++-
.../go-client/client.go => imports/imports.go | 58 +-
integrate_test.sh | 36 +-
.../mapping/dynamic/service_name_mapping_test.go | 61 --
metadata/mapping/memory/service_name_mapping.go | 5 +-
.../{dynamic => metadata}/service_name_mapping.go | 42 +-
metadata/mapping/mock_service_name_mapping.go | 8 +-
metadata/mapping/service_name_mapping.go | 8 +-
metadata/report/delegate/delegate_report.go | 2 +
metadata/report/delegate/delegate_report_test.go | 1 +
metadata/report/etcd/report.go | 34 +
metadata/report/etcd/report_test.go | 31 +
metadata/report/nacos/report.go | 47 +
metadata/report/report.go | 10 +
metadata/report/zookeeper/report.go | 35 +
metadata/service/exporter/configurable/exporter.go | 54 +-
.../service/exporter/configurable/exporter_test.go | 93 +-
metadata/service/remote/service_test.go | 14 +-
metrics/prometheus/reporter.go | 235 ++++-
protocol/dubbo/dubbo_codec.go | 1 +
protocol/dubbo/dubbo_invoker.go | 9 +-
protocol/dubbo/dubbo_invoker_test.go | 420 ++++----
protocol/dubbo/dubbo_protocol.go | 14 +-
protocol/dubbo/dubbo_protocol_test.go | 265 ++---
protocol/dubbo/hessian2/hessian_dubbo.go | 1 +
protocol/dubbo/hessian2/hessian_dubbo_test.go | 1 +
protocol/dubbo/hessian2/hessian_request.go | 1 +
protocol/dubbo/hessian2/hessian_request_test.go | 1 +
protocol/dubbo/hessian2/hessian_response.go | 1 +
protocol/dubbo/hessian2/hessian_response_test.go | 1 +
protocol/dubbo/hessian2/java_class.go | 1 +
protocol/dubbo/impl/codec.go | 1 +
protocol/dubbo/impl/hessian.go | 1 +
protocol/dubbo3/dubbo3_invoker.go | 25 +-
protocol/dubbo3/dubbo3_invoker_test.go | 2 +-
protocol/dubbo3/dubbo3_protocol.go | 35 +-
protocol/dubbo3/dubbo3_protocol_test.go | 3 +-
protocol/dubbo3/internal/client.go | 28 +-
protocol/dubbo3/internal/helloworld.pb.go | 127 +--
protocol/dubbo3/internal/server.go | 43 +-
protocol/grpc/client.go | 101 +-
protocol/grpc/codec.go | 1 +
protocol/grpc/grpc_invoker.go | 2 +
protocol/grpc/grpc_invoker_test.go | 2 +-
protocol/grpc/grpc_protocol_test.go | 50 +-
protocol/grpc/internal/helloworld/client.go | 1 +
protocol/grpc/internal/helloworld/helloworld.pb.go | 1 +
protocol/grpc/internal/multiprotos/first.pb.go | 1 +
protocol/grpc/internal/multiprotos/second.pb.go | 1 +
protocol/grpc/internal/routeguide/client.go | 1 +
protocol/grpc/internal/routeguide/routeguide.pb.go | 1 +
protocol/grpc/internal/routeguide/server.go | 1 +
protocol/grpc/server.go | 4 +-
protocol/invoker.go | 1 +
protocol/jsonrpc/http.go | 1 +
protocol/jsonrpc/http_test.go | 272 ++---
protocol/jsonrpc/jsonrpc_invoker_test.go | 103 +-
protocol/jsonrpc/jsonrpc_protocol.go | 10 +-
protocol/jsonrpc/jsonrpc_protocol_test.go | 5 +-
protocol/jsonrpc/server.go | 1 +
protocol/rest/client/client_impl/resty_client.go | 1 +
protocol/rest/config/reader/rest_config_reader.go | 11 +-
protocol/rest/rest_invoker_test.go | 394 +++----
protocol/rest/rest_protocol.go | 10 +-
protocol/rest/rest_protocol_test.go | 313 +++---
.../rest/server/server_impl/go_restful_server.go | 1 +
registry/base_registry.go | 7 +-
registry/directory/directory.go | 3 +-
registry/directory/directory_test.go | 6 +-
registry/etcdv3/registry_test.go | 91 +-
registry/etcdv3/service_discovery.go | 32 +-
registry/etcdv3/service_discovery_test.go | 109 +-
.../metadata_service_url_params_customizer_test.go | 1 +
registry/file/service_discovery.go | 6 +-
registry/file/service_discovery_test.go | 146 ++-
registry/kubernetes/registry_test.go | 66 +-
registry/nacos/listener.go | 2 +
registry/nacos/registry.go | 6 +-
registry/nacos/registry_test.go | 1 +
registry/nacos/service_discovery.go | 51 +-
registry/nacos/service_discovery_test.go | 326 +++---
registry/protocol/protocol.go | 49 +-
registry/protocol/protocol_test.go | 14 +-
.../servicediscovery/service_discovery_registry.go | 35 +-
.../service_discovery_registry_test.go | 392 +++----
registry/zookeeper/listener.go | 1 +
registry/zookeeper/registry.go | 2 +
registry/zookeeper/service_discovery.go | 47 +-
registry/zookeeper/service_discovery_test.go | 281 +++++
remoting/etcdv3/client.go | 1 +
remoting/etcdv3/listener.go | 3 +
remoting/etcdv3/listener_test.go | 2 +
remoting/getty/config.go | 82 +-
remoting/getty/getty_client.go | 52 +-
remoting/getty/getty_client_test.go | 22 +-
remoting/getty/getty_server.go | 35 +-
.../getty/getty_server_test.go | 25 +-
remoting/getty/pool.go | 4 +-
remoting/kubernetes/client.go | 20 +-
remoting/kubernetes/registry_controller.go | 54 +-
remoting/nacos/builder.go | 19 +-
remoting/zookeeper/client.go | 1 +
.../curator_discovery/service_discovery.go | 2 +
remoting/zookeeper/listener.go | 3 +
samples | 1 -
test/integrate/dubbo/go-client/Dockerfile | 42 -
test/integrate/dubbo/go-client/client.yml | 59 --
test/integrate/dubbo/go-client/go.mod | 10 -
test/integrate/dubbo/go-client/go.sum | 1087 -------------------
test/integrate/dubbo/go-client/log.yml | 27 -
test/integrate/dubbo/go-client/user.go | 57 -
test/integrate/dubbo/go-client/version.go | 20 -
test/integrate/dubbo/go-server/Dockerfile | 41 -
test/integrate/dubbo/go-server/go.mod | 14 -
test/integrate/dubbo/go-server/go.sum | 1092 -------------------
test/integrate/dubbo/go-server/log.yml | 27 -
test/integrate/dubbo/go-server/server.go | 56 -
test/integrate/dubbo/go-server/server.yml | 55 -
test/integrate/dubbo/go-server/user.go | 67 --
test/integrate/dubbo/go-server/version.go | 20 -
246 files changed, 7328 insertions(+), 9272 deletions(-)
copy remoting/kubernetes/facade.go => common/extension/config.go (84%)
delete mode 100644 common/logger/log.yml
delete mode 100644 common/logger/logger_test.go
copy config/{metric_config_test.go => application_config_test.go} (81%)
delete mode 100644 config/base_config.go
delete mode 100644 config/base_config_test.go
delete mode 100644 config/config_api.go
delete mode 100644 config/config_center_config_test.go
create mode 100644 config/config_loader_options_test.go
create mode 100644 config/dubbo_bootstrap.go
rename config/{ => generic}/generic_service.go (85%)
copy common/host_util_test.go => config/interfaces/config.go (84%)
create mode 100644 config/logger_config.go
create mode 100644 config/logger_config_test.go
delete mode 100644 config/metadata_report_config_test.go
copy config/{graceful_shutdown_config_test.go => protocol_config_test.go} (55%)
create mode 100644 config/root_config.go
delete mode 100644 config/service_config_test.go
create mode 100644 config/testdata/application.yaml
create mode 100644 config/testdata/config/app/application.yaml
create mode 100644 config/testdata/config/application/application.yaml
create mode 100644 config/testdata/config/center/conf-application.yaml
create mode 100644 config/testdata/config/logger/empty_log.yaml
create mode 100644 config/testdata/config/logger/file_log.yaml
create mode 100644 config/testdata/config/logger/log.yaml
create mode 100644 config/testdata/config/protocol/application.yaml
create mode 100644 config/testdata/config/protocol/empty_application.yaml
create mode 100644 config/testdata/config/provider/application.yaml
create mode 100644 config/testdata/config/provider/empty_registry_application.yaml
create mode 100644 config/testdata/config/provider/registry_application.yaml
create mode 100644 config/testdata/config/registry/application.yaml
create mode 100644 config/testdata/config/registry/empty_application.yaml
rename test/integrate/dubbo/go-client/client.go => imports/imports.go (55%)
delete mode 100644 metadata/mapping/dynamic/service_name_mapping_test.go
rename metadata/mapping/{dynamic => metadata}/service_name_mapping.go (63%)
create mode 100644 registry/zookeeper/service_discovery_test.go
copy cluster/router/v3router/judger/list_string_match_judger_test.go => remoting/getty/getty_server_test.go (70%)
delete mode 160000 samples
delete mode 100644 test/integrate/dubbo/go-client/Dockerfile
delete mode 100644 test/integrate/dubbo/go-client/client.yml
delete mode 100644 test/integrate/dubbo/go-client/go.mod
delete mode 100644 test/integrate/dubbo/go-client/go.sum
delete mode 100644 test/integrate/dubbo/go-client/log.yml
delete mode 100644 test/integrate/dubbo/go-client/user.go
delete mode 100644 test/integrate/dubbo/go-client/version.go
delete mode 100644 test/integrate/dubbo/go-server/Dockerfile
delete mode 100644 test/integrate/dubbo/go-server/go.mod
delete mode 100644 test/integrate/dubbo/go-server/go.sum
delete mode 100644 test/integrate/dubbo/go-server/log.yml
delete mode 100644 test/integrate/dubbo/go-server/server.go
delete mode 100644 test/integrate/dubbo/go-server/server.yml
delete mode 100644 test/integrate/dubbo/go-server/user.go
delete mode 100644 test/integrate/dubbo/go-server/version.go
[dubbo-go] 01/01: Merge remote-tracking branch 'apache/develop'
Posted by fa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
fangyc pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
commit bfca099a8346be25ecf44f535a035f7a1fabd225
Merge: 481eb47 efe12a0
Author: fangyincheng <fa...@sina.com>
AuthorDate: Mon Sep 27 23:37:51 2021 +0800
Merge remote-tracking branch 'apache/develop'
.gitignore | 3 +-
Makefile | 11 +-
.../cluster_impl/available_cluster_invoker_test.go | 1 +
cluster/cluster_impl/base_cluster_invoker.go | 1 +
.../cluster_impl/broadcast_cluster_invoker_test.go | 1 +
cluster/cluster_impl/failback_cluster_test.go | 2 +
cluster/cluster_impl/failfast_cluster_test.go | 2 +
cluster/cluster_impl/failover_cluster_test.go | 1 +
cluster/cluster_impl/failsafe_cluster_test.go | 2 +
cluster/cluster_impl/forking_cluster_test.go | 1 +
.../zone_aware_cluster_invoker_test.go | 1 +
cluster/router/chain/chain.go | 3 +-
.../v3router/k8s_api/listener_handler_impl.go | 2 +
cluster/router/v3router/k8s_crd/client.go | 3 +
.../router/v3router/k8s_crd/listener_handler.go | 1 +
cluster/router/v3router/router_chain_test.go | 1 +
common/constant/default.go | 3 +-
common/constant/env.go | 12 +-
common/constant/key.go | 97 +-
.../version.go => common/extension/config.go | 14 +-
common/extension/config_center_factory.go | 4 +-
common/extension/proxy_factory.go | 4 +-
common/extension/registry.go | 8 +-
common/extension/service_discovery.go | 8 +-
common/logger/log.yml | 27 -
common/logger/logger.go | 76 +-
common/logger/logger_test.go | 137 ---
common/logger/logging.go | 10 +
common/metadata_info.go | 2 +-
common/proxy/proxy.go | 31 +-
common/proxy/proxy_factory/default.go | 9 +-
common/proxy/proxy_test.go | 1 +
common/url.go | 5 +-
common/yaml/yaml.go | 1 +
config/application_config.go | 95 +-
...c_config_test.go => application_config_test.go} | 10 +-
config/base_config.go | 312 ------
config/base_config_test.go | 303 ------
config/config_api.go | 545 ----------
config/config_api_test.go | 283 +++--
config/config_center_config.go | 325 ++++--
config/config_center_config_test.go | 75 --
config/config_loader.go | 437 ++------
config/config_loader_options.go | 166 +--
config/config_loader_options_test.go | 63 ++
config/config_loader_test.go | 1115 ++++++++++----------
config/config_setter.go | 4 -
config/config_utils.go | 47 +
config/consumer_config.go | 291 +++--
config/dubbo_bootstrap.go | 110 ++
config/{ => generic}/generic_service.go | 8 +-
config/graceful_shutdown.go | 103 +-
config/graceful_shutdown_config.go | 6 +-
config/graceful_shutdown_test.go | 184 ++--
config/instance/metadata_report_test.go | 14 +-
.../version.go => config/interfaces/config.go | 14 +-
config/logger_config.go | 155 +++
config/logger_config_test.go | 72 ++
config/metadata_report_config.go | 115 +-
config/method_config.go | 44 +-
config/metric_config.go | 4 +
config/metric_config_test.go | 8 +-
config/protocol_config.go | 90 +-
...port_config_test.go => protocol_config_test.go} | 45 +-
config/provider_config.go | 145 ++-
config/provider_config_test.go | 48 +-
config/reference_config.go | 284 +++--
config/reference_config_test.go | 777 +++++++-------
config/registry_config.go | 281 +++--
config/registry_config_test.go | 38 +-
config/root_config.go | 280 +++++
config/router_config.go | 77 +-
config/router_config_test.go | 10 +-
config/service.go | 40 +-
config/service_config.go | 432 ++++++--
config/service_config_test.go | 215 ----
config/service_discovery_config.go | 6 +-
config/testdata/application.yaml | 35 +
config/testdata/config/app/application.yaml | 21 +
.../testdata/config/application/application.yaml | 4 +
.../testdata/config/center/conf-application.yaml | 13 +
config/testdata/config/logger/empty_log.yaml | 11 +
config/testdata/config/logger/file_log.yaml | 44 +
config/testdata/config/logger/log.yaml | 36 +
config/testdata/config/protocol/application.yaml | 7 +
.../config/protocol/empty_application.yaml | 7 +
config/testdata/config/provider/application.yaml | 17 +
.../provider/empty_registry_application.yaml | 8 +
.../config/provider/registry_application.yaml | 13 +
config/testdata/config/registry/application.yaml | 10 +
.../config/registry/empty_application.yaml | 2 +
config/uniform_router_config.go | 1 +
config_center/apollo/impl.go | 19 +-
config_center/apollo/impl_test.go | 109 +-
config_center/apollo/listener.go | 1 +
config_center/dynamic_configuration.go | 2 +
config_center/file/impl.go | 1 +
config_center/mock_dynamic_config.go | 1 +
config_center/nacos/client.go | 1 +
config_center/nacos/impl.go | 2 +
config_center/parser/configuration_parser.go | 2 +
config_center/zookeeper/impl.go | 13 +-
filter/accesslog/filter_test.go | 1 +
filter/active/filter_test.go | 1 +
filter/auth/consumer_sign_filter_test.go | 1 +
filter/auth/provider_auth_filter_test.go | 1 +
filter/echo/filter.go | 1 -
filter/generic/filter_test.go | 2 +
filter/generic/generalizer/example.pb.go | 1 +
filter/generic/generalizer/gson.go | 1 +
filter/generic/generalizer/map.go | 2 +
filter/generic/generalizer/protobuf_json.go | 2 +
filter/generic/service_filter.go | 1 +
filter/generic/service_filter_test.go | 3 +
filter/gshutdown/filter.go | 4 +-
filter/gshutdown/filter_test.go | 10 +-
filter/hystrix/filter.go | 8 +-
filter/hystrix/filter_test.go | 2 +
filter/metrics/filter.go | 8 +-
filter/metrics/filter_test.go | 1 +
filter/seata/filter.go | 3 +-
filter/sentinel/filter_test.go | 3 +
filter/tps/filter_test.go | 1 +
filter/tps/limiter/method_service_test.go | 1 +
go.mod | 14 +-
go.sum | 215 +++-
.../go-client/client.go => imports/imports.go | 58 +-
integrate_test.sh | 36 +-
.../mapping/dynamic/service_name_mapping_test.go | 61 --
metadata/mapping/memory/service_name_mapping.go | 5 +-
.../{dynamic => metadata}/service_name_mapping.go | 42 +-
metadata/mapping/mock_service_name_mapping.go | 8 +-
metadata/mapping/service_name_mapping.go | 8 +-
metadata/report/delegate/delegate_report.go | 2 +
metadata/report/delegate/delegate_report_test.go | 1 +
metadata/report/etcd/report.go | 34 +
metadata/report/etcd/report_test.go | 31 +
metadata/report/nacos/report.go | 47 +
metadata/report/report.go | 10 +
metadata/report/zookeeper/report.go | 35 +
metadata/service/exporter/configurable/exporter.go | 54 +-
.../service/exporter/configurable/exporter_test.go | 93 +-
metadata/service/remote/service_test.go | 14 +-
metrics/prometheus/reporter.go | 235 ++++-
protocol/dubbo/dubbo_codec.go | 1 +
protocol/dubbo/dubbo_invoker.go | 9 +-
protocol/dubbo/dubbo_invoker_test.go | 420 ++++----
protocol/dubbo/dubbo_protocol.go | 14 +-
protocol/dubbo/dubbo_protocol_test.go | 265 ++---
protocol/dubbo/hessian2/hessian_dubbo.go | 1 +
protocol/dubbo/hessian2/hessian_dubbo_test.go | 1 +
protocol/dubbo/hessian2/hessian_request.go | 1 +
protocol/dubbo/hessian2/hessian_request_test.go | 1 +
protocol/dubbo/hessian2/hessian_response.go | 1 +
protocol/dubbo/hessian2/hessian_response_test.go | 1 +
protocol/dubbo/hessian2/java_class.go | 1 +
protocol/dubbo/impl/codec.go | 1 +
protocol/dubbo/impl/hessian.go | 1 +
protocol/dubbo3/dubbo3_invoker.go | 25 +-
protocol/dubbo3/dubbo3_invoker_test.go | 2 +-
protocol/dubbo3/dubbo3_protocol.go | 35 +-
protocol/dubbo3/dubbo3_protocol_test.go | 3 +-
protocol/dubbo3/internal/client.go | 28 +-
protocol/dubbo3/internal/helloworld.pb.go | 127 +--
protocol/dubbo3/internal/server.go | 43 +-
protocol/grpc/client.go | 101 +-
protocol/grpc/codec.go | 1 +
protocol/grpc/grpc_invoker.go | 2 +
protocol/grpc/grpc_invoker_test.go | 2 +-
protocol/grpc/grpc_protocol_test.go | 50 +-
protocol/grpc/internal/helloworld/client.go | 1 +
protocol/grpc/internal/helloworld/helloworld.pb.go | 1 +
protocol/grpc/internal/multiprotos/first.pb.go | 1 +
protocol/grpc/internal/multiprotos/second.pb.go | 1 +
protocol/grpc/internal/routeguide/client.go | 1 +
protocol/grpc/internal/routeguide/routeguide.pb.go | 1 +
protocol/grpc/internal/routeguide/server.go | 1 +
protocol/grpc/server.go | 4 +-
protocol/invoker.go | 1 +
protocol/jsonrpc/http.go | 1 +
protocol/jsonrpc/http_test.go | 272 ++---
protocol/jsonrpc/jsonrpc_invoker_test.go | 103 +-
protocol/jsonrpc/jsonrpc_protocol.go | 10 +-
protocol/jsonrpc/jsonrpc_protocol_test.go | 5 +-
protocol/jsonrpc/server.go | 1 +
protocol/rest/client/client_impl/resty_client.go | 1 +
protocol/rest/config/reader/rest_config_reader.go | 11 +-
protocol/rest/rest_invoker_test.go | 394 +++----
protocol/rest/rest_protocol.go | 10 +-
protocol/rest/rest_protocol_test.go | 313 +++---
.../rest/server/server_impl/go_restful_server.go | 1 +
registry/base_registry.go | 7 +-
registry/directory/directory.go | 3 +-
registry/directory/directory_test.go | 6 +-
registry/etcdv3/registry_test.go | 91 +-
registry/etcdv3/service_discovery.go | 32 +-
registry/etcdv3/service_discovery_test.go | 109 +-
.../metadata_service_url_params_customizer_test.go | 1 +
registry/file/service_discovery.go | 6 +-
registry/file/service_discovery_test.go | 146 ++-
registry/kubernetes/registry_test.go | 66 +-
registry/nacos/listener.go | 2 +
registry/nacos/registry.go | 6 +-
registry/nacos/registry_test.go | 1 +
registry/nacos/service_discovery.go | 51 +-
registry/nacos/service_discovery_test.go | 326 +++---
registry/protocol/protocol.go | 49 +-
registry/protocol/protocol_test.go | 14 +-
.../servicediscovery/service_discovery_registry.go | 35 +-
.../service_discovery_registry_test.go | 392 +++----
registry/zookeeper/listener.go | 1 +
registry/zookeeper/registry.go | 2 +
registry/zookeeper/service_discovery.go | 47 +-
registry/zookeeper/service_discovery_test.go | 281 +++++
remoting/etcdv3/client.go | 1 +
remoting/etcdv3/listener.go | 3 +
remoting/etcdv3/listener_test.go | 2 +
remoting/getty/config.go | 82 +-
remoting/getty/getty_client.go | 52 +-
remoting/getty/getty_client_test.go | 22 +-
remoting/getty/getty_server.go | 35 +-
.../user.go => remoting/getty/getty_server_test.go | 46 +-
remoting/getty/pool.go | 4 +-
remoting/kubernetes/client.go | 20 +-
remoting/kubernetes/registry_controller.go | 54 +-
remoting/nacos/builder.go | 19 +-
remoting/zookeeper/client.go | 1 +
.../curator_discovery/service_discovery.go | 2 +
remoting/zookeeper/listener.go | 3 +
samples | 1 -
test/integrate/dubbo/go-client/Dockerfile | 42 -
test/integrate/dubbo/go-client/client.yml | 59 --
test/integrate/dubbo/go-client/go.mod | 10 -
test/integrate/dubbo/go-client/go.sum | 1087 -------------------
test/integrate/dubbo/go-client/log.yml | 27 -
test/integrate/dubbo/go-server/Dockerfile | 41 -
test/integrate/dubbo/go-server/go.mod | 14 -
test/integrate/dubbo/go-server/go.sum | 1092 -------------------
test/integrate/dubbo/go-server/log.yml | 27 -
test/integrate/dubbo/go-server/server.go | 56 -
test/integrate/dubbo/go-server/server.yml | 55 -
test/integrate/dubbo/go-server/user.go | 67 --
242 files changed, 7337 insertions(+), 9134 deletions(-)