You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by fa...@apache.org on 2020/01/12 14:05:54 UTC
[dubbo-go] branch master updated (ab78c63 -> 932e149)
This is an automated email from the ASF dual-hosted git repository.
fangyc pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from ab78c63 Merge pull request #299 from apache/revert-296-upgrade
add f1b5d12 Fix: receive heartbeat from server
add 4ce2ea8 Mod: modify README
add 944e6dc add lock for invocation attachment
add 382169c Merge pull request #288 from xujianhai666/fix-map-attach
add 4409354 optimize code style
add b74bb2f fix code
add ba0b1a3 bug fix
add c6f6377 Merge pull request #293 from pantianying/develop_generic_code_fix
add e0e015c Merge branch 'develop' into heartbeat_for_server
add 53bb7fb add notes
add 01f84dc Merge pull request #302 from fangyincheng/heartbeat_for_server
add b4d116a generic service filter
add 131ad2d go.mod modify
add 1ac170a reponse fix
add 5ef93c3 optimize code
add fe314db fix
add 6aca4f5 modify error log info
add f96a30b modify test
add 8064687 split import block and add some blank lines
add af31400 split import packages
add a7a7926 add license
add b786517 modify generic_service filter name
add 527f21e fix
add 1c5cca4 modify filter package
add 8eaeb96 Merge branch 'develop' into generic-service
add bd7989a fix
add 8394520 Merge pull request #291 from Patrick0308/generic-service
add 62e7207 revert filter dir
add c95940a modify filter dir
add a92d606 modify filter dir & version
add 70aed98 delete mock json
add e7aa7e5 delete mock json in apollo test case
add e8cc8c7 Merge pull request #304 from zouyx/feature/deleteMockJson
add ad79b88 gost 1.5.1
add b0dbcb8 upgrade hessian2
add d451c2d Merge remote-tracking branch 'upstream/develop' into dev
add 03c6a4a Merge pull request #307 from micln/dev
add 92af46e Merge remote-tracking branch 'apache/develop' into develop
add 47066c2 Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
add 5f5cfb7 Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
add ebb35e8 Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
add 411435c Merge branch 'develop' of https://github.com/apache/dubbo-go into apache-develop
add 9723e7b add code for request_timeout
add 400c388 add code
add 8517ede Merge branch 'apache-develop' into develop_req_timeout_config
add 625c571 merge code
add 9bdc231 fix bug
add 52fbe96 fix bug
add 311135a fix bug
add 4226997 modify the format of the incoming package
add b2b66c3 remove one const
add bfa60ea Merge pull request #284 from pantianying/develop_req_timeout_config
add 3110d49 add GenericServiceFilter in README.md
add 2c86ec0 Merge pull request #310 from Patrick0308/modify-readme
add e31ffd6 Merge remote-tracking branch 'apache/develop' into develop
add 1980135 fix ut
add 1d7e21f Mod: modify date
add 20ca967 Fix: ut
add 4bd2851 Merge pull request #306 from fangyincheng/develop
add d01b5ee When protocol config don't have right config, remind user to check warning.
add a109609 Merge pull request #314 from Patrick0308/add_protocol_warning
add 5117a84 Imp: check consumerConfig.RequestTimeout by getty.MaxWheelTimeSpan
add dff4870 Mod: upgrade gost/getty version
add f691f24 Mod: change gost/getty version in go.sum
add 5ff8d34 Imp: check sessin timeout; change default client conf params
add dab215a Fmt: protocol/dubbo/config
add 932e149 Mod: upgrade hessian2
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
README.md | 5 +-
README_CN.md | 4 +-
cluster/router/condition_router.go | 2 +-
common/constant/default.go | 2 +-
common/constant/version.go | 4 +-
common/extension/filter.go | 7 +-
common/extension/tps_limit.go | 14 +-
common/url.go | 4 +-
common/url_test.go | 4 +-
config/consumer_config.go | 5 +
config/graceful_shutdown.go | 2 +-
config/method_config.go | 1 +
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/{impl => filter_impl}/access_log_filter.go | 2 +-
.../access_log_filter_test.go | 2 +-
filter/{impl => filter_impl}/active_filter.go | 2 +-
filter/{impl => filter_impl}/echo_filter.go | 2 +-
filter/{impl => filter_impl}/echo_filter_test.go | 2 +-
.../{impl => filter_impl}/execute_limit_filter.go | 4 +-
.../execute_limit_filter_test.go | 2 +-
filter/{impl => filter_impl}/generic_filter.go | 23 ++--
.../{impl => filter_impl}/generic_filter_test.go | 2 +-
filter/filter_impl/generic_service_filter.go | 126 ++++++++++++++++++
filter/filter_impl/generic_service_filter_test.go | 148 +++++++++++++++++++++
.../graceful_shutdown_filter.go | 5 +-
.../graceful_shutdown_filter_test.go | 10 +-
filter/{impl => filter_impl}/hystrix_filter.go | 2 +-
.../{impl => filter_impl}/hystrix_filter_test.go | 2 +-
filter/{impl => filter_impl}/token_filter.go | 2 +-
filter/{impl => filter_impl}/token_filter_test.go | 2 +-
.../tps}/tps_limit_fix_window_strategy.go | 6 +-
.../tps}/tps_limit_fix_window_strategy_test.go | 2 +-
.../tps}/tps_limit_sliding_window_strategy.go | 6 +-
.../tps}/tps_limit_sliding_window_strategy_test.go | 2 +-
.../tps}/tps_limit_strategy_mock.go | 2 +-
.../tps_limit_thread_safe_fix_window_strategy.go | 6 +-
...s_limit_thread_safe_fix_window_strategy_test.go | 2 +-
.../tps}/tps_limiter_method_service.go | 10 +-
.../tps}/tps_limiter_method_service_test.go | 8 +-
.../impl => filter_impl/tps}/tps_limiter_mock.go | 2 +-
filter/{impl => filter_impl}/tps_limit_filter.go | 6 +-
.../{impl => filter_impl}/tps_limit_filter_test.go | 21 ++-
.../rejected_execution_handler_mock.go | 2 +-
.../rejected_execution_handler_only_log.go | 6 +-
.../rejected_execution_handler_only_log_test.go | 2 +-
filter/{common => }/rejected_execution_handler.go | 2 +-
filter/{impl/tps => }/tps_limit_strategy.go | 2 +-
filter/{impl/tps => }/tps_limiter.go | 2 +-
go.mod | 7 +-
go.sum | 17 +--
protocol/dubbo/client.go | 8 ++
protocol/dubbo/codec.go | 14 +-
protocol/dubbo/config.go | 23 +++-
protocol/dubbo/dubbo_protocol.go | 12 +-
protocol/dubbo/listener.go | 24 ++--
protocol/dubbo/readwriter.go | 6 +-
protocol/invocation/rpcinvocation.go | 6 +
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 +-
68 files changed, 571 insertions(+), 169 deletions(-)
rename filter/{impl => filter_impl}/access_log_filter.go (99%)
rename filter/{impl => filter_impl}/access_log_filter_test.go (99%)
rename filter/{impl => filter_impl}/active_filter.go (98%)
rename filter/{impl => filter_impl}/echo_filter.go (98%)
rename filter/{impl => filter_impl}/echo_filter_test.go (98%)
rename filter/{impl => filter_impl}/execute_limit_filter.go (98%)
rename filter/{impl => filter_impl}/execute_limit_filter_test.go (99%)
rename filter/{impl => filter_impl}/generic_filter.go (90%)
rename filter/{impl => filter_impl}/generic_filter_test.go (99%)
create mode 100644 filter/filter_impl/generic_service_filter.go
create mode 100644 filter/filter_impl/generic_service_filter_test.go
rename filter/{impl => filter_impl}/graceful_shutdown_filter.go (95%)
rename filter/{impl => filter_impl}/graceful_shutdown_filter_test.go (89%)
rename filter/{impl => filter_impl}/hystrix_filter.go (99%)
rename filter/{impl => filter_impl}/hystrix_filter_test.go (99%)
rename filter/{impl => filter_impl}/token_filter.go (98%)
rename filter/{impl => filter_impl}/token_filter_test.go (99%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limit_fix_window_strategy.go (96%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limit_fix_window_strategy_test.go (99%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limit_sliding_window_strategy.go (96%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limit_sliding_window_strategy_test.go (99%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limit_strategy_mock.go (99%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limit_thread_safe_fix_window_strategy.go (95%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limit_thread_safe_fix_window_strategy_test.go (99%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limiter_method_service.go (96%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limiter_method_service_test.go (97%)
rename filter/{impl/tps/impl => filter_impl/tps}/tps_limiter_mock.go (99%)
rename filter/{impl => filter_impl}/tps_limit_filter.go (95%)
rename filter/{impl => filter_impl}/tps_limit_filter_test.go (84%)
rename filter/{common/impl => handler}/rejected_execution_handler_mock.go (99%)
rename filter/{common/impl => handler}/rejected_execution_handler_only_log.go (93%)
rename filter/{common/impl => handler}/rejected_execution_handler_only_log_test.go (98%)
rename filter/{common => }/rejected_execution_handler.go (98%)
rename filter/{impl/tps => }/tps_limit_strategy.go (98%)
rename filter/{impl/tps => }/tps_limiter.go (98%)