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 aac5ad2039da73f4facb815cde7ba87a416326c9 Merge: 8f9802ef6 d63f53c00 Author: cvictory <[email protected]> AuthorDate: Thu Aug 25 17:58:46 2022 +0800 merge new 1.5 version .github/PULL_REQUEST_TEMPLATE.md | 2 +- .github/workflows/github-actions.yml | 14 +- .gitmodules | 3 + CHANGE.md | 157 +++- NOTICE | 2 +- README.md | 61 +- README_CN.md | 82 +- cluster/cluster_impl/available_cluster.go | 4 +- .../cluster_impl/available_cluster_invoker_test.go | 2 +- cluster/cluster_impl/base_cluster_invoker.go | 89 ++- cluster/cluster_impl/broadcast_cluster.go | 2 +- .../cluster_impl/broadcast_cluster_invoker_test.go | 2 +- cluster/cluster_impl/failback_cluster.go | 2 +- cluster/cluster_impl/failback_cluster_invoker.go | 10 +- cluster/cluster_impl/failback_cluster_test.go | 19 +- cluster/cluster_impl/failfast_cluster.go | 2 +- cluster/cluster_impl/failfast_cluster_test.go | 9 +- cluster/cluster_impl/failover_cluster.go | 2 +- cluster/cluster_impl/failover_cluster_invoker.go | 8 +- cluster/cluster_impl/failover_cluster_test.go | 4 +- cluster/cluster_impl/failsafe_cluster.go | 2 +- cluster/cluster_impl/failsafe_cluster_invoker.go | 2 +- cluster/cluster_impl/failsafe_cluster_test.go | 10 +- cluster/cluster_impl/forking_cluster.go | 2 +- cluster/cluster_impl/forking_cluster_invoker.go | 4 +- cluster/cluster_impl/forking_cluster_test.go | 2 +- cluster/cluster_impl/interceptor_invoker.go | 76 ++ cluster/cluster_impl/mock_cluster.go | 2 +- cluster/cluster_impl/zone_aware_cluster.go | 2 +- ...luster.go => zone_aware_cluster_interceptor.go} | 42 +- cluster/cluster_impl/zone_aware_cluster_invoker.go | 36 +- .../zone_aware_cluster_invoker_test.go | 8 +- cluster/cluster_interceptor.go | 16 +- cluster/directory/base_directory.go | 68 +- cluster/directory/base_directory_test.go | 9 +- cluster/directory/static_directory.go | 7 +- cluster/loadbalance/consistent_hash.go | 6 +- cluster/loadbalance/consistent_hash_test.go | 6 +- cluster/loadbalance/least_active.go | 2 +- cluster/loadbalance/least_active_test.go | 8 +- cluster/loadbalance/random_test.go | 6 +- cluster/loadbalance/round_robin.go | 4 +- cluster/loadbalance/round_robin_test.go | 4 +- cluster/loadbalance/util.go | 2 +- cluster/router/.gitkeep | 0 cluster/router/chain.go | 17 + cluster/router/chain/chain.go | 128 ++- cluster/router/chain/chain_test.go | 52 +- cluster/router/condition/app_router.go | 5 +- cluster/router/condition/app_router_test.go | 33 +- cluster/router/condition/factory.go | 8 +- cluster/router/condition/factory_test.go | 114 ++- cluster/router/condition/listenable_router.go | 11 +- cluster/router/condition/router.go | 6 +- cluster/router/condition/router_test.go | 15 +- cluster/router/{chain.go => conn_checker.go} | 12 +- cluster/router/conncheck/conn_check_route.go | 138 ++++ cluster/router/conncheck/conn_check_route_test.go | 163 ++++ .../factory.go => conncheck/conn_health_check.go} | 22 +- .../conn_health_check_test.go} | 60 +- cluster/router/{tag => conncheck}/factory.go | 25 +- .../{healthcheck => conncheck}/factory_test.go | 6 +- cluster/router/healthcheck/default_health_check.go | 8 +- cluster/router/healthcheck/factory.go | 4 +- cluster/router/healthcheck/factory_test.go | 2 +- cluster/router/healthcheck/health_check_route.go | 12 +- .../router/healthcheck/health_check_route_test.go | 22 +- cluster/router/{healthcheck => local}/factory.go | 20 +- .../router/{healthcheck => local}/factory_test.go | 8 +- cluster/router/local/self_priority_route.go | 106 +++ cluster/router/local/self_priority_route_test.go | 76 ++ cluster/router/router.go | 7 +- cluster/router/tag/factory.go | 4 +- cluster/router/tag/factory_test.go | 7 +- cluster/router/tag/file.go | 29 +- cluster/router/tag/tag_router.go | 30 +- cluster/router/tag/tag_router_test.go | 61 +- cluster/router/utils/bitmap_util.go | 14 +- cluster/router/utils/bitmap_util_test.go | 78 ++ common/config/environment.go | 18 +- common/config/environment_test.go | 23 + common/constant/default.go | 6 +- common/constant/key.go | 41 +- common/constant/version.go | 4 +- common/extension/cluster_interceptor.go | 60 ++ .../extension/conn_checker.go | 36 +- common/extension/metadata_service.go | 17 + common/logger/logger.go | 11 +- common/node.go | 2 +- common/proxy/proxy.go | 80 +- common/proxy/proxy_factory/default.go | 2 +- common/proxy/proxy_factory/generic.go | 160 ++++ .../proxy/proxy_factory/generic_test.go | 57 +- common/proxy/proxy_test.go | 8 +- common/url.go | 19 +- config/base_config.go | 18 +- config/base_config_test.go | 12 +- config/config_api.go | 556 +++++++++++++ config/config_api_test.go | 174 ++++ config/config_center_config.go | 49 +- config/config_loader.go | 56 +- config/config_loader_test.go | 7 +- config/consumer_config.go | 6 +- config/generic_service_ext.go | 41 + config/graceful_shutdown.go | 14 +- config/graceful_shutdown_config_test.go | 4 +- config/metadata_report_config.go | 4 +- config/provider_config.go | 4 +- config/reference_config.go | 58 +- config/reference_config_test.go | 53 +- config/registry_config.go | 4 +- config/remote_config.go | 12 +- config/service.go | 5 + config/service_config.go | 21 +- config/service_discovery_config.go | 13 +- config/testdata/router_config.yml | 2 +- config/testdata/router_config_error.yml | 2 +- config_center/apollo/impl_test.go | 4 +- config_center/configurator.go | 4 +- config_center/configurator/mock.go | 6 +- config_center/configurator/override.go | 2 +- config_center/configurator/override_test.go | 14 +- config_center/file/impl.go | 110 ++- config_center/nacos/client.go | 23 +- config_center/nacos/impl.go | 4 +- config_center/zookeeper/impl.go | 14 +- config_center/zookeeper/impl_test.go | 19 +- config_center/zookeeper/listener.go | 10 +- config_center/zookeeper/listener_test.go | 101 +++ contributing.md | 6 +- doc/apache/apache-release-procedure-20200306.md | 10 +- doc/pic/misc/dubbogo-dingding.png | Bin 0 -> 39890 bytes doc/pic/misc/dubbogo-wechat.png | Bin 0 -> 15414 bytes filter/filter_impl/access_log_filter.go | 2 +- filter/filter_impl/active_filter.go | 4 +- filter/filter_impl/active_filter_test.go | 4 +- filter/filter_impl/auth/consumer_sign.go | 2 +- filter/filter_impl/auth/consumer_sign_test.go | 2 +- filter/filter_impl/auth/provider_auth.go | 2 +- filter/filter_impl/auth/provider_auth_test.go | 2 +- filter/filter_impl/execute_limit_filter.go | 2 +- filter/filter_impl/generic_filter.go | 19 +- filter/filter_impl/generic_filter_test.go | 29 +- filter/filter_impl/generic_service_filter.go | 2 +- filter/filter_impl/graceful_shutdown_filter.go | 2 +- filter/filter_impl/hystrix_filter.go | 4 +- filter/filter_impl/sentinel_filter.go | 5 +- filter/filter_impl/token_filter.go | 2 +- .../tps/tps_limiter_method_service_test.go | 2 +- filter/filter_impl/tps_limit_filter.go | 4 +- filter/filter_impl/tracing_filter.go | 2 +- go.mod | 34 +- go.sum | 207 +++-- integrate_test.sh | 69 +- metadata/report/delegate/delegate_report.go | 4 + metadata/report/zookeeper/report.go | 12 +- .../metadata_service_proxy_factory_test.go | 2 +- metadata/service/remote/service.go | 36 +- metadata/service/remote/service_proxy.go | 2 +- metrics/prometheus/reporter.go | 2 +- protocol/dubbo/dubbo_exporter.go | 4 +- protocol/dubbo/dubbo_invoker.go | 100 ++- protocol/dubbo/dubbo_invoker_test.go | 2 - protocol/dubbo/dubbo_protocol.go | 6 +- protocol/dubbo/dubbo_protocol_test.go | 8 +- protocol/dubbo/impl/hessian.go | 4 + protocol/grpc/client.go | 19 +- protocol/grpc/client_test.go | 6 +- protocol/grpc/grpc_exporter.go | 4 +- protocol/grpc/grpc_invoker.go | 73 +- protocol/grpc/grpc_invoker_test.go | 7 +- protocol/grpc/grpc_protocol.go | 43 +- protocol/grpc/grpc_protocol_test.go | 40 +- .../grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go | 6 + protocol/grpc/server.go | 101 ++- protocol/invocation/rpcinvocation.go | 3 +- protocol/invocation/rpcinvocation_test.go | 74 ++ protocol/invoker.go | 42 +- .../factory_test.go => protocol/invoker_test.go | 25 +- protocol/jsonrpc/jsonrpc_exporter.go | 4 +- protocol/jsonrpc/jsonrpc_invoker.go | 2 +- protocol/jsonrpc/jsonrpc_protocol.go | 2 +- protocol/jsonrpc/jsonrpc_protocol_test.go | 4 +- protocol/mock/mock_invoker.go | 12 +- .../protocolwrapper/protocol_filter_wrapper.go | 22 +- .../protocol_filter_wrapper_test.go | 4 +- protocol/rest/config/reader/rest_config_reader.go | 4 +- protocol/rest/config/rest_config.go | 12 +- protocol/rest/rest_exporter.go | 4 +- protocol/rest/rest_invoker.go | 2 +- protocol/rest/rest_invoker_test.go | 2 +- protocol/rest/rest_protocol.go | 9 +- protocol/rest/rest_protocol_test.go | 4 +- protocol/rest/server/rest_server.go | 2 +- protocol/rpc_status.go | 97 ++- registry/base_registry.go | 11 +- registry/consul/registry.go | 43 +- registry/directory/directory.go | 77 +- registry/directory/directory_test.go | 6 +- registry/etcdv3/listener.go | 10 +- registry/etcdv3/registry.go | 19 +- registry/etcdv3/service_discovery_test.go | 4 +- registry/event.go | 2 +- registry/file/service_discovery.go | 2 +- registry/kubernetes/registry.go | 4 +- registry/mock_registry.go | 2 +- registry/nacos/listener.go | 8 +- registry/nacos/registry.go | 23 +- registry/nacos/registry_test.go | 24 +- registry/nacos/service_discovery.go | 16 +- registry/nacos/service_discovery_test.go | 36 +- registry/protocol/protocol.go | 50 +- registry/protocol/protocol_test.go | 18 +- .../servicediscovery/service_discovery_registry.go | 6 +- registry/zookeeper/listener.go | 15 +- registry/zookeeper/registry.go | 64 +- registry/zookeeper/registry_test.go | 11 +- registry/zookeeper/service_discovery.go | 21 +- registry/zookeeper/service_discovery_test.go | 31 +- remoting/consul/test_agent.go | 2 +- remoting/etcdv3/facade.go | 2 +- remoting/etcdv3/listener.go | 6 +- remoting/exchange.go | 2 +- remoting/exchange_client.go | 25 +- remoting/exchange_server.go | 4 +- remoting/getty/config.go | 6 - remoting/getty/getty_client.go | 380 ++++++++- remoting/getty/getty_client_test.go | 34 +- remoting/getty/listener.go | 16 +- remoting/getty/pool.go | 449 ----------- remoting/getty/pool_test.go | 51 -- remoting/getty/readwriter.go | 6 +- remoting/getty/readwriter_test.go | 171 ++++ remoting/kubernetes/client.go | 2 +- remoting/kubernetes/facade_test.go | 2 +- remoting/nacos/builder.go | 1 + remoting/zookeeper/client.go | 581 +------------- remoting/zookeeper/client_test.go | 166 ---- .../curator_discovery/service_discovery.go | 5 +- remoting/zookeeper/facade.go | 60 +- remoting/zookeeper/facade_test.go | 35 +- remoting/zookeeper/listener.go | 114 ++- remoting/zookeeper/listener_test.go | 16 +- samples | 1 + test/integrate/dubbo/go-client/Dockerfile | 4 +- test/integrate/dubbo/go-client/go.mod | 10 +- test/integrate/dubbo/go-client/go.sum | 879 ++++++++++++++++++++- test/integrate/dubbo/go-server/Dockerfile | 6 +- test/integrate/dubbo/go-server/go.mod | 9 +- test/integrate/dubbo/go-server/go.sum | 879 ++++++++++++++++++++- tools/cli/.gitignore | 5 + tools/cli/README.md | 14 + tools/cli/README_CN.md | 11 + tools/cli/build.sh | 2 + tools/cli/client/client.go | 197 +++++ .../cli/common/protocol.go | 28 +- .../test_agent.go => tools/cli/common/tool.go | 31 +- tools/cli/example/README.md | 136 ++++ tools/cli/example/README_CN.md | 132 ++++ tools/cli/example/server/builddev.sh | 2 + tools/cli/example/server/config/log.yml | 28 + tools/cli/example/server/config/server.yml | 58 ++ tools/cli/example/server/go.mod | 8 + go.sum => tools/cli/example/server/go.sum | 658 +++++++-------- tools/cli/example/server/main.go | 77 ++ tools/cli/example/server/user.go | 80 ++ tools/cli/example/test.sh | 1 + tools/cli/example/user.json | 12 + tools/cli/example/userCall.json | 11 + tools/cli/go.mod | 12 + tools/cli/go.sum | 482 +++++++++++ tools/cli/json_register/json_register.go | 66 ++ tools/cli/main.go | 78 ++ tools/cli/protocol/dubbo/codec.go | 125 +++ tools/cli/protocol/dubbo/dubbo_protocol.go | 112 +++ .../cli/protocol/protocol.go | 29 +- tools/cli/test.sh | 1 + tools/cli/user.json | 12 + tools/cli/userCall.json | 11 + 279 files changed, 8856 insertions(+), 3293 deletions(-) diff --cc go.sum index bc0b1ec8b,4e8d631cd..6cc9d713a --- a/go.sum +++ b/go.sum @@@ -132,6 -129,7 +129,8 @@@ github.com/cockroachdb/datadriven v0.0. github.com/codahale/hdrhistogram v0.0.0-20161010025455-3a0bb77429bd/go.mod h1:sE/e/2PUdi/liOCUjSTXgM1o87ZssimdTWN964YiIeI= github.com/coredns/coredns v1.1.2 h1:bAFHrSsBeTeRG5W3Nf2su3lUGw7Npw2UKeCJm/3A638= github.com/coredns/coredns v1.1.2/go.mod h1:zASH/MVDgR6XZTbxvOnsZfffS+31vg6Ackf/wo1+AM0= ++github.com/coreos/bbolt v1.3.3 h1:n6AiVyVRKQFNb6mJlwESEvvLoDyiTzXX7ORAUlkeBdY= + github.com/coreos/bbolt v1.3.3/go.mod h1:iRUV2dpdMOn7Bo10OQBFzIJO9kkE559Wcmn+qkEiiKk= github.com/coreos/etcd v3.3.10+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE= github.com/coreos/etcd v3.3.13+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE= github.com/coreos/etcd v3.3.25+incompatible h1:0GQEw6h3YnuOVdtwygkIfJ+Omx0tZ8/QkVyXI4LkbeY=
