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