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 e13ab17e7 feat:add discussions notifications (#2837)
add 5873f36a2 doc: update Contact part of README (#2824)
add 1d1f32a4f fix: update go version & golangci lint (#2830)
add effa9ff35 Merge branch 'develop' of https://github.com/apache/dubbo-go
into develop
add 7923bb210 remove unused fuction (#2846)
add e608f8ff1 Fix: the issue where adding weight to the nacos option fails
(#2843)
add 90a886c7b optimize: replace interface to any (#2848)
No new revisions were added by this update.
Summary of changes:
.github/workflows/github-actions.yml | 4 +-
.github/workflows/golangci-lint.yml | 9 ++-
.golangci.yml | 35 ++++-----
Makefile | 2 +-
client/action.go | 2 +-
client/client.go | 22 +++---
cluster/cluster/zoneaware/cluster_invoker_test.go | 8 +--
.../consistenthashing/loadbalance_test.go | 6 +-
cluster/loadbalance/consistenthashing/selector.go | 2 +-
cluster/loadbalance/p2c/loadbalance_test.go | 2 +-
cluster/loadbalance/roundrobin/loadbalance.go | 2 +-
cluster/metrics/local_metrics.go | 16 ++---
cluster/metrics/metrics.go | 12 ++--
cluster/metrics/mock_metrics.go | 30 ++++----
cluster/router/condition/dynamic_router.go | 4 +-
cluster/router/condition/router_test.go | 10 +--
cluster/router/script/instance/js_instance.go | 6 +-
cluster/router/script/instance/js_instance_test.go | 46 ++++++------
cluster/router/script/router_test.go | 2 +-
cluster/router/tag/match.go | 18 ++---
cluster/router/tag/router_test.go | 18 ++---
common/config/environment.go | 6 +-
common/config/utils.go | 2 +-
common/constant/key.go | 7 ++
common/rpc_service.go | 20 +++---
common/rpc_service_test.go | 10 +--
common/url.go | 18 ++---
config/config_resolver.go | 2 +-
config/config_setter.go | 2 +-
config/config_utils.go | 2 +-
config/consumer_config.go | 4 +-
config/custom_config.go | 10 +--
config/custom_config_test.go | 4 +-
config/generic/generic_service.go | 2 +-
config/mock_rpcservice.go | 4 +-
config/parsers/properties/properties.go | 14 ++--
config/parsers/properties/properties_test.go | 2 +-
config/protocol_config.go | 10 +--
config/provider_config.go | 4 +-
config/reference_config.go | 2 +-
config/service.go | 10 +--
config/service_config.go | 2 +-
config_center/configuration_listener.go | 2 +-
config_center/file/listener.go | 2 +-
config_center/nacos/impl_test.go | 14 ++--
filter/accesslog/filter_test.go | 8 +--
filter/active/filter_test.go | 4 +-
filter/adaptivesvc/filter.go | 2 +-
filter/adaptivesvc/limiter/utils.go | 2 +-
filter/auth/consumer_sign_filter_test.go | 2 +-
filter/auth/default_authenticator_test.go | 16 ++---
filter/auth/provider_auth_filter_test.go | 4 +-
filter/auth/sign_util.go | 4 +-
filter/auth/sign_util_test.go | 6 +-
filter/echo/filter.go | 2 +-
filter/echo/filter_test.go | 4 +-
filter/exec_limit/filter_test.go | 6 +-
filter/generic/filter.go | 2 +-
filter/generic/filter_test.go | 6 +-
filter/generic/generalizer/example.pb.go | 6 +-
filter/generic/generalizer/generalizer.go | 6 +-
filter/generic/generalizer/gson.go | 6 +-
filter/generic/generalizer/map.go | 22 +++---
filter/generic/generalizer/map_test.go | 58 +++++++--------
filter/generic/generalizer/protobuf_json.go | 6 +-
filter/generic/service_filter.go | 2 +-
filter/generic/service_filter_test.go | 26 +++----
filter/graceful_shutdown/consumer_filter.go | 2 +-
filter/graceful_shutdown/consumer_filter_test.go | 2 +-
filter/graceful_shutdown/provider_filter.go | 2 +-
filter/graceful_shutdown/provider_filter_test.go | 2 +-
filter/handler/rejected_execution_handler_mock.go | 2 +-
filter/hystrix/filter.go | 12 ++--
filter/metrics/filter_test.go | 4 +-
filter/otel/trace/attachment.go | 8 +--
filter/otel/trace/attachment_test.go | 16 ++---
filter/otel/trace/filter.go | 2 +-
filter/otel/trace/filter_test.go | 84 +++++++++++-----------
filter/seata/filter_test.go | 2 +-
filter/sentinel/filter.go | 8 +--
filter/sentinel/filter_test.go | 16 ++---
filter/token/filter_test.go | 16 ++---
filter/tps/filter_test.go | 12 ++--
filter/tps/limiter/method_service_test.go | 8 +--
filter/tps/limiter/mock.go | 2 +-
filter/tracing/filter_test.go | 4 +-
global/config_test.go | 4 +-
global/consumer_config.go | 2 +-
global/custom_config.go | 6 +-
global/protocol_config.go | 8 +--
global/provider_config.go | 2 +-
go.mod | 2 +-
go.sum | 2 +
loader.go | 2 +-
logger/logrus/logrus.go | 20 +++---
logger/zap/zap.go | 20 +++---
metadata/client.go | 10 +--
metadata/client_test.go | 4 +-
metadata/metadata_service.go | 12 ++--
metadata/report/nacos/report_test.go | 14 ++--
.../triple_api/proto/metadata_service_v2.pb.go | 8 +--
metrics/prometheus/registry.go | 2 +-
metrics/prometheus/rt_vec.go | 2 +-
metrics/util/aggregate/aggregator.go | 2 +-
metrics/util/aggregate/counter.go | 2 +-
metrics/util/aggregate/pane.go | 8 +--
metrics/util/aggregate/quantile.go | 2 +-
metrics/util/aggregate/sliding_window.go | 8 +--
protocol/dubbo/dubbo_codec.go | 14 ++--
protocol/dubbo/dubbo_invoker_test.go | 18 ++---
protocol/dubbo/example/new/client/main.go | 2 +-
protocol/dubbo/hessian2/const.go | 2 +-
protocol/dubbo/hessian2/hessian_dubbo.go | 10 +--
protocol/dubbo/hessian2/hessian_dubbo_test.go | 30 ++++----
protocol/dubbo/hessian2/hessian_request.go | 38 +++++-----
protocol/dubbo/hessian2/hessian_request_test.go | 12 ++--
protocol/dubbo/hessian2/hessian_response.go | 26 +++----
protocol/dubbo/hessian2/hessian_response_test.go | 22 +++---
protocol/dubbo/hessian2/java_class.go | 6 +-
protocol/dubbo/impl/codec_test.go | 14 ++--
protocol/dubbo/impl/const.go | 2 +-
protocol/dubbo/impl/hessian.go | 48 ++++++-------
protocol/dubbo/impl/hessian_test.go | 8 +--
protocol/dubbo/impl/package.go | 6 +-
protocol/dubbo/impl/request.go | 10 +--
protocol/dubbo/impl/response.go | 10 +--
protocol/dubbo/opentracing.go | 4 +-
protocol/dubbo3/common_test.go | 8 +--
protocol/dubbo3/dubbo3_invoker.go | 2 +-
protocol/dubbo3/dubbo3_protocol.go | 10 +--
protocol/dubbo3/dubbo3_protocol_test.go | 6 +-
protocol/dubbo3/internal/helloworld.pb.go | 6 +-
protocol/dubbo3/internal/helloworld_triple.pb.go | 6 +-
protocol/grpc/client.go | 2 +-
protocol/grpc/codec.go | 4 +-
protocol/grpc/internal/helloworld/helloworld.pb.go | 10 +--
protocol/grpc/internal/multiprotos/first.pb.go | 10 +--
protocol/grpc/internal/multiprotos/second.pb.go | 22 +++---
protocol/grpc/internal/routeguide/routeguide.pb.go | 22 +++---
.../grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go | 10 +--
protocol/grpc/server.go | 2 +-
protocol/invocation.go | 20 +++---
protocol/invocation/rpcinvocation.go | 62 ++++++++--------
protocol/invocation/rpcinvocation_test.go | 4 +-
protocol/jsonrpc/http.go | 6 +-
protocol/jsonrpc/http_test.go | 20 +++---
protocol/jsonrpc/json.go | 28 ++++----
protocol/jsonrpc/json_test.go | 4 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 2 +-
protocol/jsonrpc/server.go | 4 +-
protocol/mock/mock_invoker.go | 2 +-
protocol/options.go | 2 +-
protocol/protocol.go | 2 +-
protocol/rest/client/client_impl/resty_client.go | 2 +-
protocol/rest/client/rest_client.go | 4 +-
protocol/rest/config/rest_config.go | 8 +--
protocol/rest/rest_invoker.go | 6 +-
protocol/rest/rest_invoker_test.go | 10 +--
protocol/rest/rest_protocol_test.go | 14 ++--
protocol/rest/server/rest_server.go | 44 ++++++------
.../rest/server/server_impl/go_restful_server.go | 2 +-
protocol/result.go | 34 ++++-----
protocol/rpc_status.go | 8 +--
protocol/triple/client.go | 8 +--
protocol/triple/dubbo3_invoker.go | 2 +-
protocol/triple/health/triple_health/health.pb.go | 6 +-
.../triple/health/triple_health/health.triple.go | 14 ++--
.../reflection/triple_reflection/reflection.pb.go | 22 +++---
.../triple_reflection/reflection.triple.go | 6 +-
protocol/triple/server.go | 28 ++++----
protocol/triple/server_test.go | 8 +--
protocol/triple/triple.go | 26 ++-----
protocol/triple/triple_invoker.go | 4 +-
protocol/triple/triple_invoker_test.go | 12 ++--
protocol/triple/triple_protocol/buffer_pool.go | 2 +-
protocol/triple/triple_protocol/client_stream.go | 12 ++--
.../triple/triple_protocol/client_stream_test.go | 2 +-
protocol/triple/triple_protocol/codec.go | 50 ++++++-------
protocol/triple/triple_protocol/codec_test.go | 4 +-
protocol/triple/triple_protocol/compression.go | 4 +-
protocol/triple/triple_protocol/envelope.go | 4 +-
protocol/triple/triple_protocol/error.go | 2 +-
protocol/triple/triple_protocol/handler.go | 8 +--
protocol/triple/triple_protocol/handler_compat.go | 10 +--
protocol/triple/triple_protocol/handler_stream.go | 12 ++--
.../triple_protocol/handler_stream_compat.go | 12 ++--
.../triple/triple_protocol/interceptor_ext_test.go | 6 +-
.../triple_protocol/internal/assert/assert.go | 22 +++---
.../triple_protocol/internal/assert/assert_test.go | 4 +-
.../gen/proto/connect/collide/v1/collide.pb.go | 6 +-
.../gen/proto/connect/import/v1/import.pb.go | 2 +-
.../internal/gen/proto/connect/ping/v1/ping.pb.go | 22 +++---
.../connect/ping/v1/pingv1connect/ping.connect.go | 6 +-
.../proto/connectext/grpc/status/v1/status.pb.go | 4 +-
.../interoperability/interop.triple_wrapper.pb.go | 6 +-
.../proto/connectext/grpc/status/v1/status.pb.go | 4 +-
protocol/triple/triple_protocol/maxbytes.go | 2 +-
.../triple/triple_protocol/maxbytes_low_version.go | 2 +-
protocol/triple/triple_protocol/option.go | 2 +-
protocol/triple/triple_protocol/protocol.go | 8 +--
protocol/triple/triple_protocol/protocol_grpc.go | 10 +--
protocol/triple/triple_protocol/protocol_triple.go | 16 ++---
protocol/triple/triple_protocol/recover.go | 2 +-
.../triple/triple_protocol/recover_ext_test.go | 6 +-
protocol/triple/triple_protocol/server.go | 10 +--
protocol/triple/triple_protocol/triple.go | 24 +++----
protocol/triple/triple_protocol/triple_ext_test.go | 6 +-
proxy/proxy.go | 22 +++---
proxy/proxy_factory.go | 2 +-
proxy/proxy_factory/default.go | 4 +-
proxy/proxy_factory/pass_through.go | 6 +-
proxy/proxy_test.go | 24 +++----
registry/base_registry.go | 2 +-
registry/directory/directory.go | 6 +-
registry/etcdv3/service_discovery.go | 4 +-
registry/nacos/registry.go | 13 +++-
registry/nacos/registry_test.go | 20 +++---
registry/nacos/service_discovery.go | 26 +++++--
registry/nacos/service_discovery_test.go | 3 +-
registry/polaris/service_discovery.go | 6 +-
registry/protocol/protocol.go | 8 +--
registry/protocol/protocol_test.go | 14 ++--
.../metadata_service_url_params_customizer_test.go | 4 +-
registry/servicediscovery/store/cache_manager.go | 10 +--
registry/zookeeper/service_discovery.go | 18 ++---
registry/zookeeper/service_discovery_test.go | 2 +-
remoting/codec.go | 2 +-
remoting/exchange.go | 8 +--
remoting/getty/dubbo_codec_for_test.go | 14 ++--
remoting/getty/getty_client_test.go | 48 ++++++-------
remoting/getty/listener.go | 4 +-
remoting/getty/listener_test.go | 6 +-
remoting/getty/opentracing.go | 4 +-
remoting/getty/readwriter.go | 8 +--
remoting/getty/readwriter_test.go | 6 +-
remoting/polaris/parser/parser.go | 4 +-
remoting/polaris/parser/parser_test.go | 10 +--
remoting/xds/mapping/debug.go | 4 +-
.../curator_discovery/service_discovery.go | 2 +-
.../curator_discovery/service_instance.go | 14 ++--
server/options.go | 2 +-
server/server.go | 8 +--
.../cmd/testGenCode/template/newApp/api/api.pb.go | 6 +-
.../template/newApp/api/api_triple.pb.go | 12 ++--
.../template/newDemo/api/samples_api.pb.go | 6 +-
.../template/newDemo/api/samples_api_triple.pb.go | 12 ++--
tools/dubbogo-cli/generator/application/api.go | 18 ++---
tools/dubbogo-cli/generator/sample/api.go | 6 +-
tools/dubbogo-cli/generator/sample/api_tripe.go | 12 ++--
.../dubbogo-cli/generator/sample/hessian/logger.go | 2 +-
tools/dubbogo-cli/internal/client/client.go | 10 +--
tools/dubbogo-cli/internal/common/tool.go | 2 +-
.../internal/json_register/json_register.go | 4 +-
tools/dubbogo-cli/internal/protocol/dubbo/codec.go | 8 +--
.../internal/protocol/dubbo/dubbo_protocol.go | 2 +-
.../dubbogo-cli/internal/protocol/dubbo3/codec.go | 8 +--
.../internal/protocol/dubbo3/dubbo_protocol.go | 2 +-
tools/dubbogo-cli/internal/protocol/protocol.go | 4 +-
xds/balancer/clusterresolver/resource_resolver.go | 4 +-
.../clusterresolver/resource_resolver_dns.go | 2 +-
xds/balancer/orca/orca.go | 2 +-
xds/client/bootstrap/bootstrap_test.go | 2 +-
xds/client/client.go | 2 +-
xds/client/load/store.go | 6 +-
xds/client/pubsub/dump.go | 4 +-
xds/client/pubsub/update.go | 4 +-
xds/client/pubsub/watch.go | 4 +-
xds/client/resource/errors.go | 2 +-
xds/client/resource/locality_id.go | 2 +-
xds/client/resource/type.go | 2 +-
xds/client/resource/unmarshal.go | 2 +-
xds/clusterspecifier/cluster_specifier.go | 2 +-
xds/credentials/certgenerate/generate_cert.go | 8 +--
xds/credentials/certgenerate/generate_csr.go | 2 +-
xds/credentials/certprovider/pemfile/builder.go | 2 +-
xds/credentials/certprovider/provider.go | 2 +-
.../certprovider/remote/v1alpha1/ca.pb.go | 6 +-
.../certprovider/remote/v1alpha1/ca_grpc.pb.go | 4 +-
xds/credentials/certprovider/store.go | 6 +-
xds/httpfilter/fault/fault.go | 4 +-
xds/internal/internal.go | 14 ++--
xds/resolver/serviceconfig.go | 6 +-
xds/utils/balancer/stub/stub.go | 2 +-
xds/utils/balancerload/load.go | 4 +-
xds/utils/buffer/unbounded.go | 12 ++--
xds/utils/credentials/xds/handshake_info.go | 2 +-
xds/utils/grpclog/grpclog.go | 40 +++++------
xds/utils/grpclog/prefixLogger.go | 6 +-
xds/utils/hierarchy/hierarchy.go | 2 +-
xds/utils/pretty/pretty.go | 2 +-
xds/utils/resolver/config_selector.go | 4 +-
xds/utils/wrr/edf.go | 10 +--
xds/utils/wrr/random.go | 6 +-
xds/utils/wrr/wrr.go | 4 +-
xds/utils/xds_cache/timeoutCache.go | 12 ++--
295 files changed, 1369 insertions(+), 1358 deletions(-)