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 4c27e0224 chore: fix some comments (#2793)
add c3bd98bb1 Update golangci-lint.yml (#2754)
add 2d9a52f41 fix typo (#2749)
add 7a9b5c7f5 feat:add keepalive config for triple portocol (#2757)
add cdcc10c03 feat: 修复代理Http请求，变量名自动进行驼峰转换问题 (#2746)
add 51eb90011 merger branch dev-3.3 (#2760)
add f3614e9d5 fix/return err (#2763)
add ea32b5dae fix error dubbo_registry_directory metric type (#2766)
add cade2982d fix: improve thread safety in CacheListener (#2769)
add 8f9a47a89 fix #2758, findMappedServices panic (#2768)
add a15c2c504 Fix: Ensure Subscribe Waits for Register Completion or
Timeout (#2775)
add 2b15cb059 Fix issue 2699 (#2778)
add 761f0e06d Fix: Same address cannot distinguish different registry
center (#2784)
add a82628947 Fix/remove setdeadline (#2785)
add 42b0a4e52 Fix typos: serivce->service, balancce->balance (#2788)
add dbf6162c4 Fix (Server): Avoid error reporting warning logs when
detecting EOF via Peek to properly close the connection (#2790)
add db2cc255b fix issue 2683: defeat memory leak (#2792)
add ec49b40dc nacos registry support subscribe multi category (#2783)
add ff3500cc1 fix:invalid timeout (#2797)
add 88823f4a1 Merge branch 'main' of github.com:apache/dubbo-go into
develop
add bd9cc141a fix: Resolve URL parsing panic and improve error handling in
dubbogo-cli for ZooKeeper (#2795)
add bc98c2dfb move internal into dubbo-go-samples repo (#2794)
add 012a24799 docs: add v3.3.0 release note (#2802)
No new revisions were added by this update.
Summary of changes:
.github/workflows/golangci-lint.yml | 2 +-
.gitignore | 1 +
CHANGELOG.md | 93 +++
client/action.go | 20 +-
client/client.go | 4 +
client/options.go | 19 +
client/options_test.go | 38 ++
common/constant/default.go | 5 +
common/constant/key.go | 5 +
common/extension/metadata_remote.go | 51 --
common/extension/metadata_report_factory.go | 8 +-
common/extension/metadata_service.go | 55 --
common/extension/metadata_service_exporter.go | 46 --
common/extension/metadata_service_proxy_factory.go | 50 --
.../extension/metadata_service_proxy_factory_v2.go | 50 --
common/extension/metadata_service_v1.go | 55 --
common/extension/metadata_service_v2.go | 55 --
common/host_util.go | 5 +-
common/host_util_test.go | 5 +
common/metadata_info.go | 253 --------
common/rpc_service.go | 17 +
common/url.go | 2 +-
compat.go | 20 +-
config/application_config_test.go | 1 +
config/config_loader.go | 79 ---
config/custom_config_test.go | 1 +
config/instance/metadata_report.go | 66 ---
config/instance/metadata_report_test.go | 112 ----
config/instance/registry_metadata_report.go | 71 ---
config/instance/registry_metadata_report_test.go | 64 ---
config/invoker_compat.go | 27 -
...etadata_report_config.go => metadata_config.go} | 174 ++++--
...port_config_test.go => metadata_config_test.go} | 1 -
config/provider_config.go | 10 +-
config/provider_config_test.go | 1 +
config/reference_config.go | 4 +-
config/registry_config.go | 21 +-
config/root_config.go | 82 +--
config/service_config.go | 15 +-
config/service_config_test.go | 2 +-
.../config/provider/registry_application.yaml | 2 +-
config/tls_config.go | 5 +-
dubbo.go | 2 +-
global/application_config.go | 2 +-
global/metadata_report_config.go | 19 +-
global/reference_config.go | 110 ++--
global/registry_config.go | 14 +-
go.mod | 6 +-
go.sum | 12 +-
graceful_shutdown/common.go | 2 -
imports/imports.go | 3 -
metadata/client.go | 219 +++++++
metadata/client_test.go | 299 ++++++++++
metadata/definition/definition.go | 188 ------
metadata/definition/definition_test.go | 75 ---
metadata/definition/mock.go | 45 --
metadata/identifier/base_metadata_identifier.go | 113 ----
.../identifier/base_metadata_identifier_test.go | 41 --
metadata/identifier/metadata_identifier.go | 34 --
metadata/identifier/metadata_identifier_test.go | 44 --
metadata/identifier/service_metadata_identifier.go | 54 --
.../identifier/service_metadata_identifier_test.go | 45 --
.../identifier/subscribe_metadata_identifier.go | 48 --
.../subscribe_metadata_identifier_test.go | 42 --
metadata/info/metadata_info.go | 303 ++++++++++
metadata/info/metadata_info_test.go | 159 +++++
metadata/mapping/memory/service_name_mapping.go | 64 ---
metadata/mapping/metadata/service_name_mapping.go | 99 ++--
.../mapping/metadata/service_name_mapping_test.go | 182 ++++++
metadata/mapping/mock_service_name_mapping.go | 45 --
metadata/mapping/service_name_mapping.go | 16 +-
metadata/metadata.go | 75 +--
metadata/metadata_service.go | 378 ++++++++++++
metadata/metadata_service_test.go | 363 ++++++++++++
metadata/metadata_test.go | 141 +++++
metadata/options.go | 229 ++++++--
metadata/report/delegate/delegate_report.go | 319 -----------
metadata/report/delegate/delegate_report_test.go | 119 ----
metadata/report/etcd/report.go | 116 +---
metadata/report/nacos/report.go | 173 +-----
metadata/report/nacos/report_test.go | 242 +-------
metadata/report/report.go | 52 +-
metadata/report/{factory => }/report_factory.go | 7 +-
metadata/report/reporter_metric.go | 66 ---
metadata/report/zookeeper/listener.go | 83 ++-
metadata/report/zookeeper/report.go | 122 +---
metadata/report_instance.go | 123 ++++
metadata/report_instance_test.go | 264 +++++++++
metadata/service/exporter/configurable/exporter.go | 231 --------
.../service/exporter/configurable/exporter_test.go | 129 -----
metadata/service/exporter/exporter.go | 30 -
.../local/metadata_service_proxy_factory.go | 161 ------
.../local/metadata_service_proxy_factory_test.go | 95 ---
metadata/service/local/service.go | 374 ------------
metadata/service/local/service_proxy.go | 263 ---------
metadata/service/local/service_proxy_test.go | 94 ---
metadata/service/local/service_test.go | 131 -----
metadata/service/local_service.go | 169 ------
metadata/service/remote/service.go | 144 -----
metadata/service/remote/service_test.go | 186 ------
metadata/service/remote_service.go | 32 --
.../triple_api/proto/metadata_service.hessian2.go | 8 +-
metrics/registry/collector.go | 10 +-
options.go | 63 +-
protocol/dubbo/dubbo_codec.go | 4 +-
protocol/dubbo/dubbo_invoker.go | 3 +-
protocol/dubbo3/dubbo3_invoker_test.go | 4 -
protocol/jsonrpc/server.go | 3 +
protocol/rest/client/client_impl/resty_client.go | 7 +-
protocol/rest/client/rest_client.go | 5 +-
protocol/rest/rest_protocol.go | 3 +-
protocol/triple/client.go | 8 +-
protocol/triple/dubbo3_invoker.go | 5 +
protocol/triple/internal/client/cmd_client/main.go | 57 --
.../client/cmd_client_with_registry/main.go | 46 --
.../triple/internal/client/cmd_instance/main.go | 51 --
.../client/cmd_instance_with_registry/main.go | 57 --
.../internal/client/cmd_with_yml/cmd/main.go | 38 --
.../internal/client/cmd_with_yml/conf/dubbogo.yml | 7 -
protocol/triple/internal/client/common/client.go | 119 ----
.../triple/internal/client/health_client/main.go | 75 ---
.../internal/client/reflection_client/main.go | 125 ----
.../internal/dubbo3_server/api/greet_service.go | 142 -----
.../triple/internal/dubbo3_server/cmd/dubbogo.yml | 13 -
protocol/triple/internal/dubbo3_server/cmd/main.go | 32 --
.../internal/proto/dubbo3_gen/greet_triple.pb.go | 399 -------------
protocol/triple/internal/proto/greet.pb.go | 637 ---------------------
protocol/triple/internal/proto/greet.proto | 44 --
.../proto/triple_gen/greettriple/greet.triple.go | 396 -------------
.../triple/internal/server/api/greet_service.go | 128 -----
.../triple/internal/server/cmd_instance/main.go | 51 --
.../server/cmd_instance_with_registry/main.go | 56 --
protocol/triple/internal/server/cmd_server/main.go | 46 --
.../server/cmd_server_with_registry/main.go | 49 --
.../internal/server/cmd_with_yml/cmd/main.go | 33 --
.../internal/server/cmd_with_yml/conf/dubbogo.yml | 10 -
protocol/triple/server.go | 17 +-
protocol/triple/triple.go | 9 +-
protocol/triple/triple_protocol/codec.go | 4 +-
protocol/triple/triple_test.go | 497 ----------------
proxy/proxy_factory/default.go | 57 ++
registry/directory/directory.go | 33 +-
registry/etcdv3/service_discovery_test.go | 11 +-
registry/event/base_configuration_listener.go | 119 ----
registry/exposed_tmp/exposed.go | 122 +---
registry/nacos/listener.go | 57 +-
registry/nacos/registry.go | 131 ++---
registry/nacos/service_discovery_test.go | 11 +-
registry/protocol/protocol.go | 10 +-
registry/service_discovery.go | 9 +-
registry/service_discovery_holder.go | 25 -
registry/service_instance.go | 17 +-
registry/service_mapping_changed_listener.go | 27 -
.../metadata_service_url_params_customizer.go | 18 +-
.../metadata_service_url_params_customizer_test.go | 2 +-
.../metadata_service_version_customizer.go | 2 +-
.../protocol_ports_metadata_customizer.go | 23 +-
.../service_instance_host_port_customizer.go} | 41 +-
.../customizer}/service_revision_customizer.go | 24 +-
.../servicediscovery/service_discovery_registry.go | 206 +++----
.../service_instances_changed_listener_impl.go | 125 +---
.../service_mapping_change_listener_impl.go | 4 +-
.../servicediscovery/store/cache_manager_test.go | 18 +-
registry/zookeeper/service_discovery_test.go | 11 +-
remoting/nacos/builder.go | 23 +-
server/action.go | 30 +-
server/compat.go | 11 -
server/metadata.go | 93 ---
server/options.go | 2 +-
server/server.go | 144 ++---
tools/dubbogo-cli/cmd/show.go | 67 ++-
tools/dubbogo-cli/metadata/zookeeper/zookeeper.go | 71 ++-
172 files changed, 3932 insertions(+), 9666 deletions(-)
delete mode 100644 common/extension/metadata_remote.go
delete mode 100644 common/extension/metadata_service.go
delete mode 100644 common/extension/metadata_service_exporter.go
delete mode 100644 common/extension/metadata_service_proxy_factory.go
delete mode 100644 common/extension/metadata_service_proxy_factory_v2.go
delete mode 100644 common/extension/metadata_service_v1.go
delete mode 100644 common/extension/metadata_service_v2.go
delete mode 100644 common/metadata_info.go
delete mode 100644 config/instance/metadata_report.go
delete mode 100644 config/instance/metadata_report_test.go
delete mode 100644 config/instance/registry_metadata_report.go
delete mode 100644 config/instance/registry_metadata_report_test.go
delete mode 100644 config/invoker_compat.go
rename config/{metadata_report_config.go => metadata_config.go} (60%)
rename config/{metadata_report_config_test.go => metadata_config_test.go} (97%)
create mode 100644 metadata/client.go
create mode 100644 metadata/client_test.go
delete mode 100644 metadata/definition/definition.go
delete mode 100644 metadata/definition/definition_test.go
delete mode 100644 metadata/definition/mock.go
delete mode 100644 metadata/identifier/base_metadata_identifier.go
delete mode 100644 metadata/identifier/base_metadata_identifier_test.go
delete mode 100644 metadata/identifier/metadata_identifier.go
delete mode 100644 metadata/identifier/metadata_identifier_test.go
delete mode 100644 metadata/identifier/service_metadata_identifier.go
delete mode 100644 metadata/identifier/service_metadata_identifier_test.go
delete mode 100644 metadata/identifier/subscribe_metadata_identifier.go
delete mode 100644 metadata/identifier/subscribe_metadata_identifier_test.go
create mode 100644 metadata/info/metadata_info.go
create mode 100644 metadata/info/metadata_info_test.go
delete mode 100644 metadata/mapping/memory/service_name_mapping.go
create mode 100644 metadata/mapping/metadata/service_name_mapping_test.go
delete mode 100644 metadata/mapping/mock_service_name_mapping.go
create mode 100644 metadata/metadata_service.go
create mode 100644 metadata/metadata_service_test.go
create mode 100644 metadata/metadata_test.go
delete mode 100644 metadata/report/delegate/delegate_report.go
delete mode 100644 metadata/report/delegate/delegate_report_test.go
rename metadata/report/{factory => }/report_factory.go (85%)
delete mode 100644 metadata/report/reporter_metric.go
create mode 100644 metadata/report_instance.go
create mode 100644 metadata/report_instance_test.go
delete mode 100644 metadata/service/exporter/configurable/exporter.go
delete mode 100644 metadata/service/exporter/configurable/exporter_test.go
delete mode 100644 metadata/service/exporter/exporter.go
delete mode 100644 metadata/service/local/metadata_service_proxy_factory.go
delete mode 100644
metadata/service/local/metadata_service_proxy_factory_test.go
delete mode 100644 metadata/service/local/service.go
delete mode 100644 metadata/service/local/service_proxy.go
delete mode 100644 metadata/service/local/service_proxy_test.go
delete mode 100644 metadata/service/local/service_test.go
delete mode 100644 metadata/service/local_service.go
delete mode 100644 metadata/service/remote/service.go
delete mode 100644 metadata/service/remote/service_test.go
delete mode 100644 metadata/service/remote_service.go
delete mode 100644 protocol/triple/internal/client/cmd_client/main.go
delete mode 100644
protocol/triple/internal/client/cmd_client_with_registry/main.go
delete mode 100644 protocol/triple/internal/client/cmd_instance/main.go
delete mode 100644
protocol/triple/internal/client/cmd_instance_with_registry/main.go
delete mode 100644 protocol/triple/internal/client/cmd_with_yml/cmd/main.go
delete mode 100644
protocol/triple/internal/client/cmd_with_yml/conf/dubbogo.yml
delete mode 100644 protocol/triple/internal/client/common/client.go
delete mode 100644 protocol/triple/internal/client/health_client/main.go
delete mode 100644 protocol/triple/internal/client/reflection_client/main.go
delete mode 100644 protocol/triple/internal/dubbo3_server/api/greet_service.go
delete mode 100644 protocol/triple/internal/dubbo3_server/cmd/dubbogo.yml
delete mode 100644 protocol/triple/internal/dubbo3_server/cmd/main.go
delete mode 100644 protocol/triple/internal/proto/dubbo3_gen/greet_triple.pb.go
delete mode 100644 protocol/triple/internal/proto/greet.pb.go
delete mode 100644 protocol/triple/internal/proto/greet.proto
delete mode 100644
protocol/triple/internal/proto/triple_gen/greettriple/greet.triple.go
delete mode 100644 protocol/triple/internal/server/api/greet_service.go
delete mode 100644 protocol/triple/internal/server/cmd_instance/main.go
delete mode 100644
protocol/triple/internal/server/cmd_instance_with_registry/main.go
delete mode 100644 protocol/triple/internal/server/cmd_server/main.go
delete mode 100644
protocol/triple/internal/server/cmd_server_with_registry/main.go
delete mode 100644 protocol/triple/internal/server/cmd_with_yml/cmd/main.go
delete mode 100644
protocol/triple/internal/server/cmd_with_yml/conf/dubbogo.yml
delete mode 100644 protocol/triple/triple_test.go
delete mode 100644 registry/event/base_configuration_listener.go
delete mode 100644 registry/service_discovery_holder.go
delete mode 100644 registry/service_mapping_changed_listener.go
rename registry/{event =>
servicediscovery/customizer}/metadata_service_url_params_customizer.go (86%)
rename registry/{event =>
servicediscovery/customizer}/metadata_service_url_params_customizer_test.go
(99%)
rename registry/{event =>
servicediscovery/customizer}/metadata_service_version_customizer.go (98%)
rename registry/{event =>
servicediscovery/customizer}/protocol_ports_metadata_customizer.go (84%)
copy
registry/servicediscovery/{instance/random/random_service_instance_selector.go
=> customizer/service_instance_host_port_customizer.go} (52%)
rename registry/{event =>
servicediscovery/customizer}/service_revision_customizer.go (86%)
delete mode 100644 server/metadata.go
