You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by fl...@apache.org on 2020/02/02 04:15:55 UTC
[dubbo-go] 01/01: Merge pull request #347 from apache/develop
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a commit to branch feature/rest
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
commit e899345e6482dab1c46bfa20751e1a41b2c3f840
Merge: 932e149 c291d2c
Author: Ming Deng <mi...@gmail.com>
AuthorDate: Sun Feb 2 12:15:45 2020 +0800
Merge pull request #347 from apache/develop
Develop to feature/rest
.travis.yml | 3 +
CHANGE.md | 38 +++
LICENSE | 13 +
NOTICE | 2 +-
README.md | 7 +-
README_CN.md | 7 +-
cluster/cluster.go | 1 +
cluster/cluster_impl/available_cluster.go | 1 +
cluster/cluster_impl/available_cluster_invoker.go | 6 +-
.../cluster_impl/available_cluster_invoker_test.go | 4 +-
cluster/cluster_impl/broadcast_cluster.go | 1 +
cluster/cluster_impl/broadcast_cluster_invoker.go | 7 +-
.../cluster_impl/broadcast_cluster_invoker_test.go | 4 +-
cluster/cluster_impl/failback_cluster.go | 1 +
cluster/cluster_impl/failback_cluster_invoker.go | 11 +-
cluster/cluster_impl/failback_cluster_test.go | 12 +-
cluster/cluster_impl/failfast_cluster.go | 1 +
cluster/cluster_impl/failfast_cluster_invoker.go | 7 +-
cluster/cluster_impl/failfast_cluster_test.go | 4 +-
cluster/cluster_impl/failover_cluster.go | 1 +
cluster/cluster_impl/failover_cluster_invoker.go | 5 +-
cluster/cluster_impl/failover_cluster_test.go | 16 +-
cluster/cluster_impl/failsafe_cluster.go | 1 +
cluster/cluster_impl/failsafe_cluster_invoker.go | 7 +-
cluster/cluster_impl/failsafe_cluster_test.go | 12 +-
cluster/cluster_impl/forking_cluster.go | 1 +
cluster/cluster_impl/forking_cluster_invoker.go | 17 +-
cluster/cluster_impl/forking_cluster_test.go | 6 +-
cluster/cluster_impl/mock_cluster.go | 1 +
cluster/cluster_impl/registry_aware_cluster.go | 1 +
.../cluster_impl/registry_aware_cluster_invoker.go | 9 +-
.../cluster_impl/registry_aware_cluster_test.go | 8 +-
cluster/directory.go | 3 +-
cluster/directory/base_directory.go | 8 +
cluster/directory/static_directory.go | 1 +
cluster/loadbalance.go | 3 +-
cluster/loadbalance/consistent_hash.go | 13 +-
cluster/loadbalance/least_active.go | 16 +-
cluster/loadbalance/random.go | 1 +
cluster/loadbalance/round_robin.go | 10 +-
cluster/loadbalance/util.go | 1 +
cluster/router.go | 4 +
cluster/router/condition_router.go | 21 +-
cluster/router/condition_router_test.go | 10 +-
cluster/router/router_factory.go | 4 +
common/config/environment.go | 20 +-
common/constant/env.go | 5 +-
common/constant/key.go | 4 +
common/constant/version.go | 7 +-
common/extension/cluster.go | 2 +
common/extension/config_center.go | 2 +
common/extension/config_center_factory.go | 2 +
common/extension/configurator.go | 12 +-
common/extension/filter.go | 4 +
common/extension/graceful_shutdown.go | 2 +
common/extension/loadbalance.go | 2 +
common/extension/protocol.go | 2 +
common/extension/proxy_factory.go | 11 +-
common/extension/registry.go | 2 +
common/extension/router_factory.go | 2 +
common/extension/tps_limit.go | 4 +
common/logger/logger.go | 9 +
common/logger/logging.go | 15 +
common/node.go | 1 +
common/proxy/proxy.go | 41 ++-
common/proxy/proxy_factory.go | 2 +
common/proxy/proxy_factory/default.go | 13 +-
common/rpc_service.go | 39 ++-
common/rpc_service_test.go | 5 +-
common/url.go | 50 ++-
config/application_config.go | 8 +
config/base_config.go | 10 +-
config/config_center_config.go | 5 +-
config/config_loader.go | 8 +-
config/consumer_config.go | 7 +
config/generic_service.go | 4 +
config/graceful_shutdown.go | 2 +
config/graceful_shutdown_config.go | 4 +
config/graceful_shutdown_signal_darwin.go | 14 +-
config/graceful_shutdown_signal_linux.go | 14 +-
config/graceful_shutdown_signal_windows.go | 12 +-
config/method_config.go | 10 +-
config/mock_rpcservice.go | 4 +
config/protocol_config.go | 3 +
config/provider_config.go | 8 +
config/reference_config.go | 115 ++++---
config/reference_config_test.go | 18 +-
config/registry_config.go | 14 +-
config/service.go | 7 +-
config/service_config.go | 98 +++---
config_center/apollo/factory.go | 6 +-
config_center/apollo/impl.go | 18 +-
config_center/apollo/impl_test.go | 2 +-
config_center/apollo/listener.go | 28 +-
config_center/configuration_listener.go | 2 +
config_center/configurator.go | 1 +
config_center/configurator/mock.go | 4 +
config_center/configurator/override.go | 1 +
config_center/configurator/override_test.go | 4 +
config_center/dynamic_configuration.go | 13 +-
config_center/dynamic_configuration_factory.go | 1 +
config_center/mock_dynamic_config.go | 28 +-
config_center/parser/configuration_parser.go | 15 +-
config_center/zookeeper/impl.go | 61 ++--
config_center/zookeeper/listener.go | 8 +-
contributing.md | 12 +-
filter/filter.go | 8 +-
filter/filter_impl/access_log_filter.go | 30 +-
filter/filter_impl/access_log_filter_test.go | 6 +-
filter/filter_impl/active_filter.go | 33 +-
filter/filter_impl/active_filter_test.go | 66 ++++
filter/filter_impl/echo_filter.go | 17 +-
filter/filter_impl/echo_filter_test.go | 7 +-
filter/filter_impl/execute_limit_filter.go | 34 +-
filter/filter_impl/execute_limit_filter_test.go | 7 +-
filter/filter_impl/generic_filter.go | 18 +-
filter/filter_impl/generic_filter_test.go | 1 +
filter/filter_impl/generic_service_filter.go | 17 +-
filter/filter_impl/generic_service_filter_test.go | 15 +-
filter/filter_impl/graceful_shutdown_filter.go | 7 +-
.../filter_impl/graceful_shutdown_filter_test.go | 5 +-
filter/filter_impl/hystrix_filter.go | 31 +-
filter/filter_impl/hystrix_filter_test.go | 17 +-
filter/filter_impl/token_filter.go | 14 +-
filter/filter_impl/token_filter_test.go | 17 +-
.../tps/tps_limit_fix_window_strategy.go | 3 +
.../tps/tps_limit_sliding_window_strategy.go | 2 +
.../tps_limit_thread_safe_fix_window_strategy.go | 2 +
.../filter_impl/tps/tps_limiter_method_service.go | 8 +-
filter/filter_impl/tps_limit_filter.go | 17 +-
filter/filter_impl/tps_limit_filter_test.go | 17 +-
filter/filter_impl/tracing_filter.go | 107 +++++++
...s_log_filter_test.go => tracing_filter_test.go} | 51 +--
.../handler/rejected_execution_handler_only_log.go | 12 +-
filter/rejected_execution_handler.go | 2 +
filter/tps_limit_strategy.go | 2 +
filter/tps_limiter.go | 1 +
go.mod | 2 +
go.sum | 25 ++
protocol/dubbo/client.go | 23 +-
protocol/dubbo/codec.go | 19 +-
protocol/dubbo/config.go | 12 +-
protocol/dubbo/dubbo_exporter.go | 3 +
protocol/dubbo/dubbo_invoker.go | 34 +-
protocol/dubbo/dubbo_invoker_test.go | 19 +-
protocol/dubbo/dubbo_protocol.go | 8 +
protocol/dubbo/listener.go | 58 +++-
protocol/dubbo/listener_test.go | 58 ++++
protocol/dubbo/pool.go | 133 ++++----
protocol/dubbo/readwriter.go | 3 +
protocol/dubbo/server.go | 7 +
.../apollo/factory.go => protocol/grpc/client.go | 50 ++-
protocol/grpc/client_test.go | 54 ++++
protocol/grpc/common_test.go | 114 +++++++
.../factory.go => protocol/grpc/grpc_exporter.go | 38 ++-
protocol/grpc/grpc_invoker.go | 104 +++++++
protocol/grpc/grpc_invoker_test.go | 56 ++++
protocol/grpc/grpc_protocol.go | 113 +++++++
protocol/grpc/grpc_protocol_test.go | 85 +++++
.../grpc/internal/client.go | 32 +-
.../grpc/internal/doc.go | 25 +-
protocol/grpc/internal/helloworld.pb.go | 227 ++++++++++++++
protocol/grpc/internal/server.go | 66 ++++
protocol/grpc/protoc-gen-dubbo/examples/Makefile | 19 ++
.../protoc-gen-dubbo/examples/helloworld.pb.go | 301 ++++++++++++++++++
.../protoc-gen-dubbo/examples/helloworld.proto | 37 +++
protocol/grpc/protoc-gen-dubbo/main.go | 74 +++++
.../grpc/protoc-gen-dubbo/plugin/dubbo/doc.go | 25 +-
.../grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go | 346 +++++++++++++++++++++
protocol/grpc/server.go | 106 +++++++
protocol/invocation.go | 2 +
protocol/invocation/rpcinvocation.go | 64 +++-
protocol/invoker.go | 16 +-
protocol/jsonrpc/http.go | 24 +-
protocol/jsonrpc/http_test.go | 6 +
protocol/jsonrpc/json.go | 14 +-
protocol/jsonrpc/jsonrpc_exporter.go | 3 +
protocol/jsonrpc/jsonrpc_invoker.go | 9 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 2 +-
protocol/jsonrpc/jsonrpc_protocol.go | 12 +-
protocol/jsonrpc/server.go | 30 +-
protocol/mock/mock_invoker.go | 3 +-
protocol/protocol.go | 14 +
protocol/protocolwrapper/mock_protocol_filter.go | 1 +
.../protocolwrapper/protocol_filter_wrapper.go | 22 +-
.../protocol_filter_wrapper_test.go | 7 +-
protocol/result.go | 9 +
protocol/rpc_status.go | 118 ++++++-
protocol/rpc_status_test.go | 152 +++++++++
registry/base_configuration_listener.go | 8 +
registry/consul/registry.go | 10 +-
registry/directory/directory.go | 14 +-
registry/etcdv3/listener.go | 2 +
registry/etcdv3/registry.go | 31 +-
registry/etcdv3/registry_test.go | 10 +-
registry/event.go | 1 +
registry/mock_registry.go | 21 +-
registry/nacos/listener.go | 1 +
registry/nacos/registry.go | 9 +-
registry/protocol/protocol.go | 6 +-
registry/registry.go | 6 +-
registry/zookeeper/listener.go | 12 +
registry/zookeeper/registry.go | 11 +-
remoting/etcdv3/client.go | 32 +-
remoting/etcdv3/facade.go | 1 +
remoting/etcdv3/listener.go | 9 +-
remoting/listener.go | 6 +
remoting/zookeeper/client.go | 32 +-
remoting/zookeeper/client_test.go | 9 +
remoting/zookeeper/facade.go | 1 +
remoting/zookeeper/listener.go | 64 +---
remoting/zookeeper/listener_test.go | 3 +-
212 files changed, 4011 insertions(+), 783 deletions(-)