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 7125a09bd perf(metadata): pipeline ZooKeeper revision reads (#3602)
add e487ba381 refactor: use GenericException from dubbo-go-hessian2 (#3498)
add b12066608 feat(generic): validate generic mode and clarify config API
(#3500)
add e94fa7ea3 fix(generic): reject unsupported generic modes in filters
(#3501)
add 46026183c fix(filter, registry): close access log files on error paths
(#3561)
add 51154987a feat(tools): add benchmark suite for Dubbo-Go, Dubbo-Java
and gRPC (#3502)
add c7452e174 feat(triple): add server http3 quic config helper (#3299)
add 973a60827 chore(doc): Update copyright year in NOTICE file (#3593)
add 62476d510 fix(filter, protocol, registry, config_center): guard unsafe
type assertions (#3563)
add a350e10d5 docs(metrics): document RPC error classifier categories
(#3603)
add 0d06f3be9 chore(triple): clean up draft TODOs and unify comment style
in the triple link (#3607)
add f2ec52e4c fix: correct inverted guard in
WithRegistryIDs/WithProtocolIDs (#3604)
add 5f9deabac test(openAPI): add golden tests for
protoc-gen-triple-openapi (#3606)
add 0a0ce0963 docs(protocol): unify protocol option comments (#3610)
add 115af01da fix(openapi): generate enum components and map value schemas
(#3609)
add b2ab70e49 chore(global): global config formatting (#3616)
add ee88f77d4 feat(metadata): add descriptions for GetMethods(),
GetParams() and NewServiceInfoWithURL() (#3619)
add d39c99722 fix(protocol/triple): handle ParseDuration error for
keepalive config (#3622)
add 2edb07e42 test(protocol/triple): add unit tests for hessian2Codec and
msgpackCodec (#3627)
add e50cfc62f feat(openapi): generate descriptions from proto comments
(#3630)
add 8b14fdadc fix(protocol/triple): return standard errors in SetHeader,
SetTrailer, SendHeader (#3633)
add 4649e8592 fix: make lifecycle waits cancellable (#3599)
add b6dc2352d fix: subscribe provided-by applications initially (#3623)
add e506f0d4a fix(config_center/nacos): remove unused context.WithCancel
and call CancelListenConfig on last listener removal (#3441)
add 39eeb2bda fix(protocol, registry, remoting, graceful_shutdown): handle
ignored errors across rpc paths (#3574)
add 755f48efc feature(triple): support bean generic mode and retain
protobuf compatibility (#3507)
add e1bd4e817 fix(triple): guard httpSrv/http3Srv access with atomic
pointers (#3639)
add e373d9d66 feat(openapi): support oneof fields for
protoc-gen-triple-openapi (#3637)
add 910b3895d Refactor/triple comments helpers (#3643)
add fc7a3ca99 docs: improve functional option API comments (#3642)
add 81abe9ddb Fix(generic): complete typed result and generic mode
handling (#3618)
add 387ea9adc Merge branch 'main' into develop
No new revisions were added by this update.
Summary of changes:
NOTICE | 2 +-
README.md | 9 +-
README_CN.md | 1 +
client/client.go | 18 +-
client/client_test.go | 114 ++++++
client/options.go | 322 ++++++++++++++--
client/options_test.go | 17 +
cluster/cluster/failback/cluster_invoker.go | 242 +++++++++---
cluster/cluster/failback/cluster_test.go | 251 +++++++++++++
config_center/apollo/impl.go | 6 +-
config_center/apollo/impl_test.go | 18 +-
config_center/nacos/impl.go | 3 +-
config_center/nacos/listener.go | 111 +++++-
config_center/nacos/listener_concurrency_test.go | 316 ++++++++++++++++
config_center/nacos/listener_test.go | 42 ++-
filter/accesslog/file_handle_test.go | 138 +++++++
filter/accesslog/filter.go | 58 +--
filter/accesslog/filter_test.go | 27 ++
filter/generic/filter.go | 59 +--
filter/generic/filter_test.go | 404 ++++++++++++++++++++-
filter/generic/generalizer/bean.go | 3 +
filter/generic/generalizer/gson.go | 4 +
filter/generic/generalizer/gson_test.go | 4 +-
filter/generic/service.go | 51 ++-
filter/generic/service_filter.go | 29 +-
filter/generic/service_filter_test.go | 136 ++++++-
filter/generic/service_test.go | 121 ++++++
filter/generic/util.go | 149 +++++++-
filter/generic/util_test.go | 45 ++-
global/client_protocol_config.go | 3 +-
global/config_test.go | 57 ++-
global/http3_config.go | 32 +-
global/protocol_config.go | 7 +-
global/triple_config.go | 21 +-
go.mod | 2 +-
go.sum | 13 +-
graceful_shutdown/shutdown.go | 3 +-
internal/config.go | 31 ++
internal/config_test.go | 32 ++
metadata/info/metadata_info.go | 11 +
metrics/rpc/error_classifier.go | 63 ++++
protocol/dubbo/dubbo_codec.go | 24 +-
protocol/dubbo/dubbo_codec_test.go | 28 ++
.../hessian2/generic_exception_compat_test.go | 67 ++++
protocol/dubbo/hessian2/hessian_dubbo.go | 2 +-
protocol/dubbo/hessian2/hessian_request.go | 66 ++--
protocol/dubbo/hessian2/hessian_request_test.go | 48 +++
protocol/dubbo/hessian2/hessian_response.go | 27 +-
protocol/dubbo/impl/hessian.go | 156 +++++---
protocol/dubbo/impl/hessian_test.go | 39 +-
protocol/dubbo3/dubbo3_protocol_test.go | 6 +-
protocol/grpc/grpc_invoker.go | 9 +-
protocol/grpc/grpc_invoker_test.go | 28 ++
protocol/options.go | 59 ++-
protocol/triple/client.go | 67 ++--
protocol/triple/client_test.go | 4 +-
protocol/triple/dubbo3_invoker.go | 13 +-
protocol/triple/server.go | 132 ++++---
protocol/triple/server_test.go | 4 +-
protocol/triple/triple.go | 18 +-
protocol/triple/triple_protocol/codec_test.go | 234 +++++++++++-
protocol/triple/triple_protocol/handler.go | 47 ++-
protocol/triple/triple_protocol/header.go | 9 +-
protocol/triple/triple_protocol/http3_config.go | 64 ++++
protocol/triple/triple_protocol/server.go | 81 +++--
.../triple_protocol/server_lifecycle_test.go | 344 ++++++++++++++++++
protocol/triple/triple_protocol/server_test.go | 78 +++-
protocol/triple/triple_test.go | 9 +-
registry/base_registry.go | 58 ++-
registry/base_registry_test.go | 208 +++++++++++
registry/directory/directory.go | 132 +++++--
registry/directory/directory_test.go | 45 +++
registry/nacos/listener.go | 4 +-
registry/protocol/protocol.go | 79 +++-
registry/protocol/protocol_test.go | 42 +++
.../servicediscovery/service_discovery_registry.go | 17 +-
.../service_discovery_registry_test.go | 102 ++++++
registry/servicediscovery/store/cache_manager.go | 5 +-
.../store/cache_manager_fd_test.go | 61 ++--
remoting/getty/config.go | 10 +-
remoting/getty/getty_client.go | 123 ++++---
remoting/getty/getty_client_test.go | 144 ++++++++
remoting/getty/pool.go | 49 ++-
remoting/polaris/parser/parser.go | 5 +-
server/options.go | 316 +++++++++++++++-
server/options_test.go | 4 +-
tools/benchmark/README.md | 299 +++++++++++++++
tools/benchmark/README_CN.md | 299 +++++++++++++++
tools/benchmark/client/clients/dubbo_client.go | 112 ++++++
tools/benchmark/client/clients/grpc_client.go | 96 +++++
tools/benchmark/client/engine/engine.go | 125 +++++++
tools/benchmark/client/engine/metrics.go | 87 +++++
tools/benchmark/client/engine/statistics.go | 110 ++++++
tools/benchmark/client/main.go | 344 ++++++++++++++++++
tools/benchmark/client/monitor/system_monitor.go | 195 ++++++++++
.../benchmark/client/payload/payload.go | 56 +--
.../build/Dockerfile => benchmark/config.yaml} | 42 ++-
tools/benchmark/proto/benchmark.pb.go | 194 ++++++++++
.../proto/benchmark.proto} | 28 +-
tools/benchmark/proto/benchmark.triple.go | 209 +++++++++++
tools/benchmark/proto/benchmark_grpc.pb.go | 170 +++++++++
tools/benchmark/scripts/gen_code.sh | 57 +++
tools/benchmark/scripts/run_all.sh | 178 +++++++++
tools/benchmark/scripts/run_single.sh | 139 +++++++
tools/benchmark/server/dubbo-go/main.go | 122 +++++++
tools/benchmark/server/dubbo-java/pom.xml | 109 ++++++
.../apache/dubbo/benchmark/BenchmarkRequest.java | 23 +-
.../apache/dubbo/benchmark/BenchmarkResponse.java | 23 +-
.../apache/dubbo/benchmark/BenchmarkServer.java | 41 +++
.../apache/dubbo/benchmark/BenchmarkService.java} | 7 +-
.../dubbo/benchmark/BenchmarkServiceImpl.java | 19 +-
.../src/main/resources/application.properties | 7 +
tools/benchmark/server/grpc/main.go | 101 ++++++
.../protoc-gen-triple-openapi/example/greet.proto | 29 ++
.../example/greet.triple.openapi.json | 169 ++++++++-
.../example/greet.triple.openapi.yaml | 110 ++++++
.../internal/converter/components.go | 11 +-
.../internal/converter/convert.go | 18 +-
.../internal/converter/convert_test.go | 384 ++++++++++++++++++++
.../internal/converter/schema/schema.go | 40 +-
.../internal/converter/schema/util.go | 86 ++++-
121 files changed, 9232 insertions(+), 849 deletions(-)
create mode 100644 config_center/nacos/listener_concurrency_test.go
create mode 100644 filter/accesslog/file_handle_test.go
create mode 100644 protocol/dubbo/hessian2/generic_exception_compat_test.go
create mode 100644 protocol/triple/triple_protocol/http3_config.go
create mode 100644 protocol/triple/triple_protocol/server_lifecycle_test.go
create mode 100644 registry/base_registry_test.go
copy tools/protoc-gen-triple-openapi/main.go =>
registry/servicediscovery/store/cache_manager_fd_test.go (50%)
create mode 100644 tools/benchmark/README.md
create mode 100644 tools/benchmark/README_CN.md
create mode 100644 tools/benchmark/client/clients/dubbo_client.go
create mode 100644 tools/benchmark/client/clients/grpc_client.go
create mode 100644 tools/benchmark/client/engine/engine.go
create mode 100644 tools/benchmark/client/engine/metrics.go
create mode 100644 tools/benchmark/client/engine/statistics.go
create mode 100644 tools/benchmark/client/main.go
create mode 100644 tools/benchmark/client/monitor/system_monitor.go
copy logger/logger.go => tools/benchmark/client/payload/payload.go (50%)
copy tools/{dubbogo-cli/cmd/testGenCode/template/newApp/build/Dockerfile =>
benchmark/config.yaml} (64%)
create mode 100644 tools/benchmark/proto/benchmark.pb.go
copy
tools/{protoc-gen-go-triple/test/correctly/multiple_services/proto/greet.proto
=> benchmark/proto/benchmark.proto} (60%)
create mode 100644 tools/benchmark/proto/benchmark.triple.go
create mode 100644 tools/benchmark/proto/benchmark_grpc.pb.go
create mode 100755 tools/benchmark/scripts/gen_code.sh
create mode 100755 tools/benchmark/scripts/run_all.sh
create mode 100755 tools/benchmark/scripts/run_single.sh
create mode 100644 tools/benchmark/server/dubbo-go/main.go
create mode 100644 tools/benchmark/server/dubbo-java/pom.xml
copy
protocol/triple/triple_protocol/internal/proto/triple/collide/v1/collide.proto
=>
tools/benchmark/server/dubbo-java/src/main/java/org/apache/dubbo/benchmark/BenchmarkRequest.java
(64%)
copy
protocol/triple/triple_protocol/internal/proto/triple/collide/v1/collide.proto
=>
tools/benchmark/server/dubbo-java/src/main/java/org/apache/dubbo/benchmark/BenchmarkResponse.java
(64%)
create mode 100644
tools/benchmark/server/dubbo-java/src/main/java/org/apache/dubbo/benchmark/BenchmarkServer.java
copy tools/{protoc-gen-go-triple/gen/generator/gen.go =>
benchmark/server/dubbo-java/src/main/java/org/apache/dubbo/benchmark/BenchmarkService.java}
(80%)
copy common/extension/config.go =>
tools/benchmark/server/dubbo-java/src/main/java/org/apache/dubbo/benchmark/BenchmarkServiceImpl.java
(67%)
create mode 100644
tools/benchmark/server/dubbo-java/src/main/resources/application.properties
create mode 100644 tools/benchmark/server/grpc/main.go
create mode 100644
tools/protoc-gen-triple-openapi/internal/converter/convert_test.go
