This is an automated email from the ASF dual-hosted git repository. Alanxtl pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
commit 643ffa3c4f16d4c52684ce5917b92d5a1e369176 Merge: 4da5e9e0a d4b4fbfbc Author: alanxtl <[email protected]> AuthorDate: Wed Sep 2 20:43:50 2026 +0800 Merge remote-tracking branch 'upstream/develop' .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 + common/{extension/cluster.go => dubboutil/json.go} | 47 +- 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, 7328 insertions(+), 1211 deletions(-)
