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/08/18 04:18:01 UTC
[dubbo-go] branch develop updated (727e346 -> 3da71a1)
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 727e346 Merge branch '3.0' into develop
add fc2cd0d fix: loadbalance unit test (#1270)
add b1f51ad make the package v3router/judger test coverage rate reach 80% (#1260)
add 0f0e1f6 Fix: Graceful shutdown bugs(supplement #1254) (#1257)
add 5892eec refine grpc test code (#1266)
add cee963f registry 默认值问题 (#1275)
add 3596e59 config center for more parameters (#1277)
add 893bfb5 fix: add arch picture in readme and delete unused router field. (#1279)
add 048392c fix common.URL serialization bug (#1292)
add d2b3b67 [#1288] fix the inconsistent filepath key logic for v3.0 (#1290)
add 6b1d9dd fix typo and update link
add 4e6c0e7 Merge pull request #1294 from xavier-niu/doc/readme
add 3a1b260 performance optimization: change time.After => time.NewTimer for 3.0 (#1300)
add e43af85 refactor metadata service (#1298)
add e97d5e2 move internal to helloworld
add a1aade2 fix type
add bbda4b5 add grpc stream test
add 7a4c587 fix spell
add 1ee0a85 fix spell
add 21e9f4e Merge pull request #1291 from dubbo-x/grpc-refine
add 2e8402e url多个问题 (#1306)
add af29042 Rft: Filter (#1299)
add 60ad0b5 upgrade getty gost version
add 52deca0 fix: delete consul (#1280)
add 103aa72 Support Key generate Func in ServiceEvent (#1286)
add 3ab0ab6 fix: change register event chan to unbundent chan (#1330)
add 0277fc3 fix: #1323 delete zk registry when set defualt consumer/provider config (#1324)
add 9aeb7ff Ftr: Generic invocation supports Generalizer (#1315)
add 86fe9e3 fix logging level (#1341)
add dd517d6 Ftr: add lumberjack log config (#1335)
add 103cf14 Ftr: add json generalizer (#1343)
add 1643df2 style(*): format imports with dubbogo/tools/imports-formatter (#1346)
add ebce04e fix Fixed the problem that the timeout period of the original method level does not take effect (#1336)
add fb0d226 fix:#1143 Feature/reduce etcd registry conn; wait group modify (#1297)
add ff50bd2 ftr: triple multi params support (#1344)
add b2ae992 fix: remove unused getty import
add 92df41c fix: mock zk registry (#1351)
add f76b01c 优化Nacos下的ServiceName的命名风格 (#1352)
add 0376b53 remove zk test (#1357)
add c5802c5 Use class name as the default reference name (#1339)
add 495090f Feat/upgrade getty (#1345)
add f192c1e support multi pb (#1361)
add 77a8b5f logo (#1382)
add f8f38b5 Change the key of a mock EchoFilter (#1381)
new 3da71a1 Merge branch '3.0' into 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:
.github/workflows/github-actions.yml | 4 +-
.gitignore | 4 +-
README.md | 13 +-
README_CN.md | 11 +-
cluster/cluster_impl/failover_cluster_test.go | 4 -
cluster/loadbalance/consistent_hash_test.go | 6 +-
cluster/router/chain.go | 2 -
cluster/router/chain/chain.go | 62 +-
cluster/router/chain/invoker_cache.go | 78 --
cluster/router/router.go | 2 +-
cluster/router/rule.go | 31 -
cluster/router/v3router/factory.go | 4 +-
cluster/router/v3router/factory_test.go | 2 +-
.../v3router/judger/attachment_match_judger.go | 55 +-
.../judger/attachment_match_judger_test.go | 15 +-
.../router/v3router/judger/bool_match_judger.go | 4 +-
...er_test.go => list_string_match_judger_test.go} | 21 +-
.../router/v3router/judger/method_match_judger.go | 1 +
.../v3router/judger/method_match_judger_test.go | 77 ++
.../v3router/judger/url_label_match_judge_test.go | 19 +-
cluster/router/v3router/router_chain.go | 23 +-
cluster/router/v3router/router_chain_test.go | 53 +-
cluster/router/v3router/uniform_route.go | 4 +-
common/constant/default.go | 14 +-
common/constant/key.go | 114 ++-
.../constant/{serializtion.go => serialization.go} | 0
common/extension/auth.go | 18 +-
common/extension/metadata_remote.go | 10 +-
common/extension/metadata_service.go | 4 +-
common/extension/metadata_service_proxy_factory.go | 2 +-
common/host_util.go | 4 +-
common/logger/file_log.yml | 36 +
common/logger/logger.go | 58 +-
common/logger/logger_test.go | 54 ++
common/rpc_service.go | 35 +-
common/rpc_service_test.go | 33 +
common/url.go | 24 +-
config/config_api.go | 10 -
config/config_api_test.go | 11 +-
config/config_center_config.go | 64 +-
config/config_center_config_test.go | 22 +-
config/config_loader.go | 25 +-
config/config_loader_test.go | 30 +-
.../constant/version.go => config/config_setter.go | 13 +-
config/generic_service.go | 4 +-
config/graceful_shutdown.go | 8 +
config/graceful_shutdown_test.go | 9 +
config/interfaces/config_reader.go | 4 +-
config/reference_config.go | 14 +-
config/reference_config_test.go | 2 +-
config/remote_config.go | 23 +-
config/service.go | 6 +-
config/service_config.go | 6 +-
config/service_discovery_config.go | 4 +-
config/testdata/consumer_config.yml | 1 -
.../testdata/consumer_config_with_configcenter.yml | 1 -
.../testdata/consumer_config_withoutProtocol.yml | 1 -
config/testdata/provider_config.yml | 1 -
.../testdata/provider_config_withoutProtocol.yml | 1 -
config/uniform_router_config.go | 2 +-
config_center/apollo/impl_test.go | 3 +-
config_center/nacos/client.go | 45 +-
config_center/nacos/client_test.go | 6 +-
config_center/nacos/impl.go | 2 +-
config_center/zookeeper/impl_test.go | 232 ------
config_center/zookeeper/listener_test.go | 101 ---
doc/pic/arch/dubbo-go-arch.png | Bin 190013 -> 0 bytes
doc/pic/arch/dubbo-go-ext.png | Bin 194550 -> 0 bytes
doc/pic/misc/dubbogo-dingding.png | Bin 39890 -> 0 bytes
doc/pic/misc/dubbogo-wechat.png | Bin 15414 -> 0 bytes
filter/README.md | 38 +
.../access_log_filter.go => accesslog/filter.go} | 76 +-
.../filter_test.go} | 14 +-
.../active_filter.go => active/filter.go} | 21 +-
.../filter_test.go} | 10 +-
filter/{filter_impl => }/auth/accesskey_storage.go | 15 +-
.../auth/accesskey_storage_test.go | 2 +-
.../consumer_sign_filter.go} | 17 +-
.../consumer_sign_filter_test.go} | 0
.../auth/default_authenticator.go | 14 +-
.../auth/default_authenticator_test.go | 0
.../provider_auth_filter.go} | 10 +-
.../provider_auth_filter_test.go} | 0
filter/{filter_impl => }/auth/sign_util.go | 0
filter/{filter_impl => }/auth/sign_util_test.go | 0
.../{filter_impl/echo_filter.go => echo/filter.go} | 26 +-
.../echo_filter_test.go => echo/filter_test.go} | 6 +-
.../execute_limit_filter.go => execlmt/filter.go} | 26 +-
.../filter_test.go} | 14 +-
filter/filter_impl/generic_filter.go | 167 ----
filter/filter_impl/generic_service_filter.go | 132 ----
filter/filter_impl/generic_service_filter_test.go | 150 ----
filter/filter_impl/import.go | 41 +
filter/generic/filter.go | 97 +++
filter/generic/filter_test.go | 100 +++
filter/generic/generalizer/example.pb.go | 259 ++++++
.../generic/generalizer/generalizer.go | 34 +-
filter/generic/generalizer/gson.go | 99 +++
filter/generic/generalizer/gson_test.go | 97 +++
filter/generic/generalizer/map.go | 206 +++++
.../generalizer/map_test.go} | 170 +++-
filter/generic/generalizer/protobuf_json.go | 90 +++
.../generic/generalizer/protobuf_json_test.go | 43 +-
filter/generic/service_filter.go | 130 ++++
filter/generic/service_filter_test.go | 211 +++++
filter/generic/util.go | 80 ++
.../filter.go} | 67 +-
.../filter_test.go} | 4 +-
.../handler/rejected_execution_handler_only_log.go | 3 +-
.../hystrix_filter.go => hystrix/filter.go} | 75 +-
.../filter_test.go} | 28 +-
.../metrics_filter.go => metrics/filter.go} | 28 +-
.../filter_test.go} | 4 +-
.../seata_filter.go => seata/filter.go} | 20 +-
.../seata_filter_test.go => seata/filter_test.go} | 4 +-
.../sentinel_filter.go => sentinel/filter.go} | 35 +-
.../filter_test.go} | 8 +-
.../token_filter.go => token/filter.go} | 24 +-
.../token_filter_test.go => token/filter_test.go} | 10 +-
.../tps_limit_filter.go => tps/filter.go} | 30 +-
.../filter_test.go} | 25 +-
.../limiter/method_service.go} | 22 +-
.../limiter/method_service_test.go} | 9 +-
.../tps_limiter_mock.go => tps/limiter/mock.go} | 2 +-
.../strategy/fix_window.go} | 16 +-
.../strategy/fix_window_test.go} | 2 +-
.../strategy/mock.go} | 8 +-
.../strategy/sliding_window.go} | 12 +-
.../strategy/sliding_window_test.go} | 2 +-
.../strategy/thread_safe_fix_window.go} | 18 +-
.../strategy/thread_safe_fix_window_test.go} | 2 +-
filter/{tps_limit_strategy.go => tps_strategy.go} | 2 +-
.../tracing_filter.go => tracing/filter.go} | 10 +-
.../filter_test.go} | 2 +-
go.mod | 38 +-
go.sum | 409 +++-------
metadata/identifier/base_metadata_identifier.go | 9 +-
.../identifier/base_metadata_identifier_test.go | 2 +-
metadata/identifier/metadata_identifier_test.go | 2 +-
.../identifier/service_metadata_identifier_test.go | 2 +-
metadata/report/consul/report.go | 134 ----
metadata/report/consul/report_test.go | 170 ----
metadata/report/zookeeper/report_test.go | 203 -----
.../service/exporter/configurable/exporter_test.go | 5 +-
.../metadata_service_proxy_factory.go | 2 +-
.../metadata_service_proxy_factory_test.go | 2 +-
metadata/service/{inmemory => local}/service.go | 6 +-
.../service/{inmemory => local}/service_proxy.go | 2 +-
.../{inmemory => local}/service_proxy_test.go | 2 +-
.../service/{inmemory => local}/service_test.go | 4 +-
metadata/service/{service.go => local_service.go} | 4 +-
metadata/service/{remoting => remote}/service.go | 24 +-
.../service/{remoting => remote}/service_test.go | 8 +-
.../{remoting_service.go => remote_service.go} | 2 +-
protocol/dubbo/dubbo_invoker.go | 6 +-
protocol/dubbo/dubbo_invoker_test.go | 2 -
protocol/dubbo/dubbo_protocol_test.go | 2 -
protocol/dubbo/hessian2/hessian_request.go | 95 +--
protocol/dubbo/hessian2/hessian_response.go | 6 +-
protocol/dubbo/hessian2/java_class.go | 200 +++++
protocol/dubbo/hessian2/java_class_test.go | 132 ++++
protocol/dubbo/impl/const.go | 2 +
protocol/dubbo3/dubbo3_protocol.go | 28 +-
protocol/dubbo3/dubbo3_protocol_test.go | 63 ++
protocol/dubbo3/internal/helloworld.pb.go | 9 +-
.../protoc-gen-dubbo3/examples/helloworld.pb.go | 9 +-
protocol/dubbo3/protoc-gen-dubbo3/go.mod | 6 +-
protocol/dubbo3/protoc-gen-dubbo3/go.sum | 95 ++-
protocol/dubbo3/protoc-gen-dubbo3/main.go | 5 +-
protocol/grpc/client_test.go | 73 +-
protocol/grpc/common_test.go | 114 ---
protocol/grpc/grpc_invoker_test.go | 118 ++-
protocol/grpc/grpc_protocol_test.go | 21 +-
protocol/grpc/internal/README.md | 6 +
protocol/grpc/internal/{ => helloworld}/Makefile | 0
protocol/grpc/internal/{ => helloworld}/client.go | 2 +-
.../internal/{ => helloworld}/helloworld.pb.go | 64 +-
.../internal/{ => helloworld}/helloworld.proto | 3 +-
protocol/grpc/internal/{ => helloworld}/server.go | 53 +-
protocol/grpc/internal/{ => multiprotos}/Makefile | 4 +-
protocol/grpc/internal/multiprotos/first.pb.go | 307 ++++++++
.../grpc/internal/multiprotos/first.proto | 22 +-
protocol/grpc/internal/multiprotos/second.pb.go | 589 ++++++++++++++
.../grpc/internal/multiprotos/second.proto | 24 +-
.../examples => grpc/internal/routeguide}/Makefile | 6 +-
protocol/grpc/internal/routeguide/client.go | 110 +++
protocol/grpc/internal/routeguide/routeguide.pb.go | 865 +++++++++++++++++++++
protocol/grpc/internal/routeguide/routeguide.proto | 114 +++
protocol/grpc/internal/routeguide/server.go | 827 ++++++++++++++++++++
.../grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go | 34 +-
protocol/grpc/server.go | 5 +-
protocol/invocation/rpcinvocation.go | 4 -
protocol/jsonrpc/http.go | 4 -
.../protocol_filter_wrapper_test.go | 20 +-
registry/base_registry.go | 6 +-
registry/consul/listener.go | 207 -----
registry/consul/listener_test.go | 33 -
registry/consul/registry.go | 219 ------
registry/consul/registry_test.go | 73 --
registry/consul/service_discovery.go | 492 ------------
registry/consul/service_discovery_test.go | 209 -----
registry/consul/utils.go | 115 ---
registry/consul/utils_test.go | 211 -----
registry/directory/directory.go | 24 +-
registry/etcdv3/listener.go | 11 +-
registry/etcdv3/listener_test.go | 7 +-
registry/etcdv3/registry.go | 10 +-
registry/etcdv3/service_discovery.go | 2 +
registry/event.go | 9 +-
.../event_publishing_service_deiscovery_test.go | 4 +-
.../event/event_publishing_service_discovery.go | 4 +-
.../service_instances_changed_listener_impl.go | 2 +-
.../event_test.go | 27 +-
registry/file/listener.go | 4 +-
registry/kubernetes/listener.go | 11 +-
registry/kubernetes/registry.go | 12 +-
registry/kubernetes/registry_test.go | 1 +
registry/nacos/listener.go | 15 +-
registry/nacos/registry.go | 4 +-
registry/nacos/service_discovery.go | 11 +-
registry/service_instance.go | 4 +-
registry/service_instances_changed_listener.go | 10 +-
.../servicediscovery/service_discovery_registry.go | 6 +-
registry/zookeeper/listener.go | 10 +-
registry/zookeeper/listener_test.go | 46 --
registry/zookeeper/registry.go | 9 +-
registry/zookeeper/registry_test.go | 185 -----
registry/zookeeper/service_discovery_test.go | 279 -------
remoting/consul/test_agent.go | 38 -
remoting/etcdv3/facade.go | 52 +-
remoting/getty/config.go | 3 -
remoting/getty/dubbo_codec_for_test.go | 1 +
remoting/getty/getty_client.go | 7 +-
remoting/getty/getty_client_test.go | 4 +-
remoting/getty/getty_server.go | 3 +
remoting/getty/listener.go | 6 +-
remoting/getty/listener_test.go | 1 +
remoting/getty/pool.go | 1 +
remoting/getty/readwriter.go | 14 +-
remoting/getty/readwriter_test.go | 3 +-
remoting/kubernetes/facade.go | 4 +-
remoting/nacos/builder.go | 68 +-
remoting/nacos/builder_test.go | 2 +
remoting/zookeeper/facade.go | 1 +
remoting/zookeeper/facade_test.go | 125 ---
remoting/zookeeper/listener.go | 7 +-
remoting/zookeeper/listener_test.go | 104 ---
test/integrate/dubbo/go-client/client.yml | 2 -
test/integrate/dubbo/go-client/user.go | 5 +-
test/integrate/dubbo/go-server/server.yml | 2 -
test/integrate/dubbo/go-server/user.go | 3 +
251 files changed, 6599 insertions(+), 5627 deletions(-)
delete mode 100644 cluster/router/chain/invoker_cache.go
delete mode 100644 cluster/router/rule.go
copy cluster/router/v3router/judger/{double_range_match_judger_test.go => list_string_match_judger_test.go} (70%)
create mode 100644 cluster/router/v3router/judger/method_match_judger_test.go
copy protocol/invoker_test.go => cluster/router/v3router/judger/url_label_match_judge_test.go (73%)
rename common/constant/{serializtion.go => serialization.go} (100%)
create mode 100644 common/logger/file_log.yml
copy common/constant/version.go => config/config_setter.go (83%)
delete mode 100644 config_center/zookeeper/impl_test.go
delete mode 100644 config_center/zookeeper/listener_test.go
delete mode 100644 doc/pic/arch/dubbo-go-arch.png
delete mode 100644 doc/pic/arch/dubbo-go-ext.png
delete mode 100644 doc/pic/misc/dubbogo-dingding.png
delete mode 100644 doc/pic/misc/dubbogo-wechat.png
create mode 100644 filter/README.md
rename filter/{filter_impl/access_log_filter.go => accesslog/filter.go} (75%)
rename filter/{filter_impl/access_log_filter_test.go => accesslog/filter_test.go} (90%)
rename filter/{filter_impl/active_filter.go => active/filter.go} (78%)
rename filter/{filter_impl/active_filter_test.go => active/filter_test.go} (94%)
rename filter/{filter_impl => }/auth/accesskey_storage.go (85%)
rename filter/{filter_impl => }/auth/accesskey_storage_test.go (97%)
rename filter/{filter_impl/auth/consumer_sign.go => auth/consumer_sign_filter.go} (90%)
rename filter/{filter_impl/auth/consumer_sign_test.go => auth/consumer_sign_filter_test.go} (100%)
rename filter/{filter_impl => }/auth/default_authenticator.go (93%)
rename filter/{filter_impl => }/auth/default_authenticator_test.go (100%)
rename filter/{filter_impl/auth/provider_auth.go => auth/provider_auth_filter.go} (94%)
rename filter/{filter_impl/auth/provider_auth_test.go => auth/provider_auth_filter_test.go} (100%)
rename filter/{filter_impl => }/auth/sign_util.go (100%)
rename filter/{filter_impl => }/auth/sign_util_test.go (100%)
rename filter/{filter_impl/echo_filter.go => echo/filter.go} (78%)
rename filter/{filter_impl/echo_filter_test.go => echo/filter_test.go} (94%)
rename filter/{filter_impl/execute_limit_filter.go => execlmt/filter.go} (85%)
rename filter/{filter_impl/execute_limit_filter_test.go => execlmt/filter_test.go} (88%)
delete mode 100644 filter/filter_impl/generic_filter.go
delete mode 100644 filter/filter_impl/generic_service_filter.go
delete mode 100644 filter/filter_impl/generic_service_filter_test.go
create mode 100644 filter/filter_impl/import.go
create mode 100644 filter/generic/filter.go
create mode 100644 filter/generic/filter_test.go
create mode 100644 filter/generic/generalizer/example.pb.go
copy cluster/router/v3router/judger/double_range_match_judger_test.go => filter/generic/generalizer/generalizer.go (57%)
create mode 100644 filter/generic/generalizer/gson.go
create mode 100644 filter/generic/generalizer/gson_test.go
create mode 100644 filter/generic/generalizer/map.go
rename filter/{filter_impl/generic_filter_test.go => generic/generalizer/map_test.go} (50%)
create mode 100644 filter/generic/generalizer/protobuf_json.go
copy protocol/invoker_test.go => filter/generic/generalizer/protobuf_json_test.go (51%)
create mode 100644 filter/generic/service_filter.go
create mode 100644 filter/generic/service_filter_test.go
create mode 100644 filter/generic/util.go
rename filter/{filter_impl/graceful_shutdown_filter.go => gshutdown/filter.go} (50%)
rename filter/{filter_impl/graceful_shutdown_filter_test.go => gshutdown/filter_test.go} (95%)
rename filter/{filter_impl/hystrix_filter.go => hystrix/filter.go} (82%)
rename filter/{filter_impl/hystrix_filter_test.go => hystrix/filter_test.go} (91%)
rename filter/{filter_impl/metrics_filter.go => metrics/filter.go} (77%)
rename filter/{filter_impl/metrics_filter_test.go => metrics/filter_test.go} (97%)
rename filter/{filter_impl/seata_filter.go => seata/filter.go} (73%)
rename filter/{filter_impl/seata_filter_test.go => seata/filter_test.go} (97%)
rename filter/{filter_impl/sentinel_filter.go => sentinel/filter.go} (86%)
rename filter/{filter_impl/sentinel_filter_test.go => sentinel/filter_test.go} (97%)
rename filter/{filter_impl/token_filter.go => token/filter.go} (76%)
rename filter/{filter_impl/token_filter_test.go => token/filter_test.go} (95%)
rename filter/{filter_impl/tps_limit_filter.go => tps/filter.go} (76%)
rename filter/{filter_impl/tps_limit_filter_test.go => tps/filter_test.go} (86%)
rename filter/{filter_impl/tps/tps_limiter_method_service.go => tps/limiter/method_service.go} (91%)
rename filter/{filter_impl/tps/tps_limiter_method_service_test.go => tps/limiter/method_service_test.go} (95%)
rename filter/{filter_impl/tps/tps_limiter_mock.go => tps/limiter/mock.go} (99%)
rename filter/{filter_impl/tps/tps_limit_fix_window_strategy.go => tps/strategy/fix_window.go} (85%)
rename filter/{filter_impl/tps/tps_limit_fix_window_strategy_test.go => tps/strategy/fix_window_test.go} (98%)
rename filter/{filter_impl/tps/tps_limit_strategy_mock.go => tps/strategy/mock.go} (98%)
rename filter/{filter_impl/tps/tps_limit_sliding_window_strategy.go => tps/strategy/sliding_window.go} (86%)
rename filter/{filter_impl/tps/tps_limit_sliding_window_strategy_test.go => tps/strategy/sliding_window_test.go} (98%)
rename filter/{filter_impl/tps/tps_limit_thread_safe_fix_window_strategy.go => tps/strategy/thread_safe_fix_window.go} (82%)
rename filter/{filter_impl/tps/tps_limit_thread_safe_fix_window_strategy_test.go => tps/strategy/thread_safe_fix_window_test.go} (98%)
rename filter/{tps_limit_strategy.go => tps_strategy.go} (95%)
rename filter/{filter_impl/tracing_filter.go => tracing/filter.go} (95%)
rename filter/{filter_impl/tracing_filter_test.go => tracing/filter_test.go} (99%)
delete mode 100644 metadata/report/consul/report.go
delete mode 100644 metadata/report/consul/report_test.go
delete mode 100644 metadata/report/zookeeper/report_test.go
rename metadata/service/{inmemory => local}/metadata_service_proxy_factory.go (99%)
rename metadata/service/{inmemory => local}/metadata_service_proxy_factory_test.go (99%)
rename metadata/service/{inmemory => local}/service.go (98%)
rename metadata/service/{inmemory => local}/service_proxy.go (99%)
rename metadata/service/{inmemory => local}/service_proxy_test.go (99%)
rename metadata/service/{inmemory => local}/service_test.go (98%)
rename metadata/service/{service.go => local_service.go} (98%)
rename metadata/service/{remoting => remote}/service.go (87%)
rename metadata/service/{remoting => remote}/service_test.go (96%)
rename metadata/service/{remoting_service.go => remote_service.go} (96%)
create mode 100644 protocol/dubbo/hessian2/java_class.go
create mode 100644 protocol/dubbo/hessian2/java_class_test.go
delete mode 100644 protocol/grpc/common_test.go
copy protocol/grpc/internal/{ => helloworld}/Makefile (100%)
rename protocol/grpc/internal/{ => helloworld}/client.go (98%)
rename protocol/grpc/internal/{ => helloworld}/helloworld.pb.go (84%)
rename protocol/grpc/internal/{ => helloworld}/helloworld.proto (95%)
rename protocol/grpc/internal/{ => helloworld}/server.go (64%)
rename protocol/grpc/internal/{ => multiprotos}/Makefile (83%)
create mode 100644 protocol/grpc/internal/multiprotos/first.pb.go
rename remoting/consul/test_agent_test.go => protocol/grpc/internal/multiprotos/first.proto (78%)
create mode 100644 protocol/grpc/internal/multiprotos/second.pb.go
copy cluster/router/v3router/judger/bool_match_judger.go => protocol/grpc/internal/multiprotos/second.proto (65%)
copy protocol/{dubbo3/protoc-gen-dubbo3/examples => grpc/internal/routeguide}/Makefile (85%)
create mode 100644 protocol/grpc/internal/routeguide/client.go
create mode 100644 protocol/grpc/internal/routeguide/routeguide.pb.go
create mode 100644 protocol/grpc/internal/routeguide/routeguide.proto
create mode 100644 protocol/grpc/internal/routeguide/server.go
delete mode 100644 registry/consul/listener.go
delete mode 100644 registry/consul/listener_test.go
delete mode 100644 registry/consul/registry.go
delete mode 100644 registry/consul/registry_test.go
delete mode 100644 registry/consul/service_discovery.go
delete mode 100644 registry/consul/service_discovery_test.go
delete mode 100644 registry/consul/utils.go
delete mode 100644 registry/consul/utils_test.go
copy config_center/dynamic_configuration_test.go => registry/event_test.go (64%)
delete mode 100644 registry/zookeeper/listener_test.go
delete mode 100644 registry/zookeeper/registry_test.go
delete mode 100644 registry/zookeeper/service_discovery_test.go
delete mode 100644 remoting/consul/test_agent.go
delete mode 100644 remoting/zookeeper/facade_test.go
[dubbo-go] 01/01: Merge branch '3.0' into develop
Posted by al...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
commit 3da71a14e21951c0ec89d646a7e3feb5fe056ab8
Merge: 727e346 f8f38b5
Author: AlexStocks <al...@foxmail.com>
AuthorDate: Wed Aug 18 12:18:17 2021 +0800
Merge branch '3.0' into develop
.github/workflows/github-actions.yml | 4 +-
.gitignore | 4 +-
README.md | 13 +-
README_CN.md | 11 +-
cluster/cluster_impl/failover_cluster_test.go | 4 -
cluster/loadbalance/consistent_hash_test.go | 6 +-
cluster/router/chain.go | 2 -
cluster/router/chain/chain.go | 62 +-
cluster/router/chain/invoker_cache.go | 78 --
cluster/router/router.go | 2 +-
cluster/router/v3router/factory.go | 4 +-
cluster/router/v3router/factory_test.go | 2 +-
.../v3router/judger/attachment_match_judger.go | 55 +-
.../judger/attachment_match_judger_test.go | 15 +-
.../router/v3router/judger/bool_match_judger.go | 4 +-
.../judger/list_string_match_judger_test.go | 26 +-
.../router/v3router/judger/method_match_judger.go | 1 +
.../v3router/judger/method_match_judger_test.go | 77 ++
.../v3router/judger/url_label_match_judge_test.go | 22 +-
cluster/router/v3router/router_chain.go | 23 +-
cluster/router/v3router/router_chain_test.go | 53 +-
cluster/router/v3router/uniform_route.go | 4 +-
common/constant/default.go | 14 +-
common/constant/key.go | 114 ++-
.../constant/{serializtion.go => serialization.go} | 0
common/extension/auth.go | 18 +-
common/extension/metadata_remote.go | 10 +-
common/extension/metadata_service.go | 4 +-
common/extension/metadata_service_proxy_factory.go | 2 +-
common/host_util.go | 4 +-
common/logger/file_log.yml | 36 +
common/logger/logger.go | 58 +-
common/logger/logger_test.go | 54 ++
common/rpc_service.go | 35 +-
common/rpc_service_test.go | 33 +
common/url.go | 24 +-
config/config_api.go | 10 -
config/config_api_test.go | 11 +-
config/config_center_config.go | 64 +-
config/config_center_config_test.go | 22 +-
config/config_loader.go | 25 +-
config/config_loader_test.go | 30 +-
cluster/router/rule.go => config/config_setter.go | 19 +-
config/generic_service.go | 4 +-
config/graceful_shutdown.go | 8 +
config/graceful_shutdown_test.go | 9 +
config/interfaces/config_reader.go | 4 +-
config/reference_config.go | 14 +-
config/reference_config_test.go | 2 +-
config/remote_config.go | 23 +-
config/service.go | 6 +-
config/service_config.go | 6 +-
config/service_discovery_config.go | 4 +-
config/testdata/consumer_config.yml | 1 -
.../testdata/consumer_config_with_configcenter.yml | 1 -
.../testdata/consumer_config_withoutProtocol.yml | 1 -
config/testdata/provider_config.yml | 1 -
.../testdata/provider_config_withoutProtocol.yml | 1 -
config/uniform_router_config.go | 2 +-
config_center/apollo/impl_test.go | 3 +-
config_center/nacos/client.go | 45 +-
config_center/nacos/client_test.go | 6 +-
config_center/nacos/impl.go | 2 +-
config_center/zookeeper/impl_test.go | 232 ------
config_center/zookeeper/listener_test.go | 101 ---
doc/pic/arch/dubbo-go-arch.png | Bin 190013 -> 0 bytes
doc/pic/arch/dubbo-go-ext.png | Bin 194550 -> 0 bytes
doc/pic/misc/dubbogo-dingding.png | Bin 39890 -> 0 bytes
doc/pic/misc/dubbogo-wechat.png | Bin 15414 -> 0 bytes
filter/README.md | 38 +
.../access_log_filter.go => accesslog/filter.go} | 76 +-
.../filter_test.go} | 14 +-
.../active_filter.go => active/filter.go} | 21 +-
.../filter_test.go} | 10 +-
filter/{filter_impl => }/auth/accesskey_storage.go | 15 +-
.../auth/accesskey_storage_test.go | 2 +-
.../consumer_sign_filter.go} | 17 +-
.../consumer_sign_filter_test.go} | 0
.../auth/default_authenticator.go | 14 +-
.../auth/default_authenticator_test.go | 0
.../provider_auth_filter.go} | 10 +-
.../provider_auth_filter_test.go} | 0
filter/{filter_impl => }/auth/sign_util.go | 0
filter/{filter_impl => }/auth/sign_util_test.go | 0
.../{filter_impl/echo_filter.go => echo/filter.go} | 26 +-
.../echo_filter_test.go => echo/filter_test.go} | 6 +-
.../execute_limit_filter.go => execlmt/filter.go} | 26 +-
.../filter_test.go} | 14 +-
filter/filter_impl/generic_filter.go | 167 ----
filter/filter_impl/generic_service_filter.go | 132 ----
filter/filter_impl/generic_service_filter_test.go | 150 ----
filter/filter_impl/import.go | 41 +
filter/generic/filter.go | 97 +++
filter/generic/filter_test.go | 100 +++
filter/generic/generalizer/example.pb.go | 259 ++++++
.../generic/generalizer/generalizer.go | 41 +-
filter/generic/generalizer/gson.go | 99 +++
filter/generic/generalizer/gson_test.go | 97 +++
filter/generic/generalizer/map.go | 206 +++++
.../generalizer/map_test.go} | 170 +++-
filter/generic/generalizer/protobuf_json.go | 90 +++
.../generic/generalizer/protobuf_json_test.go | 38 +-
filter/generic/service_filter.go | 130 ++++
filter/generic/service_filter_test.go | 211 +++++
filter/generic/util.go | 80 ++
.../filter.go} | 67 +-
.../filter_test.go} | 4 +-
.../handler/rejected_execution_handler_only_log.go | 3 +-
.../hystrix_filter.go => hystrix/filter.go} | 75 +-
.../filter_test.go} | 28 +-
.../metrics_filter.go => metrics/filter.go} | 28 +-
.../filter_test.go} | 4 +-
.../seata_filter.go => seata/filter.go} | 20 +-
.../seata_filter_test.go => seata/filter_test.go} | 4 +-
.../sentinel_filter.go => sentinel/filter.go} | 35 +-
.../filter_test.go} | 8 +-
.../token_filter.go => token/filter.go} | 24 +-
.../token_filter_test.go => token/filter_test.go} | 10 +-
.../tps_limit_filter.go => tps/filter.go} | 30 +-
.../filter_test.go} | 25 +-
.../limiter/method_service.go} | 22 +-
.../limiter/method_service_test.go} | 9 +-
.../tps_limiter_mock.go => tps/limiter/mock.go} | 2 +-
.../strategy/fix_window.go} | 16 +-
.../strategy/fix_window_test.go} | 2 +-
.../strategy/mock.go} | 8 +-
.../strategy/sliding_window.go} | 12 +-
.../strategy/sliding_window_test.go} | 2 +-
.../strategy/thread_safe_fix_window.go} | 18 +-
.../strategy/thread_safe_fix_window_test.go} | 2 +-
filter/{tps_limit_strategy.go => tps_strategy.go} | 2 +-
.../tracing_filter.go => tracing/filter.go} | 10 +-
.../filter_test.go} | 2 +-
go.mod | 38 +-
go.sum | 409 +++-------
metadata/identifier/base_metadata_identifier.go | 9 +-
.../identifier/base_metadata_identifier_test.go | 2 +-
metadata/identifier/metadata_identifier_test.go | 2 +-
.../identifier/service_metadata_identifier_test.go | 2 +-
metadata/report/consul/report.go | 134 ----
metadata/report/consul/report_test.go | 170 ----
metadata/report/zookeeper/report_test.go | 203 -----
.../service/exporter/configurable/exporter_test.go | 5 +-
.../metadata_service_proxy_factory.go | 2 +-
.../metadata_service_proxy_factory_test.go | 2 +-
metadata/service/{inmemory => local}/service.go | 6 +-
.../service/{inmemory => local}/service_proxy.go | 2 +-
.../{inmemory => local}/service_proxy_test.go | 2 +-
.../service/{inmemory => local}/service_test.go | 4 +-
metadata/service/{service.go => local_service.go} | 4 +-
metadata/service/{remoting => remote}/service.go | 24 +-
.../service/{remoting => remote}/service_test.go | 8 +-
.../{remoting_service.go => remote_service.go} | 2 +-
protocol/dubbo/dubbo_invoker.go | 6 +-
protocol/dubbo/dubbo_invoker_test.go | 2 -
protocol/dubbo/dubbo_protocol_test.go | 2 -
protocol/dubbo/hessian2/hessian_request.go | 95 +--
protocol/dubbo/hessian2/hessian_response.go | 6 +-
protocol/dubbo/hessian2/java_class.go | 200 +++++
protocol/dubbo/hessian2/java_class_test.go | 132 ++++
protocol/dubbo/impl/const.go | 2 +
protocol/dubbo3/dubbo3_protocol.go | 28 +-
protocol/dubbo3/dubbo3_protocol_test.go | 63 ++
protocol/dubbo3/internal/helloworld.pb.go | 9 +-
.../protoc-gen-dubbo3/examples/helloworld.pb.go | 9 +-
protocol/dubbo3/protoc-gen-dubbo3/go.mod | 6 +-
protocol/dubbo3/protoc-gen-dubbo3/go.sum | 95 ++-
protocol/dubbo3/protoc-gen-dubbo3/main.go | 5 +-
protocol/grpc/client_test.go | 73 +-
protocol/grpc/common_test.go | 114 ---
protocol/grpc/grpc_invoker_test.go | 118 ++-
protocol/grpc/grpc_protocol_test.go | 21 +-
protocol/grpc/internal/README.md | 6 +
protocol/grpc/internal/{ => helloworld}/Makefile | 0
protocol/grpc/internal/{ => helloworld}/client.go | 2 +-
.../internal/{ => helloworld}/helloworld.pb.go | 64 +-
.../internal/{ => helloworld}/helloworld.proto | 3 +-
protocol/grpc/internal/{ => helloworld}/server.go | 53 +-
protocol/grpc/internal/{ => multiprotos}/Makefile | 4 +-
protocol/grpc/internal/multiprotos/first.pb.go | 307 ++++++++
.../grpc/internal/multiprotos/first.proto | 22 +-
protocol/grpc/internal/multiprotos/second.pb.go | 589 ++++++++++++++
.../grpc/internal/multiprotos/second.proto | 24 +-
protocol/grpc/internal/{ => routeguide}/Makefile | 38 +-
protocol/grpc/internal/routeguide/client.go | 110 +++
protocol/grpc/internal/routeguide/routeguide.pb.go | 865 +++++++++++++++++++++
protocol/grpc/internal/routeguide/routeguide.proto | 114 +++
protocol/grpc/internal/routeguide/server.go | 827 ++++++++++++++++++++
.../grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go | 34 +-
protocol/grpc/server.go | 5 +-
protocol/invocation/rpcinvocation.go | 4 -
protocol/jsonrpc/http.go | 4 -
.../protocol_filter_wrapper_test.go | 20 +-
registry/base_registry.go | 6 +-
registry/consul/listener.go | 207 -----
registry/consul/registry.go | 219 ------
registry/consul/registry_test.go | 73 --
registry/consul/service_discovery.go | 492 ------------
registry/consul/service_discovery_test.go | 209 -----
registry/consul/utils.go | 115 ---
registry/consul/utils_test.go | 211 -----
registry/directory/directory.go | 24 +-
registry/etcdv3/listener.go | 11 +-
registry/etcdv3/listener_test.go | 7 +-
registry/etcdv3/registry.go | 10 +-
registry/etcdv3/service_discovery.go | 2 +
registry/event.go | 9 +-
.../event_publishing_service_deiscovery_test.go | 4 +-
.../event/event_publishing_service_discovery.go | 4 +-
.../service_instances_changed_listener_impl.go | 2 +-
.../echo_filter_test.go => registry/event_test.go | 28 +-
registry/file/listener.go | 4 +-
registry/kubernetes/listener.go | 11 +-
registry/kubernetes/registry.go | 12 +-
registry/kubernetes/registry_test.go | 1 +
registry/nacos/listener.go | 15 +-
registry/nacos/registry.go | 4 +-
registry/nacos/service_discovery.go | 11 +-
registry/service_instance.go | 4 +-
registry/service_instances_changed_listener.go | 10 +-
.../servicediscovery/service_discovery_registry.go | 6 +-
registry/zookeeper/listener.go | 10 +-
registry/zookeeper/listener_test.go | 46 --
registry/zookeeper/registry.go | 9 +-
registry/zookeeper/registry_test.go | 185 -----
registry/zookeeper/service_discovery_test.go | 279 -------
remoting/etcdv3/facade.go | 52 +-
remoting/getty/config.go | 3 -
remoting/getty/dubbo_codec_for_test.go | 1 +
remoting/getty/getty_client.go | 7 +-
remoting/getty/getty_client_test.go | 4 +-
remoting/getty/getty_server.go | 3 +
remoting/getty/listener.go | 6 +-
remoting/getty/listener_test.go | 1 +
remoting/getty/pool.go | 1 +
remoting/getty/readwriter.go | 14 +-
remoting/getty/readwriter_test.go | 3 +-
remoting/kubernetes/facade.go | 4 +-
remoting/nacos/builder.go | 68 +-
remoting/nacos/builder_test.go | 2 +
remoting/zookeeper/facade.go | 1 +
remoting/zookeeper/facade_test.go | 125 ---
remoting/zookeeper/listener.go | 7 +-
remoting/zookeeper/listener_test.go | 104 ---
test/integrate/dubbo/go-client/client.yml | 2 -
test/integrate/dubbo/go-client/user.go | 5 +-
test/integrate/dubbo/go-server/server.yml | 2 -
test/integrate/dubbo/go-server/user.go | 3 +
248 files changed, 6633 insertions(+), 5540 deletions(-)