You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by ji...@apache.org on 2020/01/07 02:44:05 UTC
[dubbo-go] branch feature/grpc updated (e6d7c04 -> 01f84dc)
This is an automated email from the ASF dual-hosted git repository.
jianhaixu pushed a change to branch feature/grpc
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from e6d7c04 Merge pull request #271 from fangyincheng/develop
add f1b5d12 Fix: receive heartbeat from server
add 7fb327e consistent hash load balance
add 80e5bf5 fix comment.
add c27f733 Merge pull request #261 from imxyb/consistent-hash-lb
add 222a036 Update README.md
add a8e6de6 Update README_CN.md
add 81fb648 Update README.md
add 39f9052 Update README_CN.md
add 8703390 Merge branch 'master' into develop
add 17a63bf feat(dubbo/invoker): 修改dubbo 关闭的方式
add a253564 Merge pull request #268 from xujianhai666/feat-invoker
add f4f346c Imp: use var default value
add 33b75f1 Fix: use 1e6 as ms
add 3960cc1 Imp: change imports
add 2535641 add new config item for apollo
add c30bba3 Merge branch 'develop-dubbo-go-apache' into feature/apollo
add c85abd2 split config center getconfig method to getRule/getinternalproperty/getProperties
add bd7d791 fix review problems
add 4d82cfe Merge pull request #267 from zouyx/feature/apollo
add 5c3679f Merge branch 'develop' of https://github.com/apache/dubbo-go into develop
add 7d55c0d fix(common): use new uuid method
add 3fe96d3 Merge pull request #277 from xujianhai666/fix-dep
add 720def0 Ftr: replace func(rate, interval) with TpsStrategyCreator interface
add eb434b6 Merge pull request #280 from flycash/feature/StrategyCreator
add d024a3c Fix BUG: The RegistryConfigurationListener will be closed twice sometimes
add d65659f Merge pull request #281 from flycash/bug/negativeWGC
add 23a25a7 Merge branch 'master-dubbo-go-apache' into feature/addAsyncCall
add 4a49f8c add async callback
add 64815e8 fix case
add 0020ac4 fix case
add df36097 Merge branch 'master-dubbo-go-apache' into feature/addAsyncCall
add d0f16d2 add async callback
add 5bf5fc1 fix case
add ae50c05 fix case
add dba634e Merge remote-tracking branch 'origin/feature/addAsyncCall' into feature/addAsyncCall
add 498453c modify async callback
add f89f642 fix case
add ce62359 fix case
add 13f15ea fix review problems
add 25d2c23 add test case for async call
add 9c83f5e Merge pull request #272 from zouyx/feature/addAsyncCall
add c0839f0 support zkpath urlencoder
add 5a50da7 Merge pull request #283 from xujianhai666/feat-urlencoder
add 56cb00a Merge branch 'develop' of https://github.com/apache/dubbo-go into develop
add 3c1a96f support sticky connection
add 9604e7a Merge pull request #270 from CodingSinger/sticky
add d1da7ba change the position of the lock
add 16aff1f fix bug for reverseRegistryProtocol
add e6e0e14 Modify code according to code review
add 8d46ac0 Merge pull request #286 from pantianying/develop_gettyPool_lock
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
No new revisions were added by this update.
Summary of changes:
README.md | 10 +-
README_CN.md | 10 +-
cluster/cluster_impl/base_cluster_invoker.go | 39 ++++-
...luster_test.go => base_cluster_invoker_test.go} | 43 +++---
cluster/cluster_impl/failback_cluster_test.go | 2 +-
cluster/cluster_impl/failfast_cluster_test.go | 4 +-
cluster/cluster_impl/failsafe_cluster_test.go | 4 +-
cluster/loadbalance/consistent_hash.go | 165 +++++++++++++++++++++
cluster/loadbalance/consistent_hash_test.go | 110 ++++++++++++++
cluster/router/condition_router.go | 9 +-
common/constant/default.go | 4 +
common/constant/key.go | 2 +
common/extension/filter.go | 2 +-
common/extension/tps_limit.go | 6 +-
common/proxy/proxy.go | 4 +
common/proxy/proxy_factory.go | 1 +
common/proxy/proxy_factory/default.go | 7 +-
common/proxy/proxy_factory/default_test.go | 16 ++
common/rpc_service.go | 12 ++
common/url.go | 5 +
common/url_test.go | 12 ++
config/base_config.go | 4 +-
config/config_center_config.go | 2 +
config/method_config.go | 1 +
config/reference_config.go | 14 +-
config/reference_config_test.go | 57 +++++++
config/service.go | 8 +
config_center/apollo/impl.go | 40 ++---
config_center/apollo/impl_test.go | 6 +-
config_center/dynamic_configuration.go | 10 +-
config_center/mock_dynamic_config.go | 12 ++
config_center/zookeeper/impl.go | 10 +-
config_center/zookeeper/impl_test.go | 2 +-
.../common/impl/rejected_execution_handler_mock.go | 10 +-
filter/impl/generic_filter.go | 21 ++-
.../impl/tps/impl/tps_limit_fix_window_strategy.go | 12 +-
.../tps/impl/tps_limit_fix_window_strategy_test.go | 7 +-
.../tps/impl/tps_limit_sliding_window_strategy.go | 8 +-
.../impl/tps_limit_sliding_window_strategy_test.go | 9 +-
.../tps_limit_thread_safe_fix_window_strategy.go | 12 +-
...s_limit_thread_safe_fix_window_strategy_test.go | 7 +-
filter/impl/tps/impl/tps_limiter_method_service.go | 2 +-
.../tps/impl/tps_limiter_method_service_test.go | 43 ++++--
filter/impl/tps/impl/tps_limiter_mock.go | 10 +-
filter/impl/tps/tps_limit_strategy.go | 4 +
go.mod | 2 +
protocol/dubbo/client.go | 10 +-
protocol/dubbo/client_test.go | 5 +-
protocol/dubbo/codec.go | 21 ++-
protocol/dubbo/dubbo_invoker.go | 26 ++--
protocol/dubbo/dubbo_invoker_test.go | 6 +-
protocol/dubbo/listener.go | 24 +--
protocol/dubbo/pool.go | 17 ++-
protocol/dubbo/readwriter.go | 6 +-
protocol/invocation/rpcinvocation.go | 6 +
registry/base_configuration_listener.go | 2 +-
registry/protocol/protocol.go | 6 +-
registry/protocol/protocol_test.go | 5 -
registry/zookeeper/listener.go | 19 ++-
registry/zookeeper/registry.go | 16 +-
remoting/zookeeper/listener_test.go | 7 +
61 files changed, 750 insertions(+), 206 deletions(-)
copy cluster/cluster_impl/{registry_aware_cluster_test.go => base_cluster_invoker_test.go} (60%)
create mode 100644 cluster/loadbalance/consistent_hash.go
create mode 100644 cluster/loadbalance/consistent_hash_test.go