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 <[email protected]> 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(-)
