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 8b5bbcf19 [config] Decouple config reader and remove config package
(#3449)
add 706090f7e feat(service-discovery): 稳定应用级服务发现使用的元数据key (#3362)
add c7459997f feat(metadata): add concurrency safety for application-level
metadata state (#3353) (#3367)
add c8add4bb6 feat(metadata): add renew and GC policy for app-level
metadata (#3371)
add 9c955e957 test(triple): add concurrent send/close guards for
duplexHTTPCall (#3462)
add 630393dad fix(triple_protocol): replace Buf Technologies license
header with ASF header (#3464)
add 6f95e3446 build(deps): bump golang.org/x/net from 0.52.0 to 0.55.0
(#3467)
add 9c5f8203f fix(triple): make stream response close non-blocking (#3466)
add 17c747867 fix(otel): fix metadataSupplier Get/Set type mismatch
breaking trace propagation (#3433)
add 5683612b1 fix: remove stale providers after initial subscribe load
(#3479)
No new revisions were added by this update.
Summary of changes:
common/constant/key.go | 5 +
filter/otel/trace/attachment.go | 17 +-
filter/otel/trace/attachment_test.go | 40 +-
go.mod | 12 +-
go.sum | 24 +-
metadata/info/metadata_info.go | 84 +++-
metadata/info/metadata_info_test.go | 21 +
.../service_name_mapping_concurrency_test.go | 6 +
.../mapping/metadata/service_name_mapping_test.go | 15 +
metadata/metadata.go | 27 +-
metadata/metadata_service.go | 8 +-
metadata/metadata_service_test.go | 33 ++
metadata/metadata_test.go | 34 ++
metadata/report/etcd/report.go | 66 ++-
metadata/report/etcd/report_test.go | 548 ++++++++++-----------
metadata/report/nacos/report.go | 72 ++-
metadata/report/nacos/report_test.go | 118 ++++-
metadata/report/report.go | 31 ++
metadata/report/zookeeper/report.go | 80 ++-
metadata/report/zookeeper/report_test.go | 303 +++++++++++-
metadata/report_instance.go | 31 +-
metadata/report_instance_test.go | 52 ++
protocol/triple/triple_protocol/Makefile | 13 +-
protocol/triple/triple_protocol/bench_test.go | 29 +-
protocol/triple/triple_protocol/buffer_pool.go | 29 +-
protocol/triple/triple_protocol/client.go | 29 +-
.../triple/triple_protocol/client_example_test.go | 29 +-
protocol/triple/triple_protocol/client_ext_test.go | 29 +-
protocol/triple/triple_protocol/client_stream.go | 29 +-
.../triple/triple_protocol/client_stream_test.go | 29 +-
protocol/triple/triple_protocol/code.go | 29 +-
protocol/triple/triple_protocol/code_test.go | 29 +-
protocol/triple/triple_protocol/codec.go | 29 +-
protocol/triple/triple_protocol/codec_test.go | 29 +-
.../triple/triple_protocol/codec_wrapper_test.go | 29 +-
protocol/triple/triple_protocol/compression.go | 29 +-
.../triple/triple_protocol/compression_test.go | 29 +-
.../triple/triple_protocol/duplex_http_call.go | 40 +-
.../triple_protocol/duplex_http_call_test.go | 274 +++++++++++
protocol/triple/triple_protocol/envelope.go | 29 +-
protocol/triple/triple_protocol/envelope_test.go | 29 +-
protocol/triple/triple_protocol/error.go | 29 +-
.../triple/triple_protocol/error_example_test.go | 29 +-
protocol/triple/triple_protocol/error_test.go | 29 +-
protocol/triple/triple_protocol/error_writer.go | 29 +-
.../triple_protocol/error_writer_example_test.go | 29 +-
.../triple/triple_protocol/example_init_test.go | 29 +-
protocol/triple/triple_protocol/handler.go | 29 +-
.../triple/triple_protocol/handler_example_test.go | 29 +-
.../triple/triple_protocol/handler_ext_test.go | 29 +-
protocol/triple/triple_protocol/handler_stream.go | 29 +-
protocol/triple/triple_protocol/header.go | 29 +-
protocol/triple/triple_protocol/header_test.go | 29 +-
.../triple/triple_protocol/idempotency_level.go | 29 +-
protocol/triple/triple_protocol/interceptor.go | 29 +-
.../triple_protocol/interceptor_example_test.go | 29 +-
.../triple/triple_protocol/interceptor_ext_test.go | 29 +-
.../triple_protocol/internal/assert/assert.go | 29 +-
.../triple_protocol/internal/assert/assert_test.go | 29 +-
.../gen/proto/connect/collide/v1/collide.pb.go | 29 +-
.../gen/proto/connect/import/v1/import.pb.go | 29 +-
.../import/v1/importv1connect/import.connect.go | 29 +-
.../internal/gen/proto/connect/ping/v1/ping.pb.go | 29 +-
.../connect/ping/v1/pingv1connect/ping.connect.go | 29 +-
.../proto/connectext/grpc/status/v1/status.pb.go | 29 +-
.../proto/connectext/grpc/status/v1/status.pb.go | 29 +-
.../proto/connectext/grpc/status/v1/status.proto | 29 +-
.../internal/proto/triple/collide/v1/collide.proto | 29 +-
.../internal/proto/triple/import/v1/import.proto | 29 +-
.../internal/proto/triple/ping/v1/ping.proto | 29 +-
protocol/triple/triple_protocol/maxbytes.go | 29 +-
protocol/triple/triple_protocol/option.go | 29 +-
protocol/triple/triple_protocol/protobuf_util.go | 29 +-
.../triple/triple_protocol/protobuf_util_test.go | 29 +-
protocol/triple/triple_protocol/protocol.go | 29 +-
protocol/triple/triple_protocol/protocol_grpc.go | 29 +-
.../triple/triple_protocol/protocol_grpc_test.go | 29 +-
protocol/triple/triple_protocol/protocol_test.go | 29 +-
protocol/triple/triple_protocol/protocol_triple.go | 29 +-
.../triple/triple_protocol/protocol_triple_test.go | 29 +-
protocol/triple/triple_protocol/recover.go | 29 +-
.../triple/triple_protocol/recover_ext_test.go | 29 +-
.../triple_protocol/stream_close_ext_test.go | 251 ++++++++++
protocol/triple/triple_protocol/triple.go | 29 +-
protocol/triple/triple_protocol/triple_ext_test.go | 30 +-
registry/nacos/listener.go | 27 +-
registry/nacos/registry.go | 40 +-
registry/nacos/registry_test.go | 155 +++++-
.../servicediscovery/service_discovery_registry.go | 189 ++++++-
.../service_discovery_registry_test.go | 341 +++++++++++++
.../service_instances_changed_listener_impl.go | 7 +-
...service_instances_changed_listener_impl_test.go | 24 +
92 files changed, 3539 insertions(+), 1161 deletions(-)
create mode 100644 protocol/triple/triple_protocol/duplex_http_call_test.go
create mode 100644 protocol/triple/triple_protocol/stream_close_ext_test.go
