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%)