You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by xi...@apache.org on 2019/10/23 03:56:14 UTC
[dubbo-go] branch develop updated (6221170 -> 656b1d6)
This is an automated email from the ASF dual-hosted git repository.
xinminghe pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 6221170 merge master
new 125ed00 Define the interface of TpsLimitFilter
new 225b90d TpsLimiter, RejectedExecutionHandler, TpsLimitFilter
new dec6c16 Refactor MethodServiceTpsLimitImpl; Read config from yml
new 57b63db Finish Test
new e8a168c Fix UT
new 37e668d Add UT
new 687966a Fix review
new d3111f7 Fix UT
new 542ead7 Fix review: move the tps_limit to filter/impl/tps/
new 122629c fix reveiw: rename the file
new 6dd82ff Fix review
new 7c9bcec Fix Review
new 656b1d6 Merge pull request #237 from flycash/feature/TpsLimitFilter
The 1028 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:
common/constant/default.go | 2 +-
common/constant/key.go | 33 ++--
common/extension/tps_limit.go | 67 ++++++++
config/method_config.go | 15 +-
config/service_config.go | 78 +++++----
config/testdata/provider_config.yml | 9 +
filter/impl/access_log_filter.go | 2 +-
.../tps/impl/rejected_execution_handler_mock.go | 65 +++++++
.../impl/rejected_execution_handler_only_log.go | 69 ++++++++
.../rejected_execution_handler_only_log_test.go | 30 ++--
.../impl/tps/impl/tps_limit_fix_window_strategy.go | 85 ++++++++++
.../impl/tps_limit_fix_window_strategy_test.go} | 29 ++--
.../tps/impl/tps_limit_sliding_window_strategy.go | 90 ++++++++++
.../tps_limit_sliding_window_strategy_test.go} | 31 ++--
filter/impl/tps/impl/tps_limit_strategy_mock.go | 63 +++++++
.../tps_limit_thread_safe_fix_window_strategy.go | 65 +++++++
..._limit_thread_safe_fix_window_strategy_test.go} | 29 ++--
filter/impl/tps/impl/tps_limiter_method_service.go | 188 +++++++++++++++++++++
.../tps/impl/tps_limiter_method_service_test.go | 135 +++++++++++++++
filter/impl/tps/impl/tps_limiter_mock.go | 65 +++++++
.../impl/tps/rejected_execution_handler.go | 22 ++-
.../impl/tps/tps_limit_strategy.go | 38 ++---
.../impl/tps/tps_limiter.go | 19 ++-
filter/impl/tps_limit_filter.go | 72 ++++++++
filter/impl/tps_limit_filter_test.go | 102 +++++++++++
go.mod | 7 +-
go.sum | 7 +
27 files changed, 1268 insertions(+), 149 deletions(-)
create mode 100644 common/extension/tps_limit.go
create mode 100644 filter/impl/tps/impl/rejected_execution_handler_mock.go
create mode 100644 filter/impl/tps/impl/rejected_execution_handler_only_log.go
copy cluster/router.go => filter/impl/tps/impl/rejected_execution_handler_only_log_test.go (68%)
create mode 100644 filter/impl/tps/impl/tps_limit_fix_window_strategy.go
copy filter/impl/{echo_filter_test.go => tps/impl/tps_limit_fix_window_strategy_test.go} (60%)
create mode 100644 filter/impl/tps/impl/tps_limit_sliding_window_strategy.go
copy filter/impl/{echo_filter_test.go => tps/impl/tps_limit_sliding_window_strategy_test.go} (56%)
create mode 100644 filter/impl/tps/impl/tps_limit_strategy_mock.go
create mode 100644 filter/impl/tps/impl/tps_limit_thread_safe_fix_window_strategy.go
copy filter/impl/{echo_filter_test.go => tps/impl/tps_limit_thread_safe_fix_window_strategy_test.go} (58%)
create mode 100644 filter/impl/tps/impl/tps_limiter_method_service.go
create mode 100644 filter/impl/tps/impl/tps_limiter_method_service_test.go
create mode 100644 filter/impl/tps/impl/tps_limiter_mock.go
copy cluster/directory.go => filter/impl/tps/rejected_execution_handler.go (62%)
copy cluster/cluster_impl/failover_cluster.go => filter/impl/tps/tps_limit_strategy.go (59%)
copy common/proxy/proxy_factory.go => filter/impl/tps/tps_limiter.go (70%)
create mode 100644 filter/impl/tps_limit_filter.go
create mode 100644 filter/impl/tps_limit_filter_test.go