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/01/25 10:58:28 UTC
[dubbo-go] branch master updated (8d34495 -> d7ff97b)
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 8d34495 Add: travis dingding
add 5d1797b supplement rpc stats
add df48230 fix unit test
add 5bc05b9 fix ci
add 436924f fix comment issue
add ae41f5a fix comment issue
add 3aa39fd fix some naming error
add f8d1ecd Merge pull request #328 from CodingSinger/tolerance
add 5212a3d GOLINT: add comment for exported (checked by golint)
add e2dc717 Add: dingding robot in travis yml
add f5c2390 Merge branch 'develop' of https://github.com/apache/dubbo-go into develop
add da6d29a Context support
add e945c66 format code
add a81c012 Fix review: context.TODO => context.Backgroud
add ab69968 Fix review: split imports
add 29c195d Fix Review
add 1fa4bf6 Merge pull request #330 from flycash/feature/context
add adf366a update license and notice
add bc23f7c Merge pull request #336 from zouyx/feature/UpdateLicense
add d63631b Add opentracing dependency
add a8e952e define TracingFilter
add e556b01 Doing tracing filter
add 833000b Doing tracing filter
add 5c78245 tested tracing filter
add 5216fb1 rearrnage imports
add e07ca04 Move context to the invocation
add 0c19b52 Using default context.Context.
add cc7fc72 Merge origin develop
add e071810 Pass Context from client
add 37d517e Merge context
add 70a7436 Merge develop
add c48b3cb JsonRPC tracing chain
add aec964d Split import
add 0196c0e Remove TODO
add d9075ad Merge pull request #335 from flycash/feature/Opentracing
add c07e4e3 Merge commit 'd9075ad' into feature/add_comment_for_exported_by_golint
add c8b6fdd Merge pull request #333 from weiwei-xiao/feature/add_comment_for_exported_by_golint
add c9ab3f2 Update Changes.md
add 0128e85 Merge pull request #338 from zouyx/feature/UpdateChanges
add 351e1ae Imp: reduce lock scope
add 93f865c Mod: gofmt
add 5dd99c6 Merge pull request #318 from divebomb/develop
new d7ff97b 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:
CHANGE.md | 38 ++++++
LICENSE | 13 ++
NOTICE | 2 +-
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 | 10 +-
cluster/cluster_impl/failsafe_cluster.go | 1 +
cluster/cluster_impl/failsafe_cluster_invoker.go | 7 +-
cluster/cluster_impl/failsafe_cluster_test.go | 4 +-
cluster/cluster_impl/forking_cluster.go | 1 +
cluster/cluster_impl/forking_cluster_invoker.go | 5 +-
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/base_directory.go | 8 ++
cluster/directory/static_directory.go | 1 +
cluster/loadbalance/consistent_hash.go | 6 +
cluster/loadbalance/least_active.go | 3 +-
cluster/loadbalance/random.go | 1 +
cluster/loadbalance/round_robin.go | 1 +
cluster/loadbalance/util.go | 1 +
cluster/router.go | 4 +
cluster/router/condition_router.go | 1 +
cluster/router/condition_router_test.go | 2 +-
cluster/router/router_factory.go | 4 +
common/config/environment.go | 11 ++
common/constant/key.go | 4 +
common/extension/cluster.go | 2 +
common/extension/config_center.go | 2 +
common/extension/config_center_factory.go | 2 +
common/extension/configurator.go | 7 +
common/extension/filter.go | 4 +
common/extension/graceful_shutdown.go | 1 +
common/extension/loadbalance.go | 2 +
common/extension/protocol.go | 2 +
common/extension/proxy_factory.go | 3 +
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 | 11 +-
common/proxy/proxy_factory.go | 2 +
common/proxy/proxy_factory/default.go | 13 +-
common/rpc_service.go | 16 +++
common/url.go | 40 ++++++
config/application_config.go | 8 ++
config/base_config.go | 2 +
config/config_center_config.go | 3 +
config/consumer_config.go | 6 +
config/generic_service.go | 3 +
config/graceful_shutdown.go | 2 +
config/graceful_shutdown_config.go | 4 +
config/graceful_shutdown_signal_darwin.go | 2 +
config/method_config.go | 3 +
config/mock_rpcservice.go | 4 +
config/protocol_config.go | 2 +
config/provider_config.go | 7 +
config/reference_config.go | 7 +
config/registry_config.go | 3 +
config/service.go | 3 +
config/service_config.go | 5 +
config_center/apollo/listener.go | 1 +
config_center/configuration_listener.go | 2 +
config_center/configurator.go | 1 +
config_center/configurator/mock.go | 1 +
config_center/dynamic_configuration.go | 5 +
config_center/dynamic_configuration_factory.go | 1 +
config_center/mock_dynamic_config.go | 14 ++
config_center/parser/configuration_parser.go | 5 +
config_center/zookeeper/listener.go | 8 +-
filter/filter.go | 7 +-
filter/filter_impl/access_log_filter.go | 11 +-
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 | 12 +-
filter/filter_impl/echo_filter_test.go | 7 +-
filter/filter_impl/execute_limit_filter.go | 13 +-
filter/filter_impl/execute_limit_filter_test.go | 7 +-
filter/filter_impl/generic_filter.go | 13 +-
filter/filter_impl/generic_service_filter.go | 13 +-
filter/filter_impl/generic_service_filter_test.go | 6 +-
filter/filter_impl/graceful_shutdown_filter.go | 7 +-
.../filter_impl/graceful_shutdown_filter_test.go | 5 +-
filter/filter_impl/hystrix_filter.go | 25 +++-
filter/filter_impl/hystrix_filter_test.go | 13 +-
filter/filter_impl/token_filter.go | 13 +-
filter/filter_impl/token_filter_test.go | 17 +--
.../tps/tps_limit_fix_window_strategy.go | 1 +
.../tps/tps_limit_sliding_window_strategy.go | 1 +
.../tps_limit_thread_safe_fix_window_strategy.go | 1 +
.../filter_impl/tps/tps_limiter_method_service.go | 2 +
filter/filter_impl/tps_limit_filter.go | 14 +-
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} | 52 +++----
.../handler/rejected_execution_handler_only_log.go | 2 +
filter/tps_limit_strategy.go | 1 +
go.mod | 1 +
go.sum | 25 ++++
protocol/dubbo/client.go | 19 ++-
protocol/dubbo/codec.go | 7 +
protocol/dubbo/config.go | 6 +
protocol/dubbo/dubbo_exporter.go | 3 +
protocol/dubbo/dubbo_invoker.go | 9 +-
protocol/dubbo/dubbo_invoker_test.go | 9 +-
protocol/dubbo/dubbo_protocol.go | 6 +
protocol/dubbo/listener.go | 26 +++-
protocol/dubbo/pool.go | 133 ++++++++++--------
protocol/dubbo/readwriter.go | 3 +
protocol/dubbo/server.go | 7 +
protocol/grpc/client.go | 2 +
protocol/grpc/common_test.go | 4 +-
protocol/grpc/grpc_exporter.go | 3 +
protocol/grpc/grpc_invoker.go | 9 +-
protocol/grpc/grpc_invoker_test.go | 2 +-
protocol/grpc/grpc_protocol.go | 6 +
protocol/grpc/internal/client.go | 2 +
protocol/grpc/internal/server.go | 2 +
.../protoc-gen-dubbo/examples/helloworld.pb.go | 4 +-
protocol/grpc/server.go | 5 +
protocol/invocation.go | 1 +
protocol/invocation/rpcinvocation.go | 31 ++++-
protocol/invoker.go | 14 +-
protocol/jsonrpc/http.go | 23 +++-
protocol/jsonrpc/http_test.go | 6 +
protocol/jsonrpc/json.go | 8 +-
protocol/jsonrpc/jsonrpc_exporter.go | 3 +
protocol/jsonrpc/jsonrpc_invoker.go | 9 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 2 +-
protocol/jsonrpc/jsonrpc_protocol.go | 6 +
protocol/jsonrpc/server.go | 17 ++-
protocol/mock/mock_invoker.go | 3 +-
protocol/protocol.go | 12 ++
protocol/protocolwrapper/mock_protocol_filter.go | 1 +
.../protocolwrapper/protocol_filter_wrapper.go | 16 ++-
.../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/directory/directory.go | 3 +
registry/etcdv3/listener.go | 2 +
registry/event.go | 1 +
registry/mock_registry.go | 12 ++
registry/nacos/listener.go | 1 +
registry/protocol/protocol.go | 6 +-
registry/registry.go | 2 +
registry/zookeeper/listener.go | 12 ++
registry/zookeeper/registry.go | 2 +
remoting/etcdv3/client.go | 22 +++
remoting/etcdv3/facade.go | 1 +
remoting/etcdv3/listener.go | 3 +
remoting/listener.go | 3 +
remoting/zookeeper/client.go | 22 +++
remoting/zookeeper/facade.go | 1 +
remoting/zookeeper/listener.go | 5 +
174 files changed, 1496 insertions(+), 274 deletions(-)
create mode 100644 filter/filter_impl/active_filter_test.go
create mode 100644 filter/filter_impl/tracing_filter.go
copy filter/filter_impl/{access_log_filter_test.go => tracing_filter_test.go} (53%)
create mode 100644 protocol/rpc_status_test.go
[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 d7ff97bad332cc9cc98a3d56b7906759d60d4dbd
Merge: 8d34495 5dd99c6
Author: AlexStocks <al...@foxmail.com>
AuthorDate: Sat Jan 25 18:58:01 2020 +0800
Merge branch 'develop'
CHANGE.md | 38 ++++++
LICENSE | 13 ++
NOTICE | 2 +-
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 | 10 +-
cluster/cluster_impl/failsafe_cluster.go | 1 +
cluster/cluster_impl/failsafe_cluster_invoker.go | 7 +-
cluster/cluster_impl/failsafe_cluster_test.go | 4 +-
cluster/cluster_impl/forking_cluster.go | 1 +
cluster/cluster_impl/forking_cluster_invoker.go | 5 +-
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/base_directory.go | 8 ++
cluster/directory/static_directory.go | 1 +
cluster/loadbalance/consistent_hash.go | 6 +
cluster/loadbalance/least_active.go | 3 +-
cluster/loadbalance/random.go | 1 +
cluster/loadbalance/round_robin.go | 1 +
cluster/loadbalance/util.go | 1 +
cluster/router.go | 4 +
cluster/router/condition_router.go | 1 +
cluster/router/condition_router_test.go | 2 +-
cluster/router/router_factory.go | 4 +
common/config/environment.go | 11 ++
common/constant/key.go | 4 +
common/extension/cluster.go | 2 +
common/extension/config_center.go | 2 +
common/extension/config_center_factory.go | 2 +
common/extension/configurator.go | 7 +
common/extension/filter.go | 4 +
common/extension/graceful_shutdown.go | 1 +
common/extension/loadbalance.go | 2 +
common/extension/protocol.go | 2 +
common/extension/proxy_factory.go | 3 +
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 | 11 +-
common/proxy/proxy_factory.go | 2 +
common/proxy/proxy_factory/default.go | 13 +-
common/rpc_service.go | 16 +++
common/url.go | 40 ++++++
config/application_config.go | 8 ++
config/base_config.go | 2 +
config/config_center_config.go | 3 +
config/consumer_config.go | 6 +
config/generic_service.go | 3 +
config/graceful_shutdown.go | 2 +
config/graceful_shutdown_config.go | 4 +
config/graceful_shutdown_signal_darwin.go | 2 +
config/method_config.go | 3 +
config/mock_rpcservice.go | 4 +
config/protocol_config.go | 2 +
config/provider_config.go | 7 +
config/reference_config.go | 7 +
config/registry_config.go | 3 +
config/service.go | 3 +
config/service_config.go | 5 +
config_center/apollo/listener.go | 1 +
config_center/configuration_listener.go | 2 +
config_center/configurator.go | 1 +
config_center/configurator/mock.go | 1 +
config_center/dynamic_configuration.go | 5 +
config_center/dynamic_configuration_factory.go | 1 +
config_center/mock_dynamic_config.go | 14 ++
config_center/parser/configuration_parser.go | 5 +
config_center/zookeeper/listener.go | 8 +-
filter/filter.go | 7 +-
filter/filter_impl/access_log_filter.go | 11 +-
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 | 12 +-
filter/filter_impl/echo_filter_test.go | 7 +-
filter/filter_impl/execute_limit_filter.go | 13 +-
filter/filter_impl/execute_limit_filter_test.go | 7 +-
filter/filter_impl/generic_filter.go | 13 +-
filter/filter_impl/generic_service_filter.go | 13 +-
filter/filter_impl/generic_service_filter_test.go | 6 +-
filter/filter_impl/graceful_shutdown_filter.go | 7 +-
.../filter_impl/graceful_shutdown_filter_test.go | 5 +-
filter/filter_impl/hystrix_filter.go | 25 +++-
filter/filter_impl/hystrix_filter_test.go | 13 +-
filter/filter_impl/token_filter.go | 13 +-
filter/filter_impl/token_filter_test.go | 17 +--
.../tps/tps_limit_fix_window_strategy.go | 1 +
.../tps/tps_limit_sliding_window_strategy.go | 1 +
.../tps_limit_thread_safe_fix_window_strategy.go | 1 +
.../filter_impl/tps/tps_limiter_method_service.go | 2 +
filter/filter_impl/tps_limit_filter.go | 14 +-
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} | 52 +++----
.../handler/rejected_execution_handler_only_log.go | 2 +
filter/tps_limit_strategy.go | 1 +
go.mod | 1 +
go.sum | 25 ++++
protocol/dubbo/client.go | 19 ++-
protocol/dubbo/codec.go | 7 +
protocol/dubbo/config.go | 6 +
protocol/dubbo/dubbo_exporter.go | 3 +
protocol/dubbo/dubbo_invoker.go | 9 +-
protocol/dubbo/dubbo_invoker_test.go | 9 +-
protocol/dubbo/dubbo_protocol.go | 6 +
protocol/dubbo/listener.go | 26 +++-
protocol/dubbo/pool.go | 133 ++++++++++--------
protocol/dubbo/readwriter.go | 3 +
protocol/dubbo/server.go | 7 +
protocol/grpc/client.go | 2 +
protocol/grpc/common_test.go | 4 +-
protocol/grpc/grpc_exporter.go | 3 +
protocol/grpc/grpc_invoker.go | 9 +-
protocol/grpc/grpc_invoker_test.go | 2 +-
protocol/grpc/grpc_protocol.go | 6 +
protocol/grpc/internal/client.go | 2 +
protocol/grpc/internal/server.go | 2 +
.../protoc-gen-dubbo/examples/helloworld.pb.go | 4 +-
protocol/grpc/server.go | 5 +
protocol/invocation.go | 1 +
protocol/invocation/rpcinvocation.go | 31 ++++-
protocol/invoker.go | 14 +-
protocol/jsonrpc/http.go | 23 +++-
protocol/jsonrpc/http_test.go | 6 +
protocol/jsonrpc/json.go | 8 +-
protocol/jsonrpc/jsonrpc_exporter.go | 3 +
protocol/jsonrpc/jsonrpc_invoker.go | 9 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 2 +-
protocol/jsonrpc/jsonrpc_protocol.go | 6 +
protocol/jsonrpc/server.go | 17 ++-
protocol/mock/mock_invoker.go | 3 +-
protocol/protocol.go | 12 ++
protocol/protocolwrapper/mock_protocol_filter.go | 1 +
.../protocolwrapper/protocol_filter_wrapper.go | 16 ++-
.../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/directory/directory.go | 3 +
registry/etcdv3/listener.go | 2 +
registry/event.go | 1 +
registry/mock_registry.go | 12 ++
registry/nacos/listener.go | 1 +
registry/protocol/protocol.go | 6 +-
registry/registry.go | 2 +
registry/zookeeper/listener.go | 12 ++
registry/zookeeper/registry.go | 2 +
remoting/etcdv3/client.go | 22 +++
remoting/etcdv3/facade.go | 1 +
remoting/etcdv3/listener.go | 3 +
remoting/listener.go | 3 +
remoting/zookeeper/client.go | 22 +++
remoting/zookeeper/facade.go | 1 +
remoting/zookeeper/listener.go | 5 +
174 files changed, 1496 insertions(+), 274 deletions(-)