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/01/13 08:37:03 UTC
[dubbo-go] branch feature/metrics updated (93e356f -> ba71941)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/metrics
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 93e356f Merge pull request #319 from flycash/feature/Reservoir
new 62e7207 revert filter dir
new c95940a modify filter dir
new a92d606 modify filter dir & version
new 70aed98 delete mock json
new e7aa7e5 delete mock json in apollo test case
new e8cc8c7 Merge pull request #304 from zouyx/feature/deleteMockJson
new 8c24e5e upgrade gost v1.5
new 8dd1b0d Merge pull request #296 from micln/upgrade
new 9ef93b8 Revert "upgrade hessian2 & gost v1.5"
new ab78c63 Merge pull request #299 from apache/revert-296-upgrade
new ad79b88 gost 1.5.1
new b0dbcb8 upgrade hessian2
new d451c2d Merge remote-tracking branch 'upstream/develop' into dev
new 03c6a4a Merge pull request #307 from micln/dev
new 92af46e Merge remote-tracking branch 'apache/develop' into develop
new 47066c2 Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
new 5f5cfb7 Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
new ebb35e8 Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
new 411435c Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
new 9723e7b add code for request_timeout
new 400c388 add code
new 8517ede Merge branch 'apache-develop' into develop_req_timeout_config
new 625c571 merge code
new 9bdc231 fix bug
new 52fbe96 fix bug
new 311135a fix bug
new 4226997 modify the format of the incoming package
new b2b66c3 remove one const
new bfa60ea Merge pull request #284 from pantianying/develop_req_timeout_config
new 3110d49 add GenericServiceFilter in README.md
new 2c86ec0 Merge pull request #310 from Patrick0308/modify-readme
new e31ffd6 Merge remote-tracking branch 'apache/develop' into develop
new 1980135 fix ut
new 1d7e21f Mod: modify date
new 20ca967 Fix: ut
new 4bd2851 Merge pull request #306 from fangyincheng/develop
new d01b5ee When protocol config don't have right config, remind user to check warning.
new a109609 Merge pull request #314 from Patrick0308/add_protocol_warning
new 5117a84 Imp: check consumerConfig.RequestTimeout by getty.MaxWheelTimeSpan
new dff4870 Mod: upgrade gost/getty version
new f691f24 Mod: change gost/getty version in go.sum
new 5ff8d34 Imp: check sessin timeout; change default client conf params
new dab215a Fmt: protocol/dubbo/config
new 932e149 Mod: upgrade hessian2
new dffc784 Merge develop and resolve conflict
new 75e9bff Add Enables into MetricConfig
new 0884c96 Mod: Refactor the MetricFilter so that we can specify the metrics which we want to be collected
new 7df1037 Add method GetCompasses and GetFastCompasses
new ba71941 Merge pull request #320 from flycash/feature/MetricsFilter
The 1293 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:
.gitignore | 1 +
README.md | 1 +
cluster/router/condition_router.go | 2 +-
common/constant/version.go | 4 +-
common/url.go | 30 +++----
common/url_test.go | 4 +-
config/consumer_config.go | 5 ++
config/graceful_shutdown.go | 2 +-
config/method_config.go | 1 +
config/metric_config.go | 51 ++++++++++++
config/metric_config_test.go | 11 +++
config/reference_config.go | 49 +++++++-----
config/service_config.go | 8 +-
config/service_config_test.go | 24 ++++++
config/testdata/consumer_config.yml | 23 +++++-
config_center/apollo/impl_test.go | 13 +++
config_center/configurator/override.go | 2 +-
.../{filter => filter_impl}/access_log_filter.go | 2 +-
.../access_log_filter_test.go | 2 +-
filter/{filter => filter_impl}/active_filter.go | 2 +-
filter/{filter => filter_impl}/echo_filter.go | 2 +-
filter/{filter => filter_impl}/echo_filter_test.go | 2 +-
.../execute_limit_filter.go | 4 +-
.../execute_limit_filter_test.go | 2 +-
filter/{filter => filter_impl}/generic_filter.go | 2 +-
.../{filter => filter_impl}/generic_filter_test.go | 2 +-
.../generic_service_filter.go | 2 +-
.../generic_service_filter_test.go | 2 +-
.../graceful_shutdown_filter.go | 2 +-
.../graceful_shutdown_filter_test.go | 4 +-
filter/{filter => filter_impl}/hystrix_filter.go | 2 +-
.../{filter => filter_impl}/hystrix_filter_test.go | 2 +-
filter/{filter => filter_impl}/metrics_filter.go | 45 ++++++++++-
.../{filter => filter_impl}/metrics_filter_test.go | 12 ++-
filter/{filter => filter_impl}/token_filter.go | 2 +-
.../{filter => filter_impl}/token_filter_test.go | 2 +-
.../tps/tps_limit_fix_window_strategy.go | 0
.../tps/tps_limit_fix_window_strategy_test.go | 0
.../tps/tps_limit_sliding_window_strategy.go | 0
.../tps/tps_limit_sliding_window_strategy_test.go | 0
.../tps/tps_limit_strategy_mock.go | 0
.../tps_limit_thread_safe_fix_window_strategy.go | 0
...s_limit_thread_safe_fix_window_strategy_test.go | 0
.../tps/tps_limiter_method_service.go | 0
.../tps/tps_limiter_method_service_test.go | 0
filter/{ => filter_impl}/tps/tps_limiter_mock.go | 0
filter/{filter => filter_impl}/tps_limit_filter.go | 6 +-
.../tps_limit_filter_test.go | 6 +-
.../rejected_execution_handler_mock.go | 2 +-
.../rejected_execution_handler_only_log.go | 2 +-
.../rejected_execution_handler_only_log_test.go | 2 +-
go.mod | 4 +-
go.sum | 12 +--
...t_counter_impl.go => default_bucket_counter.go} | 0
...impl_test.go => default_bucket_counter_test.go} | 0
...ast_compass_impl.go => default_fast_compass.go} | 4 +-
...ompass_test.go => default_fast_compass_test.go} | 0
metrics/impl/default_metric_manager.go | 10 ++-
metrics/impl/default_metric_manager_test.go | 2 +-
...efault_registry_impl.go => default_registry.go} | 77 +++++++++++++++---
...istry_impl_test.go => default_registry_test.go} | 27 ++++++-
.../{counter_impl.go => nop_bucket_counter.go} | 51 ++++++------
...al_clock_test.go => nop_bucket_counter_test.go} | 23 +++---
metrics/impl/nop_compass.go | 92 ++++++++++++++++++++++
...iform_reservoir_test.go => nop_compass_test.go} | 37 ++++-----
metrics/impl/nop_fast_compass.go | 13 +--
metrics/impl/nop_metric_manager.go | 6 +-
metrics/impl/nop_snapshot.go | 74 +++++++++++++++++
.../{manual_clock_test.go => nop_snapshot_test.go} | 25 +++---
metrics/metric_manager.go | 1 +
metrics/metric_registry.go | 6 ++
protocol/dubbo/client.go | 8 ++
protocol/dubbo/config.go | 23 ++++--
protocol/dubbo/dubbo_protocol.go | 12 ++-
protocol/jsonrpc/jsonrpc_protocol.go | 12 ++-
registry/etcdv3/registry_test.go | 2 +-
registry/protocol/protocol.go | 2 +-
registry/zookeeper/listener_test.go | 4 +-
registry/zookeeper/registry_test.go | 2 +-
79 files changed, 682 insertions(+), 191 deletions(-)
rename filter/{filter => filter_impl}/access_log_filter.go (99%)
rename filter/{filter => filter_impl}/access_log_filter_test.go (99%)
rename filter/{filter => filter_impl}/active_filter.go (98%)
rename filter/{filter => filter_impl}/echo_filter.go (98%)
rename filter/{filter => filter_impl}/echo_filter_test.go (98%)
rename filter/{filter => filter_impl}/execute_limit_filter.go (98%)
rename filter/{filter => filter_impl}/execute_limit_filter_test.go (99%)
rename filter/{filter => filter_impl}/generic_filter.go (99%)
rename filter/{filter => filter_impl}/generic_filter_test.go (99%)
rename filter/{filter => filter_impl}/generic_service_filter.go (99%)
rename filter/{filter => filter_impl}/generic_service_filter_test.go (99%)
rename filter/{filter => filter_impl}/graceful_shutdown_filter.go (99%)
rename filter/{filter => filter_impl}/graceful_shutdown_filter_test.go (97%)
rename filter/{filter => filter_impl}/hystrix_filter.go (99%)
rename filter/{filter => filter_impl}/hystrix_filter_test.go (99%)
rename filter/{filter => filter_impl}/metrics_filter.go (69%)
rename filter/{filter => filter_impl}/metrics_filter_test.go (88%)
rename filter/{filter => filter_impl}/token_filter.go (98%)
rename filter/{filter => filter_impl}/token_filter_test.go (99%)
rename filter/{ => filter_impl}/tps/tps_limit_fix_window_strategy.go (100%)
rename filter/{ => filter_impl}/tps/tps_limit_fix_window_strategy_test.go (100%)
rename filter/{ => filter_impl}/tps/tps_limit_sliding_window_strategy.go (100%)
rename filter/{ => filter_impl}/tps/tps_limit_sliding_window_strategy_test.go (100%)
rename filter/{ => filter_impl}/tps/tps_limit_strategy_mock.go (100%)
rename filter/{ => filter_impl}/tps/tps_limit_thread_safe_fix_window_strategy.go (100%)
rename filter/{ => filter_impl}/tps/tps_limit_thread_safe_fix_window_strategy_test.go (100%)
rename filter/{ => filter_impl}/tps/tps_limiter_method_service.go (100%)
rename filter/{ => filter_impl}/tps/tps_limiter_method_service_test.go (100%)
rename filter/{ => filter_impl}/tps/tps_limiter_mock.go (100%)
rename filter/{filter => filter_impl}/tps_limit_filter.go (95%)
rename filter/{filter => filter_impl}/tps_limit_filter_test.go (96%)
rename filter/{common => handler}/rejected_execution_handler_mock.go (99%)
rename filter/{common => handler}/rejected_execution_handler_only_log.go (99%)
rename filter/{common => handler}/rejected_execution_handler_only_log_test.go (98%)
rename metrics/impl/{bucket_counter_impl.go => default_bucket_counter.go} (100%)
rename metrics/impl/{bucket_counter_impl_test.go => default_bucket_counter_test.go} (100%)
rename metrics/impl/{fast_compass_impl.go => default_fast_compass.go} (97%)
rename metrics/impl/{fast_compass_test.go => default_fast_compass_test.go} (100%)
rename metrics/impl/{default_registry_impl.go => default_registry.go} (50%)
rename metrics/impl/{default_registry_impl_test.go => default_registry_test.go} (67%)
copy metrics/impl/{counter_impl.go => nop_bucket_counter.go} (53%)
copy metrics/impl/{manual_clock_test.go => nop_bucket_counter_test.go} (71%)
create mode 100644 metrics/impl/nop_compass.go
copy metrics/impl/{uniform_reservoir_test.go => nop_compass_test.go} (61%)
create mode 100644 metrics/impl/nop_snapshot.go
copy metrics/impl/{manual_clock_test.go => nop_snapshot_test.go} (67%)