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 2020/11/24 06:28:02 UTC
[dubbo-go] branch master updated (f94fb7b -> 98977d0)
This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from f94fb7b Merge branch 'develop'
add 55d69fe Fix: fix heartbeat for client
add a735486 Merge pull request #877 from fangyincheng/fix-heartbeat
add cfc6ef7 feat: upgrade url
add 03f164a feat: update
add e9160e3 feat: update
add 603d829 feat: fix protocol need a new url
add 3f246d6 feat: update
add b8e2653 feat: update
add d5d3344 feat: fix URLEqual with *URL
add 616526d Merge branch 'hotfix/fixGopsutil' into develop-georgehao
add 10f85c0 Merge branch 'develop' of github.com:georgehao/dubbo-go into develop
add 600e030 feat: update
add 4cc7c51 Merge pull request #876 from georgehao/develop
add dead67f Doc: logo pr
add af71ce5 Merge pull request #886 from zfkun/develop
add 7b64ece Merge pull request #1 from apache/develop
add e0ce87a www.zto.com
add 2c1dc13 Merge pull request #890 from yeabow/develop
new 98977d0 Merge branch '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:
README.md | 10 ++
README_CN.md | 10 ++
cluster/cluster_impl/base_cluster_invoker.go | 2 +-
cluster/cluster_impl/failover_cluster_test.go | 6 +-
cluster/directory/base_directory.go | 4 +-
cluster/directory/base_directory_test.go | 25 ++-
cluster/directory/static_directory.go | 8 +-
cluster/loadbalance/consistent_hash_test.go | 6 +-
cluster/router/chain/chain.go | 6 +-
cluster/router/chain/chain_test.go | 29 ++--
cluster/router/condition/app_router_test.go | 8 +-
cluster/router/condition/factory_test.go | 64 ++++----
cluster/router/condition/file.go | 6 +-
cluster/router/condition/listenable_router.go | 4 +-
cluster/router/condition/router.go | 6 +-
cluster/router/condition/router_rule_test.go | 2 +-
cluster/router/condition/router_test.go | 8 +-
.../healthcheck/default_health_check_test.go | 20 +--
cluster/router/healthcheck/factory_test.go | 6 +-
cluster/router/healthcheck/health_check_route.go | 4 +-
.../router/healthcheck/health_check_route_test.go | 22 +--
cluster/router/router.go | 2 +-
cluster/router/tag/factory_test.go | 2 +-
cluster/router/tag/file.go | 7 +-
cluster/router/tag/tag_router.go | 4 +-
cluster/router/tag/tag_router_test.go | 36 ++---
common/node.go | 2 +-
common/proxy/proxy_factory.go | 2 +-
common/proxy/proxy_factory/default.go | 5 +-
common/proxy/proxy_factory/default_test.go | 6 +-
common/proxy/proxy_test.go | 4 +-
common/url.go | 177 ++++++++++++---------
common/url_test.go | 2 +-
config/config_center_config.go | 8 +-
config/config_loader.go | 11 +-
config/config_loader_test.go | 81 ++++------
config/instance/metadata_report.go | 8 +-
config/instance/metadata_report_test.go | 4 +-
config/metadata_report_config.go | 6 +-
config/reference_config.go | 8 +-
config/reference_config_test.go | 6 +-
config/registry_config.go | 4 +-
config/remote_config.go | 4 +-
config/service_config.go | 7 +-
config_center/apollo/impl.go | 12 +-
config_center/apollo/impl_test.go | 2 +-
config_center/configurator/override_test.go | 16 +-
config_center/dynamic_configuration.go | 2 +-
config_center/file/impl.go | 37 ++---
config_center/file/impl_test.go | 2 +-
config_center/nacos/client.go | 6 +-
config_center/nacos/client_test.go | 6 +-
config_center/nacos/impl.go | 4 +-
config_center/nacos/impl_test.go | 4 +-
config_center/parser/configuration_parser.go | 6 +-
config_center/zookeeper/impl.go | 4 +-
config_center/zookeeper/impl_test.go | 2 +-
filter/filter_impl/auth/consumer_sign.go | 4 +-
.../filter_impl/auth/default_authenticator_test.go | 12 +-
filter/filter_impl/auth/provider_auth.go | 4 +-
filter/filter_impl/auth/provider_auth_test.go | 2 +-
filter/filter_impl/echo_filter_test.go | 4 +-
filter/filter_impl/execute_limit_filter_test.go | 6 +-
.../filter_impl/graceful_shutdown_filter_test.go | 4 +-
filter/filter_impl/hystrix_filter_test.go | 27 +++-
filter/filter_impl/sentinel_filter.go | 2 +-
filter/filter_impl/token_filter_test.go | 8 +-
.../filter_impl/tps/tps_limiter_method_service.go | 4 +-
.../tps/tps_limiter_method_service_test.go | 8 +-
filter/filter_impl/tps/tps_limiter_mock.go | 2 +-
filter/filter_impl/tps_limit_filter_test.go | 8 +-
filter/handler/rejected_execution_handler_mock.go | 2 +-
.../handler/rejected_execution_handler_only_log.go | 2 +-
.../rejected_execution_handler_only_log_test.go | 2 +-
filter/rejected_execution_handler.go | 2 +-
filter/tps_limiter.go | 2 +-
metadata/definition/definition.go | 2 +-
metadata/identifier/service_metadata_identifier.go | 2 +-
metadata/report/consul/report.go | 2 +-
metadata/report/consul/report_test.go | 8 +-
metadata/report/delegate/delegate_report.go | 10 +-
metadata/report/etcd/report.go | 2 +-
metadata/report/etcd/report_test.go | 4 +-
metadata/report/nacos/report.go | 2 +-
metadata/report/nacos/report_test.go | 2 +-
metadata/report/report.go | 2 +-
metadata/report/zookeeper/report.go | 2 +-
metadata/report/zookeeper/report_test.go | 8 +-
.../service/exporter/configurable/exporter_test.go | 4 +-
.../inmemory/metadata_service_proxy_factory.go | 2 +-
.../metadata_service_proxy_factory_test.go | 6 +-
metadata/service/inmemory/service.go | 64 +++-----
metadata/service/inmemory/service_proxy.go | 14 +-
metadata/service/inmemory/service_proxy_test.go | 10 +-
metadata/service/remote/service.go | 12 +-
metadata/service/remote/service_proxy.go | 16 +-
metadata/service/remote/service_proxy_test.go | 14 +-
metadata/service/remote/service_test.go | 6 +-
metadata/service/service.go | 14 +-
metrics/prometheus/reporter.go | 4 +-
protocol/dubbo/dubbo_invoker.go | 2 +-
protocol/dubbo/dubbo_invoker_test.go | 2 +-
protocol/dubbo/dubbo_protocol.go | 6 +-
protocol/dubbo/hessian2/hessian_dubbo_test.go | 2 +-
protocol/grpc/client.go | 4 +-
protocol/grpc/grpc_invoker.go | 4 +-
protocol/grpc/grpc_protocol.go | 4 +-
protocol/grpc/server.go | 2 +-
protocol/invoker.go | 6 +-
protocol/jsonrpc/http.go | 4 +-
protocol/jsonrpc/jsonrpc_invoker.go | 2 +-
protocol/jsonrpc/jsonrpc_protocol.go | 4 +-
protocol/jsonrpc/server.go | 2 +-
protocol/mock/mock_invoker.go | 4 +-
protocol/protocol.go | 4 +-
protocol/protocolwrapper/mock_protocol_filter.go | 2 +-
.../protocolwrapper/protocol_filter_wrapper.go | 4 +-
.../protocol_filter_wrapper_test.go | 4 +-
protocol/rest/rest_invoker.go | 2 +-
protocol/rest/rest_protocol.go | 8 +-
protocol/rest/server/rest_server.go | 2 +-
.../rest/server/server_impl/go_restful_server.go | 2 +-
protocol/rpc_status.go | 8 +-
protocol/rpc_status_test.go | 4 +-
registry/base_registry.go | 30 ++--
registry/consul/listener.go | 14 +-
registry/consul/registry.go | 20 +--
registry/consul/service_discovery_test.go | 11 +-
registry/consul/utils.go | 12 +-
registry/consul/utils_test.go | 12 +-
registry/directory/directory.go | 10 +-
registry/directory/directory_test.go | 18 +--
registry/etcdv3/listener.go | 4 +-
registry/etcdv3/listener_test.go | 2 +-
registry/etcdv3/registry_test.go | 6 +-
registry/event.go | 2 +-
.../metadata_service_url_params_customizer_test.go | 22 +--
registry/file/service_discovery.go | 2 +-
registry/kubernetes/listener.go | 4 +-
registry/kubernetes/listener_test.go | 4 +-
registry/kubernetes/registry_test.go | 8 +-
registry/mock_registry.go | 8 +-
registry/nacos/listener.go | 14 +-
registry/nacos/registry.go | 31 ++--
registry/nacos/registry_test.go | 18 +--
registry/protocol/protocol.go | 30 ++--
registry/protocol/protocol_test.go | 21 +--
registry/registry.go | 4 +-
.../random/random_service_instance_selector.go | 2 +-
.../random_service_instance_selector_test.go | 2 +-
.../instance/service_instance_selector.go | 2 +-
.../servicediscovery/service_discovery_registry.go | 112 ++++++-------
.../service_discovery_registry_test.go | 58 +++----
.../rest/rest_subscribed_urls_synthesizer.go | 6 +-
.../rest/rest_subscribed_urls_synthesizer_test.go | 6 +-
.../synthesizer/subscribed_urls_synthesizer.go | 2 +-
registry/zookeeper/listener.go | 2 +-
registry/zookeeper/listener_test.go | 2 +-
registry/zookeeper/registry_test.go | 24 +--
registry/zookeeper/service_discovery.go | 4 +-
remoting/etcdv3/listener.go | 2 -
remoting/exchange_client.go | 14 +-
remoting/exchange_server.go | 4 +-
remoting/getty/dubbo_codec_for_test.go | 18 +--
remoting/getty/getty_client.go | 2 +-
remoting/getty/getty_client_test.go | 10 +-
remoting/getty/getty_server.go | 2 +-
remoting/getty/listener.go | 5 +-
remoting/kubernetes/client.go | 2 +-
remoting/kubernetes/facade_test.go | 6 +-
remoting/zookeeper/facade.go | 2 +-
remoting/zookeeper/facade_test.go | 6 +-
172 files changed, 876 insertions(+), 886 deletions(-)
[dubbo-go] 01/01: Merge branch 'develop'
Posted by al...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
commit 98977d0aa2a45550f0828a4e4b59aec0873e8fd0
Merge: f94fb7b 2c1dc13
Author: AlexStocks <al...@foxmail.com>
AuthorDate: Tue Nov 24 14:27:47 2020 +0800
Merge branch 'develop'
README.md | 10 ++
README_CN.md | 10 ++
cluster/cluster_impl/base_cluster_invoker.go | 2 +-
cluster/cluster_impl/failover_cluster_test.go | 6 +-
cluster/directory/base_directory.go | 4 +-
cluster/directory/base_directory_test.go | 25 ++-
cluster/directory/static_directory.go | 8 +-
cluster/loadbalance/consistent_hash_test.go | 6 +-
cluster/router/chain/chain.go | 6 +-
cluster/router/chain/chain_test.go | 29 ++--
cluster/router/condition/app_router_test.go | 8 +-
cluster/router/condition/factory_test.go | 64 ++++----
cluster/router/condition/file.go | 6 +-
cluster/router/condition/listenable_router.go | 4 +-
cluster/router/condition/router.go | 6 +-
cluster/router/condition/router_rule_test.go | 2 +-
cluster/router/condition/router_test.go | 8 +-
.../healthcheck/default_health_check_test.go | 20 +--
cluster/router/healthcheck/factory_test.go | 6 +-
cluster/router/healthcheck/health_check_route.go | 4 +-
.../router/healthcheck/health_check_route_test.go | 22 +--
cluster/router/router.go | 2 +-
cluster/router/tag/factory_test.go | 2 +-
cluster/router/tag/file.go | 7 +-
cluster/router/tag/tag_router.go | 4 +-
cluster/router/tag/tag_router_test.go | 36 ++---
common/node.go | 2 +-
common/proxy/proxy_factory.go | 2 +-
common/proxy/proxy_factory/default.go | 5 +-
common/proxy/proxy_factory/default_test.go | 6 +-
common/proxy/proxy_test.go | 4 +-
common/url.go | 177 ++++++++++++---------
common/url_test.go | 2 +-
config/config_center_config.go | 8 +-
config/config_loader.go | 11 +-
config/config_loader_test.go | 81 ++++------
config/instance/metadata_report.go | 8 +-
config/instance/metadata_report_test.go | 4 +-
config/metadata_report_config.go | 6 +-
config/reference_config.go | 8 +-
config/reference_config_test.go | 6 +-
config/registry_config.go | 4 +-
config/remote_config.go | 4 +-
config/service_config.go | 7 +-
config_center/apollo/impl.go | 12 +-
config_center/apollo/impl_test.go | 2 +-
config_center/configurator/override_test.go | 16 +-
config_center/dynamic_configuration.go | 2 +-
config_center/file/impl.go | 37 ++---
config_center/file/impl_test.go | 2 +-
config_center/nacos/client.go | 6 +-
config_center/nacos/client_test.go | 6 +-
config_center/nacos/impl.go | 4 +-
config_center/nacos/impl_test.go | 4 +-
config_center/parser/configuration_parser.go | 6 +-
config_center/zookeeper/impl.go | 4 +-
config_center/zookeeper/impl_test.go | 2 +-
filter/filter_impl/auth/consumer_sign.go | 4 +-
.../filter_impl/auth/default_authenticator_test.go | 12 +-
filter/filter_impl/auth/provider_auth.go | 4 +-
filter/filter_impl/auth/provider_auth_test.go | 2 +-
filter/filter_impl/echo_filter_test.go | 4 +-
filter/filter_impl/execute_limit_filter_test.go | 6 +-
.../filter_impl/graceful_shutdown_filter_test.go | 4 +-
filter/filter_impl/hystrix_filter_test.go | 27 +++-
filter/filter_impl/sentinel_filter.go | 2 +-
filter/filter_impl/token_filter_test.go | 8 +-
.../filter_impl/tps/tps_limiter_method_service.go | 4 +-
.../tps/tps_limiter_method_service_test.go | 8 +-
filter/filter_impl/tps/tps_limiter_mock.go | 2 +-
filter/filter_impl/tps_limit_filter_test.go | 8 +-
filter/handler/rejected_execution_handler_mock.go | 2 +-
.../handler/rejected_execution_handler_only_log.go | 2 +-
.../rejected_execution_handler_only_log_test.go | 2 +-
filter/rejected_execution_handler.go | 2 +-
filter/tps_limiter.go | 2 +-
metadata/definition/definition.go | 2 +-
metadata/identifier/service_metadata_identifier.go | 2 +-
metadata/report/consul/report.go | 2 +-
metadata/report/consul/report_test.go | 8 +-
metadata/report/delegate/delegate_report.go | 10 +-
metadata/report/etcd/report.go | 2 +-
metadata/report/etcd/report_test.go | 4 +-
metadata/report/nacos/report.go | 2 +-
metadata/report/nacos/report_test.go | 2 +-
metadata/report/report.go | 2 +-
metadata/report/zookeeper/report.go | 2 +-
metadata/report/zookeeper/report_test.go | 8 +-
.../service/exporter/configurable/exporter_test.go | 4 +-
.../inmemory/metadata_service_proxy_factory.go | 2 +-
.../metadata_service_proxy_factory_test.go | 6 +-
metadata/service/inmemory/service.go | 64 +++-----
metadata/service/inmemory/service_proxy.go | 14 +-
metadata/service/inmemory/service_proxy_test.go | 10 +-
metadata/service/remote/service.go | 12 +-
metadata/service/remote/service_proxy.go | 16 +-
metadata/service/remote/service_proxy_test.go | 14 +-
metadata/service/remote/service_test.go | 6 +-
metadata/service/service.go | 14 +-
metrics/prometheus/reporter.go | 4 +-
protocol/dubbo/dubbo_invoker.go | 2 +-
protocol/dubbo/dubbo_invoker_test.go | 2 +-
protocol/dubbo/dubbo_protocol.go | 6 +-
protocol/dubbo/hessian2/hessian_dubbo_test.go | 2 +-
protocol/grpc/client.go | 4 +-
protocol/grpc/grpc_invoker.go | 4 +-
protocol/grpc/grpc_protocol.go | 4 +-
protocol/grpc/server.go | 2 +-
protocol/invoker.go | 6 +-
protocol/jsonrpc/http.go | 4 +-
protocol/jsonrpc/jsonrpc_invoker.go | 2 +-
protocol/jsonrpc/jsonrpc_protocol.go | 4 +-
protocol/jsonrpc/server.go | 2 +-
protocol/mock/mock_invoker.go | 4 +-
protocol/protocol.go | 4 +-
protocol/protocolwrapper/mock_protocol_filter.go | 2 +-
.../protocolwrapper/protocol_filter_wrapper.go | 4 +-
.../protocol_filter_wrapper_test.go | 4 +-
protocol/rest/rest_invoker.go | 2 +-
protocol/rest/rest_protocol.go | 8 +-
protocol/rest/server/rest_server.go | 2 +-
.../rest/server/server_impl/go_restful_server.go | 2 +-
protocol/rpc_status.go | 8 +-
protocol/rpc_status_test.go | 4 +-
registry/base_registry.go | 30 ++--
registry/consul/listener.go | 14 +-
registry/consul/registry.go | 20 +--
registry/consul/service_discovery_test.go | 11 +-
registry/consul/utils.go | 12 +-
registry/consul/utils_test.go | 12 +-
registry/directory/directory.go | 10 +-
registry/directory/directory_test.go | 18 +--
registry/etcdv3/listener.go | 4 +-
registry/etcdv3/listener_test.go | 2 +-
registry/etcdv3/registry_test.go | 6 +-
registry/event.go | 2 +-
.../metadata_service_url_params_customizer_test.go | 22 +--
registry/file/service_discovery.go | 2 +-
registry/kubernetes/listener.go | 4 +-
registry/kubernetes/listener_test.go | 4 +-
registry/kubernetes/registry_test.go | 8 +-
registry/mock_registry.go | 8 +-
registry/nacos/listener.go | 14 +-
registry/nacos/registry.go | 31 ++--
registry/nacos/registry_test.go | 18 +--
registry/protocol/protocol.go | 30 ++--
registry/protocol/protocol_test.go | 21 +--
registry/registry.go | 4 +-
.../random/random_service_instance_selector.go | 2 +-
.../random_service_instance_selector_test.go | 2 +-
.../instance/service_instance_selector.go | 2 +-
.../servicediscovery/service_discovery_registry.go | 112 ++++++-------
.../service_discovery_registry_test.go | 58 +++----
.../rest/rest_subscribed_urls_synthesizer.go | 6 +-
.../rest/rest_subscribed_urls_synthesizer_test.go | 6 +-
.../synthesizer/subscribed_urls_synthesizer.go | 2 +-
registry/zookeeper/listener.go | 2 +-
registry/zookeeper/listener_test.go | 2 +-
registry/zookeeper/registry_test.go | 24 +--
registry/zookeeper/service_discovery.go | 4 +-
remoting/etcdv3/listener.go | 2 -
remoting/exchange_client.go | 14 +-
remoting/exchange_server.go | 4 +-
remoting/getty/dubbo_codec_for_test.go | 18 +--
remoting/getty/getty_client.go | 2 +-
remoting/getty/getty_client_test.go | 10 +-
remoting/getty/getty_server.go | 2 +-
remoting/getty/listener.go | 5 +-
remoting/kubernetes/client.go | 2 +-
remoting/kubernetes/facade_test.go | 6 +-
remoting/zookeeper/facade.go | 2 +-
remoting/zookeeper/facade_test.go | 6 +-
172 files changed, 876 insertions(+), 886 deletions(-)