This is an automated email from the ASF dual-hosted git repository.
AlexStocks pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
from 08a4387b7 fix(protocol/triple): SendHeader writes into ResponseHeader
instead of RequestHeader (#3668)
new f0ef1490b Merge branch 'main' into develop
add 3996cc839 feat(triple): dispatch non-IDL wrapper decoding by
SerializeType (#3550)
add 6443c823b chore: add doc comments and unit tests for instance
customizers (#3676)
add 0c194ebfb fix(tool): drain in-flight requests before canceling ctx in
engine.Stop() (#3677)
add c32066f97 fix(filter/generic): guard $invoke arg type assertions to
avoid panic (#3680)
add fcb2e5d4b feat(triple): add HTTP/3 transport options (#3681)
add a65cdc1ff chore: add doc comments and unit tests for metadata
customizers (#3678)
add 9757e7735 docs(router): complete script router comments and unit test
coverage (#3682)
add 6dea7f500 fix(generic): honor m tags during realization (#3505)
add 3945883ad fix(benchmark): Add support for dubbo-java benchmark (#3689)
add 598aa49ea fix(invocation): guard ActualMethodName type assertion to
avoid panic (#3684)
add da5838678 fix(triple): filter http.ErrServerClosed in single-protocol
server shutdown (#3671)
add c79f6166f fix:cache manager race #3569 (#3601)
add 221046200 fix(metadata, protocol, proxy): preserve request context
across RPC paths (#3579)
add ca39fe208 fix(graceful_shutdown, loadbalance): prevent hard exits and
P2C panics (#3591)
add 788f55894 Feat: enhance mapping observability (#3605)
add 0f0ee4c9c docs: complete Triple configuration field comments (#3674)
add 106675bb5 fix: self-heal application-level discovery after transient
metadata failure (#3615) (#3625)
add 6647d6a12 fix: retry failed application-level AddListener with capped
backoff (#3624) (#3634)
add 630e2839f fix(triple): stop HTTP/2/HTTP/3 startup from hanging Run
(#3645)
add a9e32b5ec deps(zookeeper): migrate from dubbogo/go-zookeeper fork to
upstream go-zookeeper/zk (#3459) (#3690)
add c150ca471 perf(remoting): share one backend client per ZK/Nacos
cluster across registry, config-center and metadata-report (#3573) (#3635)
new 4da5e9e0a Merge branch 'develop' of https://github.com/apache/dubbo-go
into develop
The 2 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/loadbalance/p2c/loadbalance.go | 22 +-
cluster/loadbalance/p2c/loadbalance_test.go | 136 ++++-
cluster/router/script/instance/instances_pool.go | 10 +
cluster/router/script/instance/js_instance.go | 16 +
cluster/router/script/instance/js_instance_test.go | 93 ++++
cluster/router/script/router.go | 16 +-
cluster/router/script/router_test.go | 35 ++
config_center/zookeeper/impl.go | 4 +-
config_center/zookeeper/impl_test.go | 97 +++-
filter/generic/generalizer/map.go | 10 +-
filter/generic/generalizer/map_test.go | 22 +
filter/generic/service_filter.go | 10 +-
filter/generic/service_filter_test.go | 49 ++
global/http3_config.go | 29 +-
global/protocol_config.go | 18 +-
global/triple_config.go | 22 +-
go.mod | 10 +-
go.sum | 30 +-
graceful_shutdown/shutdown.go | 44 +-
graceful_shutdown/shutdown_test.go | 92 +++-
metadata/client.go | 33 +-
metadata/client_test.go | 41 ++
metadata/mapping/metadata/service_name_mapping.go | 99 +++-
.../mapping/metadata/service_name_mapping_test.go | 267 ++++++++++
metadata/report/zookeeper/report.go | 19 +-
metadata/report/zookeeper/report_test.go | 2 +-
metadata/report_instance_test.go | 15 +-
metrics/metadata/collector.go | 55 ++
metrics/metadata/collector_test.go | 239 +++++++++
metrics/metadata/metric_set.go | 46 +-
protocol/dubbo/dubbo_invoker.go | 6 +-
protocol/invocation/rpcinvocation.go | 55 +-
protocol/invocation/rpcinvocation_test.go | 61 +++
protocol/jsonrpc/server.go | 228 ++++++---
protocol/jsonrpc/server_test.go | 455 +++++++++++++++++
protocol/rest/server/rest_server.go | 19 +-
protocol/rest/server/rest_server_test.go | 166 ++++++
protocol/triple/active_notify_test.go | 4 +-
protocol/triple/options.go | 60 ++-
protocol/triple/options_test.go | 62 +++
protocol/triple/server.go | 10 +-
protocol/triple/triple_protocol/codec.go | 204 +++++---
protocol/triple/triple_protocol/codec_test.go | 45 ++
.../triple/triple_protocol/codec_wrapper_test.go | 481 +++++++++++++++++-
protocol/triple/triple_protocol/inner_codec.go | 88 ++++
protocol/triple/triple_protocol/protocol_triple.go | 39 +-
protocol/triple/triple_protocol/server.go | 127 ++++-
protocol/triple/triple_protocol/server_ext_test.go | 86 ++++
.../triple_protocol/server_lifecycle_test.go | 561 ++++++++++++++++++++-
protocol/triple/triple_protocol/server_test.go | 4 +-
proxy/proxy.go | 1 +
registry/directory/directory.go | 35 +-
registry/directory/directory_test.go | 57 ++-
.../metadata_service_url_params_customizer.go | 9 +
.../metadata_service_url_params_customizer_test.go | 61 ++-
.../metadata_service_version_customizer.go | 10 +-
.../metadata_service_version_customizer_test.go | 99 ++++
.../protocol_ports_metadata_customizer.go | 8 +-
.../protocol_ports_metadata_customizer_test.go | 156 ++++++
.../service_instance_host_port_customizer.go | 8 +-
.../service_instance_host_port_customizer_test.go | 143 ++++++
.../customizer/service_instance_tag_customizer.go | 1 +
.../customizer/service_revision_customizer.go | 4 +
registry/servicediscovery/metadata_retry_test.go | 372 ++++++++++++++
.../servicediscovery/service_discovery_registry.go | 330 +++++++++++-
.../service_instances_changed_listener_impl.go | 363 ++++++++++---
...service_instances_changed_listener_impl_test.go | 71 ++-
registry/servicediscovery/store/cache_manager.go | 69 ++-
.../servicediscovery/store/cache_manager_test.go | 283 +++++++++++
.../subscribe_destroy_race_test.go | 164 ++++++
registry/servicediscovery/subscribe_retry_test.go | 370 ++++++++++++++
registry/zookeeper/registry.go | 4 +-
remoting/exchange_client.go | 55 +-
remoting/exchange_client_test.go | 60 ++-
remoting/getty/getty_client.go | 19 +-
remoting/nacos/builder.go | 80 ++-
remoting/nacos/builder_test.go | 145 ++++++
.../curator_discovery/service_discovery.go | 4 +-
remoting/zookeeper/listener.go | 4 +-
server/server.go | 10 +-
server/server_test.go | 47 ++
tools/benchmark/client/engine/engine.go | 2 +-
tools/benchmark/client/main.go | 35 +-
tools/benchmark/scripts/run_all.sh | 13 +-
tools/benchmark/scripts/run_single.sh | 9 +
tools/benchmark/server/dubbo-java/pom.xml | 45 +-
.../dubbo => }/benchmark/BenchmarkService.java | 6 +-
.../dubbo => }/benchmark/BenchmarkServiceImpl.java | 9 +-
.../apache/dubbo/benchmark/BenchmarkRequest.java | 37 --
.../apache/dubbo/benchmark/BenchmarkResponse.java | 37 --
.../apache/dubbo/benchmark/BenchmarkServer.java | 8 +-
.../src/main/resources/application.properties | 4 +-
92 files changed, 6960 insertions(+), 629 deletions(-)
create mode 100644 protocol/rest/server/rest_server_test.go
create mode 100644 protocol/triple/options_test.go
create mode 100644 protocol/triple/triple_protocol/inner_codec.go
create mode 100644 protocol/triple/triple_protocol/server_ext_test.go
create mode 100644
registry/servicediscovery/customizer/metadata_service_version_customizer_test.go
create mode 100644
registry/servicediscovery/customizer/protocol_ports_metadata_customizer_test.go
create mode 100644
registry/servicediscovery/customizer/service_instance_host_port_customizer_test.go
create mode 100644 registry/servicediscovery/metadata_retry_test.go
create mode 100644 registry/servicediscovery/subscribe_destroy_race_test.go
create mode 100644 registry/servicediscovery/subscribe_retry_test.go
rename tools/benchmark/server/dubbo-java/src/main/java/{org/apache/dubbo =>
}/benchmark/BenchmarkService.java (84%)
rename tools/benchmark/server/dubbo-java/src/main/java/{org/apache/dubbo =>
}/benchmark/BenchmarkServiceImpl.java (76%)
delete mode 100644
tools/benchmark/server/dubbo-java/src/main/java/org/apache/dubbo/benchmark/BenchmarkRequest.java
delete mode 100644
tools/benchmark/server/dubbo-java/src/main/java/org/apache/dubbo/benchmark/BenchmarkResponse.java
