This is an automated email from the ASF dual-hosted git repository.
wuxinfan pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
from 0ba792a48 fix: update golangci-lint to v2 and fix the issues detected
by it(#2850) (#2878)
add f020c63aa feat: Delete useless docs (#2880) (#2881)
add 3dc377fa6 feat: logger module refactorization (#2838)
add f233b3a5d fix: AddCallerSkip fix for default zap logger (#2887)
add beb51fc40 feat: register client filter to overallReference (#2886)
add 2bb56d28e feat: support new triple non-IDL mode (#2858)
add 395a3b8e4 refactor: switch to global protocol config (#2893)
add 2bc6c69c0 refactor: protocol package refactor (#2892)
add 5562caba2 chore:upgrade optel package (#2898)
add f50ba61c4 Fix: handle logical dead loop (#2879)
add eee5acd89 Fix nacos instance overwrite (#2882)
add 51fdc4223 fix go test error (#2903)
add daeedf231 handle SonarQubeCould AI bot warning （#2895） (#2902)
add 7b4706054 rename invocation (#2907)
add d5621ec16 chore: optimize ci (#2904)
add 374bfaa49 chore: rename invocation (#2910)
add f7323d7cf feat: TLS new API design and replace the TLSconfig of config
package (#2891)
add d27f5e743 refactor: add triple protocol config and option (#2900)
add d80526a45 Removed the dependency of dubbo, jsonrpc, and dubbo3 on
config in some protocols (#2909)
add 1e1f38b77 fix read prefix EOF error (#2912)
add 7ba9017a5 feat: replace filter/graceful_shutdown's use of config
package to global package (#2906)
add b3e6c94ef feat: decode hessian from stream（#2840) (#2841)
add 4b6c00cf2 Optimize: remove deplicate judge available (#2908)
No new revisions were added by this update.
Summary of changes:
.github/workflows/github-actions.yml | 14 +-
Makefile | 4 +-
client/action.go | 40 +-
client/client.go | 78 +++-
client/options.go | 123 ++++--
client/options_test.go | 6 +-
cluster/cluster/adaptivesvc/cluster.go | 4 +-
cluster/cluster/adaptivesvc/cluster_invoker.go | 27 +-
cluster/cluster/available/cluster.go | 4 +-
cluster/cluster/available/cluster_invoker.go | 13 +-
cluster/cluster/available/cluster_invoker_test.go | 11 +-
cluster/cluster/base/cluster_invoker.go | 28 +-
cluster/cluster/base/cluster_invoker_test.go | 10 +-
cluster/cluster/broadcast/cluster.go | 4 +-
cluster/cluster/broadcast/cluster_invoker.go | 25 +-
cluster/cluster/broadcast/cluster_invoker_test.go | 13 +-
cluster/cluster/cluster.go | 4 +-
cluster/cluster/cluster_interceptor.go | 5 +-
cluster/cluster/failback/cluster.go | 4 +-
cluster/cluster/failback/cluster_invoker.go | 41 +-
cluster/cluster/failback/cluster_test.go | 25 +-
cluster/cluster/failfast/cluster.go | 4 +-
cluster/cluster/failfast/cluster_invoker.go | 11 +-
cluster/cluster/failfast/cluster_test.go | 11 +-
cluster/cluster/failover/cluster.go | 4 +-
cluster/cluster/failover/cluster_invoker.go | 33 +-
cluster/cluster/failover/cluster_test.go | 9 +-
cluster/cluster/failsafe/cluster.go | 4 +-
cluster/cluster/failsafe/cluster_invoker.go | 23 +-
cluster/cluster/failsafe/cluster_test.go | 11 +-
cluster/cluster/forking/cluster.go | 4 +-
cluster/cluster/forking/cluster_invoker.go | 25 +-
cluster/cluster/forking/cluster_test.go | 21 +-
cluster/cluster/interceptor_invoker.go | 9 +-
cluster/cluster/mock.go | 11 +-
cluster/cluster/zoneaware/cluster.go | 4 +-
cluster/cluster/zoneaware/cluster_interceptor.go | 5 +-
cluster/cluster/zoneaware/cluster_invoker.go | 15 +-
cluster/cluster/zoneaware/cluster_invoker_test.go | 31 +-
cluster/directory/directory.go | 4 +-
cluster/directory/static/directory.go | 14 +-
cluster/directory/static/directory_test.go | 10 +-
cluster/loadbalance/aliasmethod/alias_method.go | 14 +-
cluster/loadbalance/aliasmethod/loadbalance.go | 4 +-
.../loadbalance/aliasmethod/loadbalance_test.go | 14 +-
.../loadbalance/consistenthashing/loadbalance.go | 4 +-
.../consistenthashing/loadbalance_test.go | 26 +-
cluster/loadbalance/consistenthashing/selector.go | 12 +-
cluster/loadbalance/iwrr/iwrr.go | 10 +-
cluster/loadbalance/iwrr/loadbalance.go | 4 +-
cluster/loadbalance/iwrr/loadbalance_test.go | 14 +-
cluster/loadbalance/leastactive/loadbalance.go | 6 +-
.../loadbalance/leastactive/loadbalance_test.go | 14 +-
cluster/loadbalance/loadbalance.go | 4 +-
cluster/loadbalance/loadbalance_benchmarks_test.go | 8 +-
cluster/loadbalance/p2c/loadbalance.go | 4 +-
cluster/loadbalance/p2c/loadbalance_test.go | 38 +-
cluster/loadbalance/random/loadbalance.go | 4 +-
cluster/loadbalance/random/loadbalance_test.go | 24 +-
cluster/loadbalance/roundrobin/loadbalance.go | 6 +-
cluster/loadbalance/roundrobin/loadbalance_test.go | 14 +-
cluster/loadbalance/util.go | 4 +-
cluster/router/affinity/router.go | 12 +-
cluster/router/affinity/router_test.go | 16 +-
cluster/router/chain.go | 6 +-
cluster/router/chain/chain.go | 14 +-
cluster/router/condition/dynamic_router.go | 18 +-
cluster/router/condition/matcher/argument.go | 4 +-
cluster/router/condition/matcher/attachment.go | 4 +-
cluster/router/condition/matcher/base.go | 16 +-
cluster/router/condition/matcher/matcher.go | 6 +-
cluster/router/condition/matcher/param.go | 4 +-
.../condition/matcher/pattern_value/pattern.go | 4 +-
.../condition/matcher/pattern_value/scope.go | 4 +-
.../condition/matcher/pattern_value/wildcard.go | 4 +-
cluster/router/condition/route.go | 30 +-
cluster/router/condition/router_test.go | 88 ++--
cluster/router/polaris/router.go | 16 +-
cluster/router/router.go | 10 +-
cluster/router/script/instance/instances_pool.go | 11 +-
cluster/router/script/instance/js_instance.go | 12 +-
cluster/router/script/instance/js_instance_test.go | 24 +-
cluster/router/script/router.go | 10 +-
cluster/router/script/router_test.go | 26 +-
cluster/router/tag/match.go | 36 +-
cluster/router/tag/router.go | 6 +-
cluster/router/tag/router_test.go | 130 +++---
common/constant/default.go | 3 +
common/constant/key.go | 20 +-
common/extension/logger.go | 3 +-
common/extension/protocol.go | 10 +-
common/rpc_service.go | 32 +-
compat.go | 56 +--
config/config_loader.go | 3 +-
config/graceful_shutdown.go | 12 +-
config/protocol_config.go | 2 +
config/reference_config.go | 10 +-
config/root_config.go | 2 +-
config/service_config.go | 28 +-
.../case_invert.go => config/triple_config.go | 27 +-
doc/apache/apache-release-procedure-20200306.md | 448 ---------------------
doc/apache/release_note.md | 12 -
dubbo.go | 55 ++-
filter/access_key.go | 4 +-
filter/accesslog/filter.go | 9 +-
filter/accesslog/filter_test.go | 9 +-
filter/active/filter.go | 21 +-
filter/active/filter_test.go | 11 +-
filter/adaptivesvc/filter.go | 39 +-
filter/auth/accesskey_storage.go | 4 +-
filter/auth/accesskey_storage_test.go | 6 +-
filter/auth/consumer_sign_filter.go | 7 +-
filter/auth/consumer_sign_filter_test.go | 10 +-
filter/auth/default_authenticator.go | 44 +-
filter/auth/provider_auth_filter.go | 9 +-
filter/auth/provider_auth_filter_test.go | 4 +-
filter/authenticator.go | 6 +-
filter/context/filter.go | 9 +-
filter/echo/filter.go | 11 +-
filter/echo/filter_test.go | 6 +-
filter/exec_limit/filter.go | 9 +-
filter/exec_limit/filter_test.go | 8 +-
filter/filter.go | 7 +-
filter/generic/filter.go | 45 ++-
filter/generic/filter_test.go | 11 +-
filter/generic/service_filter.go | 51 +--
filter/generic/service_filter_test.go | 43 +-
filter/generic/util.go | 6 +-
.../graceful_shutdown}/compat.go | 5 +-
filter/graceful_shutdown/consumer_filter.go | 23 +-
filter/graceful_shutdown/consumer_filter_test.go | 46 ++-
filter/graceful_shutdown/provider_filter.go | 25 +-
filter/graceful_shutdown/provider_filter_test.go | 71 +++-
filter/handler/rejected_execution_handler_mock.go | 7 +-
.../handler/rejected_execution_handler_only_log.go | 7 +-
filter/hystrix/filter.go | 23 +-
filter/hystrix/filter_test.go | 27 +-
filter/metrics/filter.go | 7 +-
filter/metrics/filter_test.go | 4 +-
filter/otel/trace/filter.go | 11 +-
filter/otel/trace/filter_test.go | 43 +-
filter/polaris/limit/limiter.go | 6 +-
filter/rejected_execution_handler.go | 5 +-
filter/seata/filter.go | 7 +-
filter/seata/filter_test.go | 11 +-
filter/sentinel/filter.go | 19 +-
filter/sentinel/filter_test.go | 17 +-
filter/token/filter.go | 15 +-
filter/token/filter_test.go | 10 +-
filter/tps/filter.go | 9 +-
filter/tps/filter_test.go | 11 +-
filter/tps/limiter/method_service.go | 6 +-
filter/tps/limiter/mock.go | 4 +-
filter/tps_limiter.go | 4 +-
filter/tracing/filter.go | 9 +-
filter/tracing/filter_test.go | 4 +-
.../protocol_client_config.go | 44 +-
global/protocol_config.go | 34 +-
global/reference_config.go | 118 +++---
global/tls_config.go | 29 +-
global/{protocol_config.go => triple_config.go} | 37 +-
go.mod | 52 +--
go.sum | 159 +++-----
graceful_shutdown/options.go | 2 +-
graceful_shutdown/shutdown.go | 76 ++--
loader.go | 2 -
common/extension/protocol.go => logger/base.go | 32 +-
logger/{logger.go => core/file.go} | 2 +-
logger/{ => core}/logrus/logrus.go | 53 +--
logger/{ => core}/zap/zap.go | 76 +---
logger/logger.go | 71 +++-
metadata/client.go | 8 +-
metadata/client_test.go | 31 +-
metadata/metadata_service.go | 13 +-
metadata/metadata_service_test.go | 10 +-
metrics/rpc/event.go | 13 +-
metrics/rpc/util.go | 4 +-
metrics/util/aggregate/aggregator_test.go | 4 +-
options.go | 44 +-
.../dubbo_exporter.go => base/base_exporter.go} | 50 ++-
protocol/{invoker.go => base/base_invoker.go} | 9 +-
.../{invoker_test.go => base/base_invoker_test.go} | 2 +-
protocol/{protocol.go => base/base_protocol.go} | 54 +--
protocol/{ => base}/invocation.go | 2 +-
protocol/{ => base}/rpc_status.go | 2 +-
protocol/{ => base}/rpc_status_test.go | 4 +-
protocol/compat.go | 44 ++
protocol/dubbo/dubbo_codec.go | 13 +-
protocol/dubbo/dubbo_exporter.go | 8 +-
protocol/dubbo/dubbo_invoker.go | 65 +--
protocol/dubbo/dubbo_protocol.go | 21 +-
protocol/dubbo/dubbo_protocol_test.go | 8 +-
protocol/dubbo/hessian2/hessian_dubbo.go | 129 ++++--
protocol/dubbo/hessian2/hessian_dubbo_test.go | 65 +++
protocol/dubbo/impl/hessian_test.go | 1 +
protocol/dubbo/opentracing.go | 4 +-
protocol/dubbo3/common_test.go | 1 +
protocol/dubbo3/dubbo3_exporter.go | 8 +-
protocol/dubbo3/dubbo3_invoker.go | 68 +++-
protocol/dubbo3/dubbo3_protocol.go | 45 ++-
protocol/dubbo3/dubbo3_protocol_test.go | 4 +-
protocol/dubbo3/internal/helloworld_triple.pb.go | 2 +-
protocol/grpc/client.go | 28 +-
protocol/grpc/grpc_exporter.go | 8 +-
protocol/grpc/grpc_invoker.go | 37 +-
protocol/grpc/grpc_protocol.go | 12 +-
protocol/grpc/grpc_protocol_test.go | 4 +-
protocol/grpc/internal/helloworld/helloworld.pb.go | 12 +-
protocol/grpc/internal/multiprotos/first.pb.go | 12 +-
protocol/grpc/internal/multiprotos/second.pb.go | 24 +-
protocol/grpc/internal/routeguide/routeguide.pb.go | 24 +-
protocol/grpc/server.go | 35 +-
protocol/invocation/rpcinvocation.go | 12 +-
protocol/jsonrpc/jsonrpc_exporter.go | 8 +-
protocol/jsonrpc/jsonrpc_invoker.go | 23 +-
protocol/jsonrpc/jsonrpc_protocol.go | 23 +-
protocol/jsonrpc/jsonrpc_protocol_test.go | 7 +-
protocol/mock/mock_invoker.go | 7 +-
protocol/options.go | 286 ++++++++++---
protocol/protocolwrapper/mock_protocol_filter.go | 12 +-
.../protocolwrapper/protocol_filter_wrapper.go | 19 +-
.../protocol_filter_wrapper_test.go | 15 +-
protocol/rest/rest_exporter.go | 8 +-
protocol/rest/rest_invoker.go | 33 +-
protocol/rest/rest_protocol.go | 12 +-
protocol/rest/server/rest_server.go | 4 +-
protocol/{ => result}/result.go | 2 +-
protocol/triple/client.go | 158 ++++++--
protocol/triple/dubbo3_invoker.go | 93 +++--
protocol/triple/health/healthServer.go | 2 +-
protocol/triple/options.go | 94 +++++
protocol/triple/reflection/serverreflection.go | 2 +-
protocol/triple/server.go | 120 ++++--
protocol/triple/triple.go | 29 +-
protocol/triple/triple_exporter.go | 8 +-
protocol/triple/triple_invoker.go | 21 +-
protocol/triple/triple_invoker_test.go | 18 +-
protocol/triple/triple_protocol/envelope.go | 8 +-
protocol/triple/triple_protocol/envelope_test.go | 76 ++++
protocol/triple/triple_protocol/handler_compat.go | 2 +-
protocol/triple/triple_protocol/server.go | 6 +-
protocol/triple/triple_protocol/triple_ext_test.go | 4 +-
proxy/proxy.go | 20 +-
proxy/proxy_factory.go | 8 +-
proxy/proxy_factory/default.go | 29 +-
proxy/proxy_factory/default_test.go | 6 +-
proxy/proxy_factory/pass_through.go | 17 +-
proxy/proxy_factory/pass_through_test.go | 6 +-
proxy/proxy_test.go | 13 +-
registry/directory/directory.go | 54 +--
registry/etcdv3/service_discovery_test.go | 13 +-
registry/exposed_tmp/exposed.go | 4 +-
registry/nacos/listener.go | 7 +-
registry/nacos/registry.go | 88 +++-
registry/nacos/registry_test.go | 240 ++++++++++-
registry/nacos/service_discovery.go | 43 +-
registry/nacos/service_discovery_test.go | 84 +++-
registry/polaris/service_discovery.go | 2 +-
registry/protocol/protocol.go | 49 +--
registry/protocol/protocol_test.go | 10 +-
.../metadata_service_url_params_customizer.go | 1 +
.../servicediscovery/service_discovery_registry.go | 22 +-
registry/zookeeper/service_discovery_test.go | 11 +-
remoting/exchange_client.go | 23 +-
remoting/getty/dubbo_codec_for_test.go | 10 +-
remoting/getty/getty_client.go | 27 +-
remoting/getty/getty_client_test.go | 17 +-
remoting/getty/getty_server.go | 33 +-
remoting/getty/getty_server_test.go | 5 +-
remoting/getty/opentracing.go | 4 +-
remoting/getty/readwriter_test.go | 11 +-
server/action.go | 142 ++++---
server/compat.go | 29 --
server/options.go | 82 ++--
server/server.go | 36 +-
tls/helper.go | 106 +++++
tls/helper_test.go | 103 +++++
{logger => tls}/options.go | 69 +---
tools/dubbogo-cli/cmd/show.go | 1 +
279 files changed, 4270 insertions(+), 3019 deletions(-)
copy common/dubboutil/case_invert.go => config/triple_config.go (56%)
delete mode 100644 doc/apache/apache-release-procedure-20200306.md
delete mode 100644 doc/apache/release_note.md
rename {graceful_shutdown => filter/graceful_shutdown}/compat.go (92%)
copy protocol/dubbo/impl/serialization.go => global/protocol_client_config.go
(54%)
copy global/{protocol_config.go => triple_config.go} (51%)
copy common/extension/protocol.go => logger/base.go (60%)
copy logger/{logger.go => core/file.go} (99%)
rename logger/{ => core}/logrus/logrus.go (70%)
rename logger/{ => core}/zap/zap.go (69%)
copy protocol/{dubbo/dubbo_exporter.go => base/base_exporter.go} (50%)
rename protocol/{invoker.go => base/base_invoker.go} (94%)
rename protocol/{invoker_test.go => base/base_invoker_test.go} (98%)
rename protocol/{protocol.go => base/base_protocol.go} (67%)
rename protocol/{ => base}/invocation.go (99%)
rename protocol/{ => base}/rpc_status.go (99%)
rename protocol/{ => base}/rpc_status_test.go (98%)
create mode 100644 protocol/compat.go
rename protocol/{ => result}/result.go (99%)
create mode 100644 protocol/triple/options.go
create mode 100644 protocol/triple/triple_protocol/envelope_test.go
create mode 100644 tls/helper.go
create mode 100644 tls/helper_test.go
copy {logger => tls}/options.go (51%)
