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 e6e14fd30 Set up default protection ruleset for default and release
branches (#3325)
add 6ac4bbbdf fix(config): remove legacy protocol timeout fallback (#3326)
add b03a7c794 Fix(config center)apollo context path error (#3331)
add 737b7f2ad fix(logger): sync dubbo-go logger facade during logger
initialization (#3345)
add fd79da266 Refactor/logger format finish (#3346)
add 48ec2ac2f feat: complete local app metadata lifecycle (#3357)
add a3428bbc5 docs: refresh outdated entries in filter README (#3365)
add 6dcf83539 build(deps): bump github.com/quic-go/quic-go from 0.52.0 to
0.59.1 (#3368)
add b19d5b4b9 Update Codecov action to version 7 (#3375)
add 38520f3e3 fix(common): omit trailing ? in URL.String() without query
params (#3328)
add 6c49e65a0 docs(triple): document header and trailer usage (#3380)
add dde23ab2a docs(generic): explain response attachment access (#3381)
add 8e96ea3de test(hessian2): cover pointer long response fields (#3382)
add f23f29b20 refactor(url): clarify append param API (#3390)
add e17b91ce1 [Enhancement] remove legacy config package (#3372)
add 60dfab6c5 test(triple): allow invalid stream send close errors (#3379)
add cdf6f2f8b feat(metadata): strengthen service-app mapping consistency,
retry and… (#3373)
add fc7f14f35 feat(metadata): Clarify metadata report selection for
multi-registry and multi-instance scenarios (#3369)
add ab00bd408 feat(router): add router chain snapshot cache (#3305)
add d44bc1894 [FEAT] delete synthesizer logic (#3360)
add c26a24ce8 [doc] update readme farmework pic (#3358)
add e1031b70d Feat/revision canonical metadata (#3370)
add 5774b3d4e fix(metadata): preserve application tag in metadata info
(#3400)
add 1ce8314a0 Feat: add benchmarks for common.URL (#3399)
add f7f350cfe perf(common): reduce URL CloneWithFilter and MergeURL params
copying (#3403)
add a7b6ee632 perf(common): optimize URL.String() locking and string
building (#3404)
No new revisions were added by this update.
Summary of changes:
.github/workflows/github-actions.yml | 2 +-
client/action.go | 4 +-
.../consistenthashing/loadbalance_test.go | 2 +-
cluster/router/affinity/router.go | 8 +-
cluster/router/chain/cache.go | 100 +++++++
cluster/router/chain/chain.go | 42 ++-
cluster/router/chain/chain_test.go | 134 +++++++++
cluster/router/condition/dynamic_router.go | 14 +-
cluster/router/router.go | 15 +-
cluster/router/script/router.go | 6 +-
cluster/router/tag/cache.go | 213 ++++++++++++++
cluster/router/tag/cache_benchmarks_test.go | 219 ++++++++++++++
cluster/router/tag/match.go | 2 +-
cluster/router/tag/router.go | 21 ++
cluster/router/tag/router_test.go | 286 ++++++++++++++++++
common/config/utils.go | 72 +++++
common/config/utils_test.go | 60 ++++
common/constant/key.go | 8 +
common/url.go | 254 ++++++++++------
common/url_benchmark_test.go | 320 ++++++++++++++++++++
common/url_test.go | 85 +++++-
config/config_loader.go | 6 +-
config/logger_config.go | 12 +-
config/logger_config_test.go | 46 +++
config/reference_config.go | 7 +-
config/reference_config_test.go | 14 +
config/registry_config.go | 2 +-
config/service_config.go | 6 +-
config/service_config_test.go | 40 +++
config_center/apollo/impl.go | 6 +-
config_center/apollo/impl_test.go | 53 ++++
config_center/nacos/impl.go | 2 +-
doc/imgs/arc.png | Bin 2068065 -> 574194
bytes
filter/README.md | 52 +++-
global/consumer_config.go | 4 +-
go.mod | 11 +-
go.sum | 22 +-
graceful_shutdown/closing_registry.go | 4 +-
graceful_shutdown/common.go | 2 +-
graceful_shutdown/shutdown.go | 48 +--
instance_options_init.go | 38 +--
internal/config.go | 4 +-
loader.go | 30 +-
metadata/client.go | 23 +-
metadata/client_test.go | 80 ++++-
metadata/info/metadata_info.go | 126 +++++++-
metadata/info/metadata_info_test.go | 56 +++-
metadata/mapping/metadata/service_name_mapping.go | 100 ++++++-
.../service_name_mapping_concurrency_test.go | 223 ++++++++++++++
.../mapping/metadata/service_name_mapping_test.go | 112 ++++++-
metadata/metadata.go | 16 +
metadata/metadata_service.go | 5 +-
metadata/metadata_service_test.go | 29 ++
metadata/metadata_test.go | 41 +++
metadata/options.go | 6 +-
metadata/report/etcd/report.go | 38 ++-
metadata/report/mapping.go | 87 ++++++
metadata/report/mapping_test.go | 66 +++++
metadata/report/nacos/report.go | 81 +++--
metadata/report/zookeeper/listener.go | 19 +-
metadata/report/zookeeper/listener_test.go | 26 ++
metadata/report/zookeeper/report.go | 34 ++-
metadata/report/zookeeper/report_test.go | 22 +-
metadata/report_instance.go | 44 ++-
metadata/report_instance_test.go | 56 +++-
.../triple_api/proto/metadata_service_v2.pb.go | 107 +++----
.../triple_api/proto/metadata_service_v2.proto | 1 +
metrics/api.go | 2 +-
metrics/probe/server.go | 8 +-
metrics/prometheus/registry.go | 16 +-
metrics/rpc/collector.go | 2 +-
metrics/rpc/util.go | 4 +-
options.go | 4 +-
otel/trace/exporter.go | 4 +-
protocol/base/base_exporter.go | 2 +-
protocol/base/base_invoker.go | 2 +-
protocol/base/rpc_status.go | 8 +-
protocol/dubbo/dubbo_codec.go | 14 +-
protocol/dubbo/dubbo_exporter.go | 2 +-
protocol/dubbo/dubbo_invoker.go | 14 +-
protocol/dubbo/dubbo_invoker_test.go | 46 +++
protocol/dubbo/dubbo_protocol.go | 10 +-
protocol/dubbo/hessian2/hessian_dubbo_test.go | 22 ++
protocol/dubbo/hessian2/hessian_request.go | 10 +-
protocol/dubbo/hessian2/hessian_response.go | 4 +-
protocol/dubbo/impl/codec.go | 6 +-
protocol/dubbo/impl/hessian.go | 2 +-
protocol/dubbo3/dubbo3_exporter.go | 2 +-
protocol/dubbo3/dubbo3_invoker.go | 16 +-
protocol/dubbo3/dubbo3_protocol.go | 20 +-
protocol/grpc/client.go | 14 +-
protocol/grpc/grpc_exporter.go | 2 +-
protocol/grpc/grpc_invoker.go | 6 +-
protocol/grpc/grpc_protocol.go | 8 +-
protocol/grpc/server.go | 10 +-
protocol/jsonrpc/http.go | 2 +-
protocol/jsonrpc/jsonrpc_exporter.go | 2 +-
protocol/jsonrpc/jsonrpc_invoker.go | 2 +-
protocol/jsonrpc/jsonrpc_protocol.go | 15 +-
protocol/jsonrpc/jsonrpc_protocol_test.go | 42 ++-
protocol/jsonrpc/server.go | 30 +-
.../protocolwrapper/protocol_filter_wrapper.go | 4 +-
protocol/rest/config/reader/rest_config_reader.go | 16 +-
protocol/rest/rest_exporter.go | 2 +-
protocol/rest/rest_protocol.go | 4 +-
protocol/rest/server/rest_server.go | 28 +-
.../rest/server/server_impl/go_restful_server.go | 8 +-
protocol/triple/client.go | 8 +-
protocol/triple/dual_transport.go | 18 +-
protocol/triple/dubbo3_invoker.go | 8 +-
protocol/triple/health/healthServer.go | 2 +-
protocol/triple/openapi/integration.go | 2 +-
protocol/triple/openapi/service.go | 2 +-
protocol/triple/options.go | 2 +-
protocol/triple/server.go | 18 +-
protocol/triple/triple.go | 12 +-
protocol/triple/triple_exporter.go | 2 +-
protocol/triple/triple_invoker.go | 6 +-
protocol/triple/triple_protocol/cors.go | 6 +-
protocol/triple/triple_protocol/envelope.go | 4 +-
protocol/triple/triple_protocol/handler_compat.go | 4 +-
protocol/triple/triple_protocol/header.go | 102 +++++--
protocol/triple/triple_protocol/negotiation.go | 4 +-
protocol/triple/triple_protocol/protocol_triple.go | 4 +-
protocol/triple/triple_protocol/server.go | 6 +-
protocol/triple/triple_protocol/triple_ext_test.go | 5 +-
proxy/proxy.go | 14 +-
proxy/proxy_factory/default.go | 6 +-
proxy/proxy_factory/pass_through.go | 2 +-
registry/base_configuration_listener.go | 6 +-
registry/base_registry.go | 36 +--
registry/directory/directory.go | 165 +++++------
registry/directory/directory_test.go | 175 +++++++++++
registry/etcdv3/listener.go | 10 +-
registry/etcdv3/registry.go | 2 +-
registry/etcdv3/service_discovery.go | 8 +-
registry/exposed_tmp/exposed.go | 4 +-
registry/mock_registry.go | 6 +-
registry/nacos/listener.go | 12 +-
registry/nacos/registry.go | 34 +--
registry/nacos/service_discovery.go | 22 +-
registry/nacos/service_discovery_test.go | 2 +-
registry/polaris/listener.go | 10 +-
registry/polaris/registry.go | 14 +-
registry/polaris/service_discovery.go | 8 +-
registry/protocol/protocol.go | 214 +++++++-------
registry/protocol/protocol_test.go | 218 +++++++++++++-
registry/service_instance.go | 4 +-
.../metadata_service_url_params_customizer.go | 7 +-
.../metadata_service_version_customizer.go | 2 +-
.../protocol_ports_metadata_customizer.go | 6 +-
.../customizer/service_revision_customizer.go | 69 +++--
.../customizer/service_revision_customizer_test.go | 325 +++++++++++++++++++++
.../servicediscovery/service_discovery_registry.go | 117 ++++++--
.../service_discovery_registry_test.go | 220 +++++++++++++-
.../service_instances_changed_listener_impl.go | 30 +-
...service_instances_changed_listener_impl_test.go | 129 +++++++-
.../service_mapping_change_listener_impl.go | 2 +-
registry/servicediscovery/store/cache_manager.go | 8 +-
.../rest/rest_subscribed_urls_synthesizer.go | 61 ----
.../rest/rest_subscribed_urls_synthesizer_test.go | 75 -----
.../synthesizer/subscribed_urls_synthesizer.go | 31 --
.../subscribed_urls_synthesizer_factory.go | 41 ---
registry/zookeeper/listener.go | 10 +-
registry/zookeeper/registry.go | 8 +-
registry/zookeeper/service_discovery.go | 14 +-
remoting/etcdv3/client.go | 6 +-
remoting/etcdv3/facade.go | 2 +-
remoting/etcdv3/listener.go | 44 +--
remoting/exchange.go | 2 +-
remoting/exchange_client.go | 4 +-
remoting/getty/getty_client.go | 22 +-
remoting/getty/getty_server.go | 22 +-
remoting/getty/listener.go | 52 ++--
remoting/getty/pool.go | 26 +-
remoting/getty/readwriter.go | 20 +-
remoting/nacos/builder.go | 2 +-
remoting/polaris/parser/parser.go | 6 +-
remoting/zookeeper/client.go | 4 +-
.../curator_discovery/service_discovery.go | 18 +-
remoting/zookeeper/facade.go | 2 +-
remoting/zookeeper/listener.go | 78 ++---
server/action.go | 16 +-
server/options.go | 4 +-
server/server.go | 18 +-
185 files changed, 5371 insertions(+), 1408 deletions(-)
create mode 100644 cluster/router/chain/cache.go
create mode 100644 cluster/router/tag/cache.go
create mode 100644 cluster/router/tag/cache_benchmarks_test.go
create mode 100644 common/url_benchmark_test.go
create mode 100644
metadata/mapping/metadata/service_name_mapping_concurrency_test.go
create mode 100644 metadata/report/mapping.go
create mode 100644 metadata/report/mapping_test.go
create mode 100644
registry/servicediscovery/customizer/service_revision_customizer_test.go
delete mode 100644
registry/servicediscovery/synthesizer/rest/rest_subscribed_urls_synthesizer.go
delete mode 100644
registry/servicediscovery/synthesizer/rest/rest_subscribed_urls_synthesizer_test.go
delete mode 100644
registry/servicediscovery/synthesizer/subscribed_urls_synthesizer.go
delete mode 100644
registry/servicediscovery/synthesizer/subscribed_urls_synthesizer_factory.go
