This is an automated email from the ASF dual-hosted git repository.
Alanxtl pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
from 4da5e9e0a Merge branch 'develop' of https://github.com/apache/dubbo-go
into develop
add c6a4a61d7 refactor: replace vault jsonutil usage (#3696)
add 422a66ada fix(polaris): resolve nil pointer panic on startup and route
miss (#3303) (#3697)
add 8e1e721df build(deps): bump github.com/gorilla/websocket from 1.4.2 to
1.5.3 (#3702)
add d9557d572 feat(metadata): expose observability for metadata source,
storage typ… (#3685)
add 76de7fe38 chore: upgrade logging dependencies (logrus, zap, go-isatty)
(#3703)
add 672933f02 fix(dubbo): accept bare-ms timeout attachment so failover
retries keep the configured timeout (#3714)
add e3802a892 fix(filter): make access log goroutine shutdown test
race-safe (#3713)
add 4154395f7 feat(triple): add HTTP/3 receive window config (#3704)
add 744af790b fix(generic): honor m tag options (#3709)
add 2046d8dec Feat: Add ZK config cache (#3612)
add 130b2a686 fix(getty): fix the getty poll bug described at #3509 (#3592)
add 56889b498 refactor(deps): migrate gost stdlib thin wrappers, uber
atomic and pkg/errors to stdlib (#3695)
add b7086bd1e feat(triple): performance optimization for Triple unary hot
path (#3706)
add d4b4fbfbc refactor: replace golang mock with uber mock (#3699)
new 643ffa3c4 Merge remote-tracking branch 'upstream/develop'
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:
.github/mockgen-copyright.txt | 14 +
.github/workflows/github-actions.yml | 26 +
client/action.go | 9 +-
cluster/cluster/adaptivesvc/cluster_invoker.go | 5 +-
cluster/cluster/available/cluster_invoker.go | 6 +-
cluster/cluster/available/cluster_invoker_test.go | 4 +-
cluster/cluster/base/cluster_invoker.go | 9 +-
cluster/cluster/broadcast/cluster_invoker_test.go | 4 +-
cluster/cluster/failback/cluster_invoker.go | 3 +
cluster/cluster/failback/cluster_test.go | 23 +-
cluster/cluster/failfast/cluster_invoker.go | 4 +
cluster/cluster/failfast/cluster_test.go | 33 +-
cluster/cluster/failover/cluster_invoker.go | 5 +-
cluster/cluster/failover/cluster_invoker_test.go | 6 +-
cluster/cluster/failsafe/cluster_invoker.go | 4 +
cluster/cluster/failsafe/cluster_test.go | 9 +-
cluster/cluster/forking/cluster_test.go | 4 +-
cluster/cluster/mock.go | 5 +-
cluster/cluster/zoneaware/cluster_invoker_test.go | 4 +-
cluster/directory/base/directory.go | 7 +-
cluster/directory/static/directory.go | 8 +-
cluster/loadbalance/consistenthashing/selector.go | 9 +-
cluster/loadbalance/p2c/loadbalance_test.go | 4 +-
cluster/metrics/metrics.go | 3 +-
cluster/metrics/mock_metrics.go | 46 +-
cluster/router/chain/chain.go | 10 +-
cluster/router/condition/route.go | 19 +-
cluster/router/polaris/router.go | 6 +
common/config/utils.go | 5 +-
common/constant/cluster.go | 2 +-
common/constant/key.go | 1 +
.../service_name_mapping.go => dubboutil/json.go} | 43 +-
common/dubboutil/json_test.go | 127 ++++
common/extension/cluster.go | 6 +-
common/extension/filter.go | 2 +-
common/extension/logger.go | 4 +-
common/extension/service_discovery.go | 4 +-
.../extension/service_instance_selector_factory.go | 4 +-
common/host_util.go | 78 ++-
common/rpc_service.go | 19 +-
common/url.go | 11 +-
config_center/apollo/impl.go | 23 +-
config_center/nacos/client.go | 9 +-
config_center/nacos/impl.go | 8 +-
config_center/nacos/impl_test.go | 4 +-
config_center/parser/configuration_parser.go | 7 +-
config_center/zookeeper/config_cache.go | 703 +++++++++++++++++++++
config_center/zookeeper/config_cache_test.go | 572 +++++++++++++++++
config_center/zookeeper/impl.go | 154 ++++-
config_center/zookeeper/impl_test.go | 338 ++++++++++
config_center/zookeeper/listener.go | 345 +++++++++-
config_center/zookeeper/listener_test.go | 452 ++++++++++++-
filter/accesslog/filter_test.go | 4 +-
filter/accesslog/memory_leak_test.go | 76 ++-
filter/active/filter_test.go | 4 +-
filter/adaptivesvc/filter.go | 3 +-
filter/adaptivesvc/filter_test.go | 4 +-
filter/auth/consumer_sign_filter_test.go | 4 +-
filter/auth/provider_auth_filter_test.go | 4 +-
filter/generic/filter_test.go | 4 +-
filter/generic/generalizer/gson.go | 9 +-
filter/generic/generalizer/map.go | 140 +++-
filter/generic/generalizer/map_test.go | 133 +++-
filter/generic/generalizer/protobuf_json.go | 9 +-
filter/generic/service_filter.go | 23 +-
filter/generic/service_filter_test.go | 8 +-
filter/generic/util.go | 20 +-
filter/generic/util_test.go | 4 +-
filter/graceful_shutdown/provider_filter_test.go | 5 +-
filter/handler/rejected_execution_handler_mock.go | 60 +-
filter/otel/trace/filter_test.go | 4 +-
filter/rejected_execution_handler.go | 2 +
filter/sentinel/filter_test.go | 3 +-
filter/token/filter.go | 13 +-
filter/tps/filter_test.go | 4 +-
filter/tps/limiter/method_service_test.go | 4 +-
filter/tps/limiter/mock.go | 58 +-
filter/tps/strategy/mock.go | 55 +-
filter/tps_limiter.go | 1 +
filter/tps_strategy.go | 2 +
global/config_test.go | 54 +-
global/http3_config.go | 44 +-
global/triple_config.go | 21 +-
go.mod | 20 +-
go.sum | 38 +-
loader.go | 33 +-
loader_test.go | 37 ++
metadata/client.go | 24 +-
metadata/client_test.go | 3 +-
metadata/mapping/metadata/service_name_mapping.go | 8 +-
metadata/metadata_service.go | 5 +-
metadata/options.go | 5 +-
metadata/report/etcd/report.go | 10 +-
metadata/report/etcd/report_test.go | 4 +-
metadata/report/nacos/report.go | 13 +-
metadata/report/nacos/report_test.go | 4 +-
metadata/report/zookeeper/report.go | 15 +-
metadata/report_instance_test.go | 3 +-
metrics/metadata/collector.go | 24 +
metrics/metadata/metric_set.go | 50 ++
protocol/base/base_invoker.go | 20 +-
protocol/base/rpc_status.go | 16 +-
protocol/dubbo/dubbo_codec.go | 18 +-
protocol/dubbo/dubbo_invoker.go | 6 +-
protocol/dubbo/dubbo_invoker_test.go | 34 +
protocol/dubbo/hessian2/const.go | 13 +-
protocol/dubbo/hessian2/hessian_dubbo.go | 9 +-
protocol/dubbo/hessian2/hessian_request.go | 32 +-
protocol/dubbo/hessian2/hessian_response.go | 48 +-
protocol/dubbo/hessian2/java_class.go | 9 +-
protocol/dubbo/impl/codec.go | 12 +-
protocol/dubbo/impl/const.go | 7 +-
protocol/dubbo/impl/hessian.go | 23 +-
protocol/dubbo/impl/package.go | 11 +-
protocol/grpc/config.go | 4 +-
protocol/grpc/grpc_invoker.go | 5 +-
protocol/jsonrpc/http.go | 2 +-
protocol/jsonrpc/http_test.go | 7 +-
protocol/jsonrpc/json.go | 27 +-
protocol/jsonrpc/server.go | 7 +-
protocol/mock/mock_invoker.go | 50 +-
protocol/rest/client/client_impl/resty_client.go | 3 +-
protocol/rest/config/reader/rest_config_reader.go | 5 +-
protocol/rest/rest_invoker.go | 10 +-
protocol/rest/server/rest_server.go | 21 +-
.../rest/server/server_impl/go_restful_server.go | 4 +-
protocol/triple/client.go | 17 +-
protocol/triple/client_external_test.go | 3 +-
.../triple/internal/http3config/http3_config.go | 72 +++
.../internal/http3config/http3_config_test.go | 195 +++++-
protocol/triple/options.go | 33 +
protocol/triple/options_test.go | 79 +++
protocol/triple/triple_protocol/client.go | 6 +-
protocol/triple/triple_protocol/codec.go | 24 +-
protocol/triple/triple_protocol/option.go | 33 +
protocol/triple/triple_protocol/protocol.go | 3 +
protocol/triple/triple_protocol/protocol_grpc.go | 58 +-
protocol/triple/triple_protocol/protocol_triple.go | 33 +-
protocol/triple/triple_protocol/server.go | 9 +-
protocol/triple/triple_protocol/unary_fastpath.go | 304 +++++++++
.../unary_fastpath_behavior_test.go | 606 ++++++++++++++++++
.../triple_protocol/unary_fastpath_bench_test.go | 131 ++++
.../triple_protocol/unary_fastpath_body_test.go | 308 +++++++++
.../unary_fastpath_concurrency_test.go | 158 +++++
.../unary_fastpath_conn_type_test.go | 78 +++
.../triple/unary_fastpath_public_entry_test.go | 260 ++++++++
proxy/proxy.go | 17 +-
proxy/proxy_factory/default.go | 6 +-
proxy/proxy_factory/pass_through.go | 5 +-
proxy/proxy_factory/utils.go | 7 +-
proxy/proxy_test.go | 25 +-
registry/base_configuration_listener.go | 4 +-
registry/base_registry.go | 25 +-
registry/directory/directory.go | 4 +-
registry/directory/directory_test.go | 4 +-
registry/etcdv3/listener.go | 5 +-
registry/etcdv3/registry.go | 11 +-
registry/etcdv3/service_discovery.go | 11 +-
registry/etcdv3/service_discovery_test.go | 37 ++
registry/mock_registry.go | 5 +-
registry/nacos/listener.go | 9 +-
registry/nacos/registry.go | 15 +-
registry/nacos/registry_test.go | 4 +-
registry/nacos/service_discovery.go | 6 +-
registry/nacos/service_discovery_test.go | 4 +-
registry/polaris/listener.go | 9 +-
registry/polaris/registry.go | 13 +-
registry/polaris/service_discovery.go | 8 +-
registry/protocol/protocol.go | 16 +-
registry/service_instance.go | 10 +-
.../customizer/service_revision_customizer.go | 6 +
registry/servicediscovery/metadata_retry_test.go | 19 +-
.../servicediscovery/service_discovery_registry.go | 15 +-
.../service_instances_changed_listener_impl.go | 74 ++-
.../subscribe_destroy_race_test.go | 5 +-
registry/servicediscovery/subscribe_retry_test.go | 5 +-
registry/zookeeper/listener.go | 7 +-
registry/zookeeper/registry.go | 17 +-
remoting/etcdv3/client.go | 10 +-
remoting/etcdv3/listener.go | 5 +-
remoting/exchange.go | 3 +-
remoting/exchange_client.go | 15 +-
remoting/getty/config.go | 33 +-
remoting/getty/dubbo_codec_for_test.go | 14 +-
remoting/getty/getty_client.go | 15 +-
remoting/getty/getty_client_test.go | 43 +-
remoting/getty/getty_server.go | 4 +-
remoting/getty/listener.go | 8 +-
remoting/getty/pool.go | 30 +-
remoting/getty/pool_test.go | 272 ++++++++
remoting/getty/readwriter.go | 14 +-
remoting/nacos/builder.go | 16 +-
remoting/polaris/builder.go | 4 +-
remoting/zookeeper/client.go | 5 +-
.../curator_discovery/service_discovery.go | 10 +-
remoting/zookeeper/listener.go | 204 ++++--
remoting/zookeeper/listener_test.go | 207 ++++++
server/action.go | 20 +-
server/action_test.go | 31 +-
server/options.go | 18 +-
server/server.go | 9 +-
.../cmd/testGenCode/template/newApp/go.sum | 13 -
.../cmd/testGenCode/template/newDemo/go.sum | 13 -
.../generator/internal/scaffold/gosum.go | 13 -
204 files changed, 7329 insertions(+), 1206 deletions(-)
create mode 100644 .github/mockgen-copyright.txt
copy common/{extension/service_name_mapping.go => dubboutil/json.go} (55%)
create mode 100644 common/dubboutil/json_test.go
create mode 100644 config_center/zookeeper/config_cache.go
create mode 100644 config_center/zookeeper/config_cache_test.go
create mode 100644 protocol/triple/triple_protocol/unary_fastpath.go
create mode 100644
protocol/triple/triple_protocol/unary_fastpath_behavior_test.go
create mode 100644 protocol/triple/triple_protocol/unary_fastpath_bench_test.go
create mode 100644 protocol/triple/triple_protocol/unary_fastpath_body_test.go
create mode 100644
protocol/triple/triple_protocol/unary_fastpath_concurrency_test.go
create mode 100644
protocol/triple/triple_protocol/unary_fastpath_conn_type_test.go
create mode 100644 protocol/triple/unary_fastpath_public_entry_test.go
