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:02 UTC
[dubbo-go] 01/01: Merge branch '3.0' into develop
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(-)