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 b87881aa2 fix: generate dependency locks for CLI scaffolds (#3483)
add c1db7f18e chore(style): modernize the code style (#3471)
add 1360af3fe style: clean up minor review issues (#3484)
add bcd6aa42b fix triple unary response metadata (#3446)
add e2eb0c451 perf(common): optimize IsEquals and ToMap to reduce
allocations (#3488)
add 110bd656c fix(polaris): reconcile initial subscribe snapshot (#3482)
add 0f71ba09e fix(cluster): eliminate data race on StickyInvoker with
atomic.Value (#3439)
add 5e87b0673 fix(registry): add lock protection for serviceListeners map
access (#3442)
add 53d81d17c chore: prepare the release for version 3.3.2 (#3469)
No new revisions were added by this update.
Summary of changes:
Makefile | 5 +-
client/action.go | 5 +-
client/client.go | 5 +-
client/options.go | 7 +-
cluster/cluster/base/cluster_invoker.go | 57 +-
cluster/cluster/base/cluster_invoker_test.go | 91 +-
cluster/cluster/broadcast/cluster_invoker_test.go | 6 +-
cluster/cluster/failback/cluster_test.go | 16 +-
cluster/cluster/failover/cluster_invoker_test.go | 6 +-
cluster/cluster/failover/cluster_test.go | 4 +-
cluster/cluster/forking/cluster_invoker.go | 2 +-
cluster/cluster/forking/cluster_test.go | 6 +-
cluster/cluster/interceptor_invoker.go | 9 +-
cluster/cluster/zoneaware/cluster_invoker_test.go | 10 +-
cluster/directory/static/directory_test.go | 4 +-
cluster/loadbalance/consistenthashing/selector.go | 2 +-
cluster/loadbalance/iwrr/iwrr.go | 7 +-
cluster/loadbalance/leastactive/loadbalance.go | 2 +-
cluster/loadbalance/loadbalance_benchmarks_test.go | 8 +-
cluster/loadbalance/random/loadbalance_test.go | 8 +-
cluster/loadbalance/roundrobin/loadbalance.go | 8 +-
cluster/router/chain/chain_test.go | 28 +-
cluster/router/condition/dynamic_router.go | 2 +-
cluster/router/condition/route.go | 8 +-
cluster/router/condition/router_test.go | 2 +-
cluster/router/polaris/router.go | 4 +-
cluster/router/script/instance/js_instance_test.go | 4 +-
cluster/router/tag/cache_benchmarks_test.go | 2 +-
common/config/environment.go | 4 +-
common/constant/key.go | 15 +-
common/constant/version.go | 4 +-
common/extension/concurrency_guards_test.go | 2 +-
common/extension/registry_type.go | 5 +-
common/extension/registry_type_test.go | 4 +-
common/match.go | 2 +-
common/rpc_service.go | 6 +-
common/rpc_service_test.go | 36 +-
common/url.go | 233 ++-
common/url_benchmark_test.go | 20 +-
common/url_test.go | 128 +-
config_center/file/impl.go | 5 +-
config_center/zookeeper/listener.go | 4 +-
filter/accesslog/memory_leak_test.go | 2 +-
filter/adaptivesvc/limiter/hill_climbing_test.go | 2 +-
filter/generic/filter.go | 2 +-
filter/generic/generalizer/bean.go | 6 +-
filter/generic/generalizer/bean_test.go | 12 +-
filter/generic/generalizer/gson_test.go | 4 +-
filter/generic/generalizer/map.go | 6 +-
filter/generic/generalizer/map_test.go | 10 +-
filter/generic/generalizer/protobuf_json.go | 2 +-
filter/generic/generalizer/protobuf_json_test.go | 4 +-
filter/generic/service_filter.go | 15 +-
filter/generic/util.go | 2 +-
filter/sentinel/filter_test.go | 6 +-
global/config_center_config.go | 8 +-
global/config_test.go | 4 +-
global/custom_config.go | 8 +-
global/metadata_report_config.go | 8 +-
global/openapi_config.go | 5 +-
global/protocol_config.go | 6 +-
global/provider_config.go | 12 +-
global/reference_config.go | 28 +-
global/registry_config.go | 5 +-
global/router_config.go | 4 +-
global/service_config.go | 8 +-
go.mod | 16 +-
go.sum | 31 +-
graceful_shutdown/shutdown.go | 5 +-
graceful_shutdown/shutdown_test.go | 2 +-
integrate_test.sh | 8 +-
internal/config.go | 8 +-
loader.go | 16 +-
metadata/info/metadata_info.go | 7 +-
metadata/mapping/metadata/service_name_mapping.go | 2 +-
.../service_name_mapping_concurrency_test.go | 15 +-
metadata/metadata_service_test.go | 26 +-
metadata/metadata_test.go | 2 +-
metadata/report/mapping.go | 9 +-
metadata/report/zookeeper/listener_test.go | 2 +-
metrics/api_test.go | 6 +-
metrics/common_test.go | 2 +-
metrics/probe/probe.go | 5 +-
metrics/prometheus/registry_test.go | 61 +-
metrics/prometheus/rt_vec_test.go | 8 +-
metrics/util/aggregate/aggregator_test.go | 10 +-
protocol/base/base_protocol_test.go | 17 +-
protocol/base/rpc_status.go | 54 +-
protocol/base/rpc_status_test.go | 74 +-
protocol/compat.go | 28 +-
protocol/dubbo/dubbo_codec_test.go | 7 +-
protocol/dubbo/dubbo_invoker_test.go | 4 +-
protocol/dubbo/dubbo_protocol.go | 2 +-
protocol/dubbo/hessian2/const.go | 2 +-
protocol/dubbo/hessian2/hessian_request.go | 2 +-
protocol/dubbo/hessian2/hessian_response.go | 10 +-
protocol/dubbo/hessian2/hessian_response_test.go | 5 +-
protocol/dubbo/hessian2/java_class.go | 2 +-
protocol/dubbo/impl/const.go | 2 +-
protocol/dubbo/impl/hessian.go | 4 +-
protocol/dubbo/impl/hessian_test.go | 10 +-
protocol/dubbo/impl/serialization_test.go | 2 +-
protocol/dubbo/impl/serialize_test.go | 10 +-
protocol/dubbo3/doc.go | 3 +
protocol/dubbo3/dubbo3_invoker.go | 5 +-
protocol/dubbo3/dubbo3_protocol.go | 2 +-
protocol/dubbo3/dubbo3_protocol_test.go | 2 +-
protocol/grpc/doc.go | 4 +
protocol/grpc/internal/routeguide/client.go | 2 +-
.../protoc-gen-dubbo/plugin}/dubbo/doc.go | 4 +-
protocol/invocation/rpcinvocation_test.go | 12 +-
protocol/jsonrpc/http_test.go | 16 +-
protocol/jsonrpc/json.go | 2 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 4 +-
protocol/jsonrpc/server.go | 12 +-
protocol/options.go | 2 +-
.../protocolwrapper/protocol_filter_wrapper.go | 5 +-
protocol/rest/config/reader/rest_config_reader.go | 2 +-
protocol/rest/server/rest_server.go | 8 +-
protocol/result/result_test.go | 21 +-
protocol/triple/client.go | 4 +-
protocol/triple/common.go | 1 -
protocol/triple/common_low_version.go | 1 -
protocol/triple/dual_transport_test.go | 21 +-
protocol/triple/dubbo3_invoker.go | 4 +-
protocol/triple/health/health_test.go | 2 +-
protocol/triple/openapi/definition_resolver.go | 6 +-
.../triple/openapi/definition_resolver_test.go | 14 +-
protocol/triple/openapi/handler.go | 8 +-
protocol/triple/openapi/schema_resolver.go | 4 +-
protocol/triple/openapi/schema_resolver_test.go | 70 +-
protocol/triple/openapi/service.go | 9 +-
protocol/triple/openapi/service_test.go | 13 +-
protocol/triple/openapi/swagger_ui_handler.go | 6 +-
protocol/triple/options.go | 5 +-
protocol/triple/reflection/serverreflection.go | 5 +-
protocol/triple/server.go | 15 +-
protocol/triple/server_test.go | 2 +-
protocol/triple/triple_invoker_test.go | 10 +-
protocol/triple/triple_protocol/code.go | 4 +-
protocol/triple/triple_protocol/codec.go | 8 +-
protocol/triple/triple_protocol/codec_test.go | 2 +-
protocol/triple/triple_protocol/compression.go | 5 +-
protocol/triple/triple_protocol/cors.go | 15 +-
protocol/triple/triple_protocol/cors_test.go | 3 -
.../triple_protocol/duplex_http_call_test.go | 24 +-
protocol/triple/triple_protocol/handler.go | 1 +
protocol/triple/triple_protocol/interceptor.go | 5 +-
.../triple_protocol/internal/assert/assert.go | 2 +-
protocol/triple/triple_protocol/maxbytes.go | 1 -
.../triple/triple_protocol/maxbytes_low_version.go | 1 -
protocol/triple/triple_protocol/negotiation.go | 20 +-
protocol/triple/triple_protocol/protocol.go | 8 +-
protocol/triple/triple_protocol/protocol_test.go | 1 -
protocol/triple/triple_protocol/triple_ext_test.go | 48 +-
protocol/triple/triple_test.go | 8 +-
proxy/proxy.go | 10 +-
proxy/proxy_factory/default.go | 6 +-
proxy/proxy_factory/pass_through.go | 2 +-
proxy/proxy_factory/utils_test.go | 7 +-
proxy/proxy_test.go | 4 +-
registry/base_configuration_listener_test.go | 2 +-
registry/directory/directory_test.go | 8 +-
registry/etcdv3/listener.go | 21 +-
registry/nacos/registry.go | 8 +-
registry/nacos/registry_test.go | 14 +-
registry/polaris/core.go | 517 ++++-
registry/polaris/listener.go | 146 +-
registry/polaris/registry.go | 252 ++-
registry/polaris/registry_test.go | 1985 ++++++++++++++++++++
registry/protocol/protocol_race_test.go | 2 +-
registry/registry.go | 6 +-
.../servicediscovery/service_discovery_registry.go | 74 +-
.../service_discovery_registry_test.go | 109 +-
.../service_instances_changed_listener_impl.go | 2 +-
registry/zookeeper/service_discovery.go | 2 +-
remoting/exchange_server_test.go | 2 +-
remoting/exchange_test.go | 5 +-
remoting/getty/config.go | 4 +-
remoting/getty/getty_client_test.go | 2 +-
remoting/getty/pool.go | 6 +-
remoting/getty/pool_test.go | 21 +-
remoting/listener_test.go | 2 +-
remoting/zookeeper/client_test.go | 8 +-
.../curator_discovery/service_discovery_test.go | 10 +-
remoting/zookeeper/listener.go | 13 +-
server/action_test.go | 6 +-
server/options.go | 6 +
server/server.go | 8 +-
server/server_test.go | 6 +-
tls/helper_test.go | 2 +-
tools/dubbogo-cli/internal/common/tool.go | 2 +-
tools/variadicrpccheck/scan.go | 18 +-
193 files changed, 4200 insertions(+), 991 deletions(-)
copy protocol/{ => grpc/protoc-gen-dubbo/plugin}/dubbo/doc.go (85%)
create mode 100644 registry/polaris/registry_test.go
