This is an automated email from the ASF dual-hosted git repository.
justxuewei pushed a change to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from e4fa5df Add: user define config (#1640)
add 8f8cf96 feat(adasvc): add infrastructure for adaptive service
add 4dfc01e feat(adasvc): reference config support adaptive service
add 2ca1018 feat(adasvc): add p2c load balance
add e83a8a6 feat(cluster): add capacity evaluator interface
add f0c64e6 feat(cluster): add capacity updater
add 69dd9d3 feat(cluster): add capacity updater
add 2db43f7 feat(cluster): add fields to vegas capeva
add 588f392 feat(cluster): refactor capeva interface
add e0a4d1a feat(cluster): add more fields to vegas capeva
add 9af855a feat(cluster): vegas evaupdater done
add 785c74c Merge branch '3.0' into feat/adasvc
add 1d5fca1 fix(common): fix typo
add 7a537ff fix(common): fix typo
add 6d866b5 fix(cluster): add apache license
add 865c058 feat(cluster): define limiter & update interface
add 9d26e68 Merge branch '3.0' into feat/adasvc
add c3f9dbe feat(cluster): remove cpu stat temporarily
add ff4e60b feat(cluster): update hill climbing limiter
add 0472bf1 feat(cluster): hill climbing done
add 7e98a27 Merge branch '3.0' into feat/adasvc
add 70ca487 fix(cluster): fix issue where init limitation is 0
add c949cef Merge branch '3.0' into feat/adasvc
add ece019f feat(cluster): provder-side filter done
add bf43b0b fix(cluster): fix uint64 subtraction issue
add d8ca7f1 fix(cluster): add adaptivesvc filter to default service
filters
add 30dcb14 style: go fmt
add 5b48b40 fix(filter): import adaptivesvc
add 99f6919 Merge branch '3.0' into feat/adasvc
add f906714 Merge branch '3.0' into feat/adasvc
add c7edac5 fix(imports): import adaptivesvc cluster and p2c loadbalance
add 73b4f70 fix(config): fix unexpectedly panic
add 1fa48ca feat(adasvc): add debug logs
add 0acc52e fix(adasvc): pass attachements with string
add e5de62f feat(adasvc): detail debug logs
add 6f1d7bf fix(adasvc): fix log info
add 4a04d4a feat: detail dubbo logs
add 4ed7505 feat: remove useless logs
add 8b12eac fix(adasvc): fix incorrect type
add 9ac6763 Merge branch '3.0' into feat-adasvc
add c23612b style: go fmt & dubbofmt
add 0f7459b fix: rpc result attrs is not initialized
add 429a336 fix(protocol): fix result panic when attrs is not initialized
add bfc336e Merge branch '3.0' into feat-adasvc
new 55e9fdf Merge pull request #1649 from apache/feat-adasvc
The 1 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:
.../cluster/{failfast => adaptivesvc}/cluster.go | 34 ++-
cluster/cluster/adaptivesvc/cluster_invoker.go | 85 ++++++
cluster/cluster/available/cluster_invoker.go | 6 +-
cluster/cluster/available/cluster_invoker_test.go | 2 +-
cluster/cluster_impl/import.go | 1 +
cluster/loadbalance/p2c/loadbalance.go | 129 +++++++++
.../doc.go => cluster/metrics/constants.go | 6 +-
cluster/metrics/local_metrics.go | 80 ++++++
cluster/metrics/metrics.go | 49 ++++
.../url_label_match_judge.go => metrics/utils.go} | 20 +-
common/constant/cluster.go | 17 +-
common/constant/default.go | 20 +-
common/constant/key.go | 12 +-
common/constant/loadbalance.go | 1 +
common/proxy/proxy.go | 6 +-
config/consumer_config.go | 2 +
config/provider_config.go | 22 +-
config/reference_config.go | 34 ++-
filter/adaptivesvc/filter.go | 125 ++++++++
filter/adaptivesvc/limiter/hill_climbing.go | 315 +++++++++++++++++++++
.../adaptivesvc/limiter/limiter.go | 25 +-
.../adaptivesvc/limiter/utils.go | 55 ++--
filter/adaptivesvc/limiter_mapper.go | 85 ++++++
filter/filter_impl/import.go | 1 +
filter/seata/filter_test.go | 2 +-
filter/sentinel/filter.go | 5 +-
imports/imports.go | 3 +
.../local/metadata_service_proxy_factory_test.go | 4 +-
protocol/dubbo/dubbo_invoker.go | 1 -
protocol/invoker.go | 9 +
.../protocolwrapper/protocol_filter_wrapper.go | 9 +
protocol/result.go | 26 ++
remoting/codec.go | 1 +
remoting/exchange.go | 6 +
remoting/exchange_client.go | 3 +
remoting/getty/listener.go | 13 +-
36 files changed, 1112 insertions(+), 102 deletions(-)
copy cluster/cluster/{failfast => adaptivesvc}/cluster.go (63%)
create mode 100644 cluster/cluster/adaptivesvc/cluster_invoker.go
create mode 100644 cluster/loadbalance/p2c/loadbalance.go
copy protocol/grpc/internal/doc.go => cluster/metrics/constants.go (93%)
create mode 100644 cluster/metrics/local_metrics.go
create mode 100644 cluster/metrics/metrics.go
copy cluster/{router/v3router/judger/url_label_match_judge.go =>
metrics/utils.go} (81%)
create mode 100644 filter/adaptivesvc/filter.go
create mode 100644 filter/adaptivesvc/limiter/hill_climbing.go
copy config/application_config_test.go =>
filter/adaptivesvc/limiter/limiter.go (74%)
copy common/extension/proxy_factory.go => filter/adaptivesvc/limiter/utils.go
(51%)
create mode 100644 filter/adaptivesvc/limiter_mapper.go
