This is an automated email from the ASF dual-hosted git repository.
victory pushed a change to branch apache_develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
from aac5ad203 merge new 1.5 version
add 5b7b35bdc Djh/doc imports (#1282)
add 5e66a46f5 [#1288] fix the inconsistent filepath key logic (#1289)
add e3d486eba support Key Func in ServiceEvent (#1285)
add 5520fa178 performance optimization: change time.After => time.NewTimer
(#1293)
add d54da0ea7 upgrade getty version to v1.4.4
add cef22eae6 upgrade gost version
add a3fdba797 fix black list : 1. change pageSize to 64; 2. make the black
recover by Service: different service can recover at the same time. 3. fix
routeChain.notify just global lock. The lock should also in service Dimension
add e2030442d make the invokers in blacklist can be recycled; make the
blackList belong to one service.
add 0f825375a fix some test issue
add 965ff2a2d fix conflict and unittest
add 96fae1750 fix import format
add 5dc973a17 fix review issue
add f5acb35f3 Merge pull request #1287 from cvictory/feature/fix_black_list
add 2c4ec27dc fix: deadlock (#1314)
add 04842e84a fix: #1320 泛化调用+应用级服务发现，客户端 panic (#1326)
add 5e781ec46 fix:generic method timeout (#1338)
add 2dca19267 Fix: struct2MapAll logics (#1356)
add 76b78e5ef remove zk test (#1363)
add d18f5cd00 Fixed nacos unit test runs incorrectly in some cases
add b670a11b1 Merge pull request #1374 from
Chans-Open-Source/feature/fix-nacos-unit-test
add d2ddb7a8b fix (#1376)
add e3d0ae985 优化Nacos下的ServiceName的命名风格 (#1377)
add 81c2e233f feat(getty): upgrade getty version to 1.4.5 for dubbo-go 1.5
(#1378)
add 13e7a6dcc Ftr: Added more event distribution types and improved event
distribution mechanism for 1.5 (#1405)
add deaf1a784 Fix: fix the exception when tcp timeout is less than 1s for
1.5 #1362 (#1388)
add 826f52590 fix generic call bug (#1413)
add 5104d50a8 up change log (#1474)
add df89ca6f6 up:nacos client 优化
add 9a00ed0dc add: nacos params
add 6025135b2 fmt
add 0e3d62691 fmt
add 196d3c04c up go sum file
add 5f59ca141 更新关闭方法
add d0cc5933b add:constant param time
add 4f78b0b4a 修改注释
add 05034bb6c 获取client添加锁
add d3d437bb0 up:更新key规范
add e9530e5d6 up:参数优化
add 16e3744bc Ftr: Modify event dispatch interface and optimit dispatch
functions (#1453)
add 3c2aaf36a upgrade hessian2 to v1.9.3 (#1445)
add 33d0282d8 merge
add 9be6479f2 Merge pull request #1479 from zhaoyunxing92/nacos-param
add 874f43d78 Ftr: compatible with lower versions registering "default."
keys (#1444)
add 1dbb573c2 Ftr: add fatal method for logger(1.5 branch) (#1483)
add fbe3ed4fd Ftr: support custom registry group name on nacos for 1.5
(#1513)
add dee2af264 upgrade hessian2 to v1.9.4 (#1529)
add 22ec982bc Fix: 1526 (#1527)
add e785d0d8b [#1573]fix the nacos namespace from server/client.yml does
not take effect
add 2cb57ab4a [#1573]remove rootpath field in nacos&add ZkDefaultGroup
constant
add 5a90f470c Merge pull request #1576 from Mulavar/fix/nacos-namespace
add 60c07e026 remove black_list module (#1605)
add 9b86b2da9 support nacos ContextPath (#1655)
add 060e2730f fix: support multi address (#1306) (#1671)
add ee7f479c5 support $invokeAsync (#1682)
add fb382e3a9 fix bug (#1662)
add 2f1d3865f Imp: upgrade getty from 1.4.5 to 1.4.7
add b05f8fe59 fix comment
add 97f918de8 Merge pull request #1719 from Lvnszn/1.5
add 9c67bd856 add 1.5.8-rc1 change log
add 6266471cb Fix: decode net stream bytes as getty rule (#1833)
add d31545bf2 Import fmt (#1901)
add 4235a69c2 pkg v1.5.8
add 7d055a55c up:change log
add 5b29a2cf8 修改测试流程
add dac68fbcb 更新ci
add 3d581d4ab rm category key
add 470b24c0f Merge pull request #1907 from zhaoyunxing92/ci
add 1a8ddb6f2 Update etcd version and fix etcd register err (#1898)
add e3797341e up change log
add 35005e2a8 rm log
add 19ca5d1d2 Merge pull request #1918 from zhaoyunxing92/update-change
new 4a4268429 merge new 1.5 version
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/github-actions.yml | 130 +++--
.gitignore | 1 +
CHANGE.md | 61 ++-
README.md | 5 +
README_CN.md | 7 +-
.../cluster_impl/available_cluster_invoker_test.go | 1 +
cluster/cluster_impl/base_cluster_invoker.go | 21 +-
cluster/cluster_impl/base_cluster_invoker_test.go | 3 +
cluster/cluster_impl/broadcast_cluster_invoker.go | 1 +
.../cluster_impl/broadcast_cluster_invoker_test.go | 1 +
cluster/cluster_impl/failback_cluster_invoker.go | 2 +-
cluster/cluster_impl/failback_cluster_test.go | 2 +
cluster/cluster_impl/failfast_cluster_invoker.go | 3 +-
cluster/cluster_impl/failfast_cluster_test.go | 2 +
cluster/cluster_impl/failover_cluster_invoker.go | 4 +-
cluster/cluster_impl/failover_cluster_test.go | 3 +-
cluster/cluster_impl/failsafe_cluster_invoker.go | 3 +-
cluster/cluster_impl/failsafe_cluster_test.go | 2 +
cluster/cluster_impl/forking_cluster_invoker.go | 2 +-
cluster/cluster_impl/forking_cluster_test.go | 1 +
cluster/cluster_impl/zone_aware_cluster_invoker.go | 2 +-
.../zone_aware_cluster_invoker_test.go | 1 +
cluster/directory.go | 1 +
cluster/directory/static_directory.go | 9 +
cluster/loadbalance/consistent_hash.go | 25 +-
cluster/loadbalance/consistent_hash_test.go | 8 +-
cluster/router/chain/chain.go | 4 +-
cluster/router/chain/chain_test.go | 298 -----------
cluster/router/condition/app_router_test.go | 220 --------
cluster/router/condition/factory_test.go | 1 +
cluster/router/condition/listenable_router.go | 1 +
cluster/router/condition/router.go | 2 +
cluster/router/condition/router_test.go | 6 +-
cluster/router/conn_checker.go | 28 -
cluster/router/conncheck/conn_check_route.go | 138 -----
cluster/router/conncheck/conn_check_route_test.go | 163 ------
cluster/router/conncheck/conn_health_check.go | 45 --
cluster/router/conncheck/conn_health_check_test.go | 52 --
cluster/router/conncheck/factory.go | 44 --
cluster/router/conncheck/factory_test.go | 74 ---
cluster/router/tag/file.go | 1 +
cluster/router/tag/router_rule.go | 2 +-
cluster/router/tag/tag_router.go | 2 +
cluster/router/tag/tag_router_test.go | 79 +--
cluster/router/utils/bitmap_util_test.go | 1 +
common/constant/default.go | 15 +
common/constant/key.go | 75 ++-
common/constant/version.go | 4 +-
common/extension/config_load_processor.go | 183 +++++++
common/extension/config_post_processor.go | 5 +
common/extension/conn_checker.go | 41 --
common/extension/event_dispatcher_test.go | 1 +
common/extension/service_discovery.go | 1 +
common/host_util.go | 4 +-
common/logger/logger.go | 5 +
common/logger/logger_test.go | 34 ++
common/logger/logging.go | 10 +
common/proxy/proxy.go | 1 +
common/proxy/proxy_test.go | 1 +
common/rpc_service.go | 4 +-
common/url.go | 36 +-
common/url_test.go | 10 +
common/yaml/yaml.go | 1 +
config/config_center_config.go | 11 +-
config/config_loader.go | 20 +-
config/config_loader_test.go | 102 ++++
config/consumer_config.go | 2 +
config/generic_service.go | 4 +-
config/graceful_shutdown.go | 2 +
config/interfaces/config_load_processor.go | 56 ++
config/interfaces/config_reader.go | 4 +-
config/metadata_report_config.go | 5 +-
config/metadata_report_config_test.go | 4 +-
config/protocol_config.go | 7 +-
config/provider_config.go | 4 +-
config/reference_config.go | 34 +-
config/remote_config.go | 24 +-
config/remote_config_test.go | 1 +
config/router_config.go | 1 +
config/router_config_test.go | 1 +
config/service_config.go | 21 +
config/service_config_test.go | 3 +-
config/testdata/consumer_config.properties | 1 -
config/testdata/consumer_config.yml | 1 -
.../testdata/consumer_config_with_configcenter.yml | 1 -
.../testdata/consumer_config_withoutProtocol.yml | 1 -
config/testdata/provider_config.properties | 1 -
config/testdata/provider_config.yml | 1 -
.../testdata/provider_config_withoutProtocol.yml | 1 -
config_center/apollo/impl.go | 2 +
config_center/apollo/impl_test.go | 1 -
config_center/apollo/listener.go | 1 +
config_center/dynamic_configuration.go | 6 +-
config_center/file/impl.go | 1 +
config_center/mock_dynamic_config.go | 1 +
config_center/nacos/client.go | 165 ++----
config_center/nacos/client_test.go | 56 +-
config_center/nacos/facade.go | 51 +-
config_center/nacos/impl.go | 37 +-
config_center/nacos/impl_test.go | 115 +----
config_center/nacos/listener.go | 2 +-
config_center/parser/configuration_parser.go | 2 +
config_center/zookeeper/impl.go | 7 +-
config_center/zookeeper/impl_test.go | 233 ---------
config_center/zookeeper/listener_test.go | 101 ----
filter/filter_impl/access_log_filter_test.go | 1 +
filter/filter_impl/active_filter_test.go | 1 +
filter/filter_impl/auth/consumer_sign.go | 1 +
filter/filter_impl/auth/consumer_sign_test.go | 1 +
filter/filter_impl/auth/default_authenticator.go | 2 +-
filter/filter_impl/auth/provider_auth_test.go | 1 +
filter/filter_impl/generic_filter.go | 143 ++----
filter/filter_impl/generic_filter_test.go | 175 +++----
filter/filter_impl/generic_generalizer_map.go | 208 ++++++++
...ter_test.go => generic_generalizer_map_test.go} | 168 +++++-
filter/filter_impl/generic_service_filter.go | 112 ++--
filter/filter_impl/generic_service_filter_test.go | 230 +++++----
filter/filter_impl/hystrix_filter.go | 4 +
filter/filter_impl/hystrix_filter_test.go | 2 +
filter/filter_impl/sentinel_filter.go | 1 -
filter/filter_impl/sentinel_filter_test.go | 1 +
filter/filter_impl/tps/tps_limit_strategy_mock.go | 4 +-
.../tps/tps_limiter_method_service_test.go | 2 +
filter/filter_impl/tps_limit_filter.go | 1 +
filter/filter_impl/tps_limit_filter_test.go | 7 +-
.../handler/rejected_execution_handler_only_log.go | 2 +-
.../rejected_execution_handler_only_log_test.go | 1 +
go.mod | 39 +-
go.sum | 572 +++++++++------------
integrate_test.sh | 1 +
metadata/identifier/base_metadata_identifier.go | 11 +-
.../identifier/base_metadata_identifier_test.go | 2 +-
metadata/identifier/metadata_identifier_test.go | 2 +-
.../identifier/service_metadata_identifier_test.go | 2 +-
.../subscribe_metadata_identifier_test.go | 2 +-
metadata/mapping/dynamic/service_name_mapping.go | 1 +
.../mapping/dynamic/service_name_mapping_test.go | 1 +
metadata/mapping/memory/service_name_mapping.go | 1 +
metadata/report/consul/report.go | 125 -----
metadata/report/consul/report_test.go | 167 ------
metadata/report/delegate/delegate_report.go | 2 +
metadata/report/delegate/delegate_report_test.go | 1 +
metadata/report/etcd/report.go | 15 +-
metadata/report/etcd/report_test.go | 134 -----
metadata/report/nacos/report.go | 14 +-
metadata/report/zookeeper/report_test.go | 169 ------
.../service/exporter/configurable/exporter_test.go | 1 -
metadata/service/remote/service_proxy.go | 1 +
metadata/service/remote/service_proxy_test.go | 1 +
protocol/dubbo/dubbo_codec.go | 51 +-
protocol/dubbo/dubbo_invoker.go | 9 +-
protocol/dubbo/dubbo_invoker_test.go | 5 +-
protocol/dubbo/dubbo_protocol.go | 3 +
protocol/dubbo/dubbo_protocol_test.go | 2 -
protocol/dubbo/hessian2/hessian_dubbo.go | 1 +
protocol/dubbo/hessian2/hessian_dubbo_test.go | 1 +
protocol/dubbo/hessian2/hessian_request.go | 93 +---
protocol/dubbo/hessian2/hessian_request_test.go | 1 +
protocol/dubbo/hessian2/hessian_response.go | 6 +-
protocol/dubbo/hessian2/hessian_response_test.go | 1 +
protocol/dubbo/hessian2/java_class.go | 201 ++++++++
protocol/dubbo/hessian2/java_class_test.go | 132 +++++
protocol/dubbo/impl/codec.go | 14 +-
protocol/dubbo/impl/const.go | 2 +
protocol/dubbo/impl/hessian.go | 1 +
protocol/dubbo/impl/package.go | 1 +
protocol/dubbo/opentracing.go | 1 +
protocol/grpc/client.go | 3 +
protocol/grpc/client_test.go | 1 +
protocol/grpc/codec.go | 1 +
protocol/grpc/grpc_invoker.go | 2 +
protocol/grpc/internal/helloworld.pb.go | 3 +
.../protoc-gen-dubbo/examples/helloworld.pb.go | 3 +
protocol/grpc/server.go | 7 +-
protocol/invocation.go | 4 +
protocol/invocation/rpcinvocation.go | 25 +-
protocol/invoker.go | 1 +
protocol/jsonrpc/http.go | 2 +-
protocol/jsonrpc/http_test.go | 2 +
protocol/jsonrpc/server.go | 1 +
protocol/rest/client/client_impl/resty_client.go | 1 +
protocol/rest/config/reader/rest_config_reader.go | 1 +
protocol/rest/rest_invoker_test.go | 1 +
.../rest/server/server_impl/go_restful_server.go | 1 +
protocol/rpc_status.go | 129 ++---
registry/consul/listener.go | 207 --------
registry/consul/listener_test.go | 33 --
registry/consul/registry.go | 219 --------
registry/consul/registry_test.go | 73 ---
registry/consul/service_discovery.go | 493 ------------------
registry/consul/service_discovery_test.go | 234 ---------
registry/consul/utils.go | 115 -----
registry/consul/utils_test.go | 210 --------
registry/directory/directory.go | 33 +-
registry/directory/directory_test.go | 1 +
registry/etcdv3/listener.go | 17 +-
registry/etcdv3/listener_test.go | 95 ----
registry/etcdv3/registry.go | 33 +-
registry/etcdv3/registry_test.go | 132 -----
registry/etcdv3/service_discovery.go | 11 +-
registry/event.go | 10 +-
.../event_publishing_service_deiscovery_test.go | 1 +
.../metadata_service_url_params_customizer_test.go | 1 +
.../event/protocol_ports_metadata_customizer.go | 4 +-
.../event_test.go | 27 +-
registry/file/listener.go | 4 +-
registry/file/service_discovery.go | 1 +
registry/kubernetes/listener.go | 17 +-
registry/kubernetes/registry.go | 8 +-
registry/kubernetes/registry_test.go | 1 +
registry/nacos/listener.go | 43 +-
registry/nacos/registry.go | 92 +---
registry/nacos/registry_test.go | 17 +-
registry/nacos/service_discovery.go | 31 +-
registry/protocol/protocol.go | 20 +-
registry/protocol/protocol_test.go | 1 +
registry/service_instance.go | 1 +
.../servicediscovery/service_discovery_registry.go | 2 +
.../service_discovery_registry_test.go | 2 +
registry/zookeeper/listener.go | 19 +-
registry/zookeeper/registry.go | 2 +
registry/zookeeper/registry_test.go | 185 -------
registry/zookeeper/service_discovery.go | 1 +
registry/zookeeper/service_discovery_test.go | 209 --------
remoting/codec.go | 2 +-
remoting/consul/test_agent.go | 38 --
remoting/consul/test_agent_test.go | 32 --
remoting/etcdv3/client.go | 449 +---------------
remoting/etcdv3/client_test.go | 411 ---------------
remoting/etcdv3/facade.go | 33 +-
remoting/etcdv3/listener.go | 29 +-
remoting/etcdv3/listener_test.go | 104 ----
remoting/exchange.go | 9 +-
remoting/getty/config.go | 26 +-
remoting/getty/dubbo_codec_for_test.go | 26 +-
remoting/getty/getty_client.go | 9 +-
remoting/getty/getty_client_test.go | 154 ++----
remoting/getty/getty_server.go | 3 +
remoting/getty/listener.go | 14 +-
remoting/getty/listener_test.go | 1 +
remoting/getty/opentracing.go | 1 +
remoting/getty/readwriter.go | 40 +-
remoting/getty/readwriter_test.go | 151 ++++--
remoting/kubernetes/client.go | 2 +
remoting/kubernetes/facade.go | 4 +-
remoting/kubernetes/registry_controller.go | 7 +
remoting/nacos/builder.go | 141 ++---
remoting/nacos/builder_test.go | 137 ++++-
remoting/zookeeper/client.go | 1 +
.../curator_discovery/service_discovery.go | 2 +
remoting/zookeeper/facade.go | 2 +
remoting/zookeeper/facade_test.go | 125 -----
remoting/zookeeper/listener.go | 8 +-
remoting/zookeeper/listener_test.go | 106 ----
samples | 1 -
test/integrate/dubbo/go-client/client.go | 11 +-
test/integrate/dubbo/go-client/client.yml | 1 -
test/integrate/dubbo/go-client/user.go | 3 +
test/integrate/dubbo/go-server/server.go | 3 +
test/integrate/dubbo/go-server/server.yml | 1 -
test/integrate/dubbo/go-server/user.go | 3 +
tools/cli/client/client.go | 5 +-
tools/cli/example/server/config/server.yml | 1 -
tools/cli/example/server/main.go | 3 +
tools/cli/example/server/user.go | 3 +
tools/cli/json_register/json_register.go | 1 +
tools/cli/protocol/dubbo/codec.go | 6 +-
tools/cli/protocol/dubbo/dubbo_protocol.go | 1 +
268 files changed, 3173 insertions(+), 7574 deletions(-)
delete mode 100644 cluster/router/chain/chain_test.go
delete mode 100644 cluster/router/condition/app_router_test.go
delete mode 100644 cluster/router/conn_checker.go
delete mode 100644 cluster/router/conncheck/conn_check_route.go
delete mode 100644 cluster/router/conncheck/conn_check_route_test.go
delete mode 100644 cluster/router/conncheck/conn_health_check.go
delete mode 100644 cluster/router/conncheck/conn_health_check_test.go
delete mode 100644 cluster/router/conncheck/factory.go
delete mode 100644 cluster/router/conncheck/factory_test.go
create mode 100644 common/extension/config_load_processor.go
delete mode 100644 common/extension/conn_checker.go
create mode 100644 config/interfaces/config_load_processor.go
delete mode 100644 config_center/zookeeper/impl_test.go
delete mode 100644 config_center/zookeeper/listener_test.go
create mode 100644 filter/filter_impl/generic_generalizer_map.go
copy filter/filter_impl/{generic_filter_test.go =>
generic_generalizer_map_test.go} (50%)
delete mode 100644 metadata/report/consul/report.go
delete mode 100644 metadata/report/consul/report_test.go
delete mode 100644 metadata/report/etcd/report_test.go
delete mode 100644 metadata/report/zookeeper/report_test.go
create mode 100644 protocol/dubbo/hessian2/java_class.go
create mode 100644 protocol/dubbo/hessian2/java_class_test.go
delete mode 100644 registry/consul/listener.go
delete mode 100644 registry/consul/listener_test.go
delete mode 100644 registry/consul/registry.go
delete mode 100644 registry/consul/registry_test.go
delete mode 100644 registry/consul/service_discovery.go
delete mode 100644 registry/consul/service_discovery_test.go
delete mode 100644 registry/consul/utils.go
delete mode 100644 registry/consul/utils_test.go
delete mode 100644 registry/etcdv3/listener_test.go
delete mode 100644 registry/etcdv3/registry_test.go
copy config_center/dynamic_configuration_test.go => registry/event_test.go
(64%)
delete mode 100644 registry/zookeeper/registry_test.go
delete mode 100644 registry/zookeeper/service_discovery_test.go
delete mode 100644 remoting/consul/test_agent.go
delete mode 100644 remoting/consul/test_agent_test.go
delete mode 100644 remoting/etcdv3/client_test.go
delete mode 100644 remoting/etcdv3/listener_test.go
delete mode 100644 remoting/zookeeper/facade_test.go
delete mode 160000 samples
