This is an automated email from the ASF dual-hosted git repository. victory pushed a commit to branch apache_develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
commit 4a4268429d8dbfec4a93b3bd6f7b642dc5656ba6 Merge: aac5ad203 19ca5d1d2 Author: cvictory <[email protected]> AuthorDate: Thu Aug 25 18:03:02 2022 +0800 merge new 1.5 version .github/workflows/github-actions.yml | 130 +++-- .gitignore | 1 + CHANGE.md | 61 ++- README.md | 5 + README_CN.md | 7 +- .../cluster_impl/available_cluster_invoker_test.go | 1 + cluster/cluster_impl/base_cluster_invoker.go | 21 +- cluster/cluster_impl/base_cluster_invoker_test.go | 3 + cluster/cluster_impl/broadcast_cluster_invoker.go | 1 + .../cluster_impl/broadcast_cluster_invoker_test.go | 1 + cluster/cluster_impl/failback_cluster_invoker.go | 2 +- cluster/cluster_impl/failback_cluster_test.go | 2 + cluster/cluster_impl/failfast_cluster_invoker.go | 3 +- cluster/cluster_impl/failfast_cluster_test.go | 2 + cluster/cluster_impl/failover_cluster_invoker.go | 4 +- cluster/cluster_impl/failover_cluster_test.go | 3 +- cluster/cluster_impl/failsafe_cluster_invoker.go | 3 +- cluster/cluster_impl/failsafe_cluster_test.go | 2 + cluster/cluster_impl/forking_cluster_invoker.go | 2 +- cluster/cluster_impl/forking_cluster_test.go | 1 + cluster/cluster_impl/zone_aware_cluster_invoker.go | 2 +- .../zone_aware_cluster_invoker_test.go | 1 + cluster/directory.go | 1 + cluster/directory/static_directory.go | 9 + cluster/loadbalance/consistent_hash.go | 25 +- cluster/loadbalance/consistent_hash_test.go | 8 +- cluster/router/chain/chain.go | 4 +- cluster/router/chain/chain_test.go | 298 ----------- cluster/router/condition/app_router_test.go | 220 -------- cluster/router/condition/factory_test.go | 1 + cluster/router/condition/listenable_router.go | 1 + cluster/router/condition/router.go | 2 + cluster/router/condition/router_test.go | 6 +- cluster/router/conn_checker.go | 28 - cluster/router/conncheck/conn_check_route.go | 138 ----- cluster/router/conncheck/conn_check_route_test.go | 163 ------ cluster/router/conncheck/conn_health_check.go | 45 -- cluster/router/conncheck/conn_health_check_test.go | 52 -- cluster/router/conncheck/factory.go | 44 -- cluster/router/conncheck/factory_test.go | 74 --- cluster/router/tag/file.go | 1 + cluster/router/tag/router_rule.go | 2 +- cluster/router/tag/tag_router.go | 2 + cluster/router/tag/tag_router_test.go | 79 +-- cluster/router/utils/bitmap_util_test.go | 1 + common/constant/default.go | 15 + common/constant/key.go | 75 ++- common/constant/version.go | 4 +- common/extension/config_load_processor.go | 183 +++++++ common/extension/config_post_processor.go | 5 + common/extension/conn_checker.go | 41 -- common/extension/event_dispatcher_test.go | 1 + common/extension/service_discovery.go | 1 + common/host_util.go | 4 +- common/logger/logger.go | 5 + common/logger/logger_test.go | 34 ++ common/logger/logging.go | 10 + common/proxy/proxy.go | 1 + common/proxy/proxy_test.go | 1 + common/rpc_service.go | 4 +- common/url.go | 36 +- common/url_test.go | 10 + common/yaml/yaml.go | 1 + config/config_center_config.go | 11 +- config/config_loader.go | 20 +- config/config_loader_test.go | 102 ++++ config/consumer_config.go | 2 + config/generic_service.go | 4 +- config/graceful_shutdown.go | 2 + config/interfaces/config_load_processor.go | 56 ++ config/interfaces/config_reader.go | 4 +- config/metadata_report_config.go | 5 +- config/metadata_report_config_test.go | 4 +- config/protocol_config.go | 7 +- config/provider_config.go | 4 +- config/reference_config.go | 34 +- config/remote_config.go | 24 +- config/remote_config_test.go | 1 + config/router_config.go | 1 + config/router_config_test.go | 1 + config/service_config.go | 21 + config/service_config_test.go | 3 +- config/testdata/consumer_config.properties | 1 - config/testdata/consumer_config.yml | 1 - .../testdata/consumer_config_with_configcenter.yml | 1 - .../testdata/consumer_config_withoutProtocol.yml | 1 - config/testdata/provider_config.properties | 1 - config/testdata/provider_config.yml | 1 - .../testdata/provider_config_withoutProtocol.yml | 1 - config_center/apollo/impl.go | 2 + config_center/apollo/impl_test.go | 1 - config_center/apollo/listener.go | 1 + config_center/dynamic_configuration.go | 6 +- config_center/file/impl.go | 1 + config_center/mock_dynamic_config.go | 1 + config_center/nacos/client.go | 165 ++---- config_center/nacos/client_test.go | 56 +- config_center/nacos/facade.go | 51 +- config_center/nacos/impl.go | 37 +- config_center/nacos/impl_test.go | 115 +---- config_center/nacos/listener.go | 2 +- config_center/parser/configuration_parser.go | 2 + config_center/zookeeper/impl.go | 7 +- config_center/zookeeper/impl_test.go | 233 --------- config_center/zookeeper/listener_test.go | 101 ---- filter/filter_impl/access_log_filter_test.go | 1 + filter/filter_impl/active_filter_test.go | 1 + filter/filter_impl/auth/consumer_sign.go | 1 + filter/filter_impl/auth/consumer_sign_test.go | 1 + filter/filter_impl/auth/default_authenticator.go | 2 +- filter/filter_impl/auth/provider_auth_test.go | 1 + filter/filter_impl/generic_filter.go | 143 ++---- filter/filter_impl/generic_filter_test.go | 175 +++---- filter/filter_impl/generic_generalizer_map.go | 208 ++++++++ ...ter_test.go => generic_generalizer_map_test.go} | 168 +++++- filter/filter_impl/generic_service_filter.go | 112 ++-- filter/filter_impl/generic_service_filter_test.go | 230 +++++---- filter/filter_impl/hystrix_filter.go | 4 + filter/filter_impl/hystrix_filter_test.go | 2 + filter/filter_impl/sentinel_filter.go | 1 - filter/filter_impl/sentinel_filter_test.go | 1 + filter/filter_impl/tps/tps_limit_strategy_mock.go | 4 +- .../tps/tps_limiter_method_service_test.go | 2 + filter/filter_impl/tps_limit_filter.go | 1 + filter/filter_impl/tps_limit_filter_test.go | 7 +- .../handler/rejected_execution_handler_only_log.go | 2 +- .../rejected_execution_handler_only_log_test.go | 1 + go.mod | 39 +- go.sum | 572 +++++++++------------ integrate_test.sh | 1 + metadata/identifier/base_metadata_identifier.go | 11 +- .../identifier/base_metadata_identifier_test.go | 2 +- metadata/identifier/metadata_identifier_test.go | 2 +- .../identifier/service_metadata_identifier_test.go | 2 +- .../subscribe_metadata_identifier_test.go | 2 +- metadata/mapping/dynamic/service_name_mapping.go | 1 + .../mapping/dynamic/service_name_mapping_test.go | 1 + metadata/mapping/memory/service_name_mapping.go | 1 + metadata/report/consul/report.go | 125 ----- metadata/report/consul/report_test.go | 167 ------ metadata/report/delegate/delegate_report.go | 2 + metadata/report/delegate/delegate_report_test.go | 1 + metadata/report/etcd/report.go | 15 +- metadata/report/etcd/report_test.go | 134 ----- metadata/report/nacos/report.go | 14 +- metadata/report/zookeeper/report_test.go | 169 ------ .../service/exporter/configurable/exporter_test.go | 1 - metadata/service/remote/service_proxy.go | 1 + metadata/service/remote/service_proxy_test.go | 1 + protocol/dubbo/dubbo_codec.go | 51 +- protocol/dubbo/dubbo_invoker.go | 9 +- protocol/dubbo/dubbo_invoker_test.go | 5 +- protocol/dubbo/dubbo_protocol.go | 3 + protocol/dubbo/dubbo_protocol_test.go | 2 - protocol/dubbo/hessian2/hessian_dubbo.go | 1 + protocol/dubbo/hessian2/hessian_dubbo_test.go | 1 + protocol/dubbo/hessian2/hessian_request.go | 93 +--- protocol/dubbo/hessian2/hessian_request_test.go | 1 + protocol/dubbo/hessian2/hessian_response.go | 6 +- protocol/dubbo/hessian2/hessian_response_test.go | 1 + protocol/dubbo/hessian2/java_class.go | 201 ++++++++ protocol/dubbo/hessian2/java_class_test.go | 132 +++++ protocol/dubbo/impl/codec.go | 14 +- protocol/dubbo/impl/const.go | 2 + protocol/dubbo/impl/hessian.go | 1 + protocol/dubbo/impl/package.go | 1 + protocol/dubbo/opentracing.go | 1 + protocol/grpc/client.go | 3 + protocol/grpc/client_test.go | 1 + protocol/grpc/codec.go | 1 + protocol/grpc/grpc_invoker.go | 2 + protocol/grpc/internal/helloworld.pb.go | 3 + .../protoc-gen-dubbo/examples/helloworld.pb.go | 3 + protocol/grpc/server.go | 7 +- protocol/invocation.go | 4 + protocol/invocation/rpcinvocation.go | 25 +- protocol/invoker.go | 1 + protocol/jsonrpc/http.go | 2 +- protocol/jsonrpc/http_test.go | 2 + protocol/jsonrpc/server.go | 1 + protocol/rest/client/client_impl/resty_client.go | 1 + protocol/rest/config/reader/rest_config_reader.go | 1 + protocol/rest/rest_invoker_test.go | 1 + .../rest/server/server_impl/go_restful_server.go | 1 + protocol/rpc_status.go | 129 ++--- 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 | 493 ------------------ registry/consul/service_discovery_test.go | 234 --------- registry/consul/utils.go | 115 ----- registry/consul/utils_test.go | 210 -------- registry/directory/directory.go | 33 +- registry/directory/directory_test.go | 1 + registry/etcdv3/listener.go | 17 +- registry/etcdv3/listener_test.go | 95 ---- registry/etcdv3/registry.go | 33 +- registry/etcdv3/registry_test.go | 132 ----- registry/etcdv3/service_discovery.go | 11 +- registry/event.go | 10 +- .../event_publishing_service_deiscovery_test.go | 1 + .../metadata_service_url_params_customizer_test.go | 1 + .../event/protocol_ports_metadata_customizer.go | 4 +- .../builder_test.go => registry/event_test.go | 38 +- registry/file/listener.go | 4 +- registry/file/service_discovery.go | 1 + registry/kubernetes/listener.go | 17 +- registry/kubernetes/registry.go | 8 +- registry/kubernetes/registry_test.go | 1 + registry/nacos/listener.go | 43 +- registry/nacos/registry.go | 92 +--- registry/nacos/registry_test.go | 17 +- registry/nacos/service_discovery.go | 31 +- registry/protocol/protocol.go | 20 +- registry/protocol/protocol_test.go | 1 + registry/service_instance.go | 1 + .../servicediscovery/service_discovery_registry.go | 2 + .../service_discovery_registry_test.go | 2 + registry/zookeeper/listener.go | 19 +- registry/zookeeper/registry.go | 2 + registry/zookeeper/registry_test.go | 185 ------- registry/zookeeper/service_discovery.go | 1 + registry/zookeeper/service_discovery_test.go | 209 -------- remoting/codec.go | 2 +- remoting/consul/test_agent.go | 38 -- remoting/consul/test_agent_test.go | 32 -- remoting/etcdv3/client.go | 449 +--------------- remoting/etcdv3/client_test.go | 411 --------------- remoting/etcdv3/facade.go | 33 +- remoting/etcdv3/listener.go | 29 +- remoting/etcdv3/listener_test.go | 104 ---- remoting/exchange.go | 9 +- remoting/getty/config.go | 26 +- remoting/getty/dubbo_codec_for_test.go | 26 +- remoting/getty/getty_client.go | 9 +- remoting/getty/getty_client_test.go | 154 ++---- remoting/getty/getty_server.go | 3 + remoting/getty/listener.go | 14 +- remoting/getty/listener_test.go | 1 + remoting/getty/opentracing.go | 1 + remoting/getty/readwriter.go | 40 +- remoting/getty/readwriter_test.go | 151 ++++-- remoting/kubernetes/client.go | 2 + remoting/kubernetes/facade.go | 4 +- remoting/kubernetes/registry_controller.go | 7 + remoting/nacos/builder.go | 141 ++--- remoting/nacos/builder_test.go | 137 ++++- remoting/zookeeper/client.go | 1 + .../curator_discovery/service_discovery.go | 2 + remoting/zookeeper/facade.go | 2 + remoting/zookeeper/facade_test.go | 125 ----- remoting/zookeeper/listener.go | 8 +- remoting/zookeeper/listener_test.go | 106 ---- samples | 1 - test/integrate/dubbo/go-client/client.go | 11 +- test/integrate/dubbo/go-client/client.yml | 1 - test/integrate/dubbo/go-client/user.go | 3 + test/integrate/dubbo/go-server/server.go | 3 + test/integrate/dubbo/go-server/server.yml | 1 - test/integrate/dubbo/go-server/user.go | 3 + tools/cli/client/client.go | 5 +- tools/cli/example/server/config/server.yml | 1 - tools/cli/example/server/main.go | 3 + tools/cli/example/server/user.go | 3 + tools/cli/json_register/json_register.go | 1 + tools/cli/protocol/dubbo/codec.go | 6 +- tools/cli/protocol/dubbo/dubbo_protocol.go | 1 + 268 files changed, 3175 insertions(+), 7583 deletions(-)
