This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 274718b Merge pull request #1066 from
yakecanlee/feature/fix-zk-configurators
add 9926081 Merge pull request #1070 from apache/1.5
add 315fd93 add default settings
add 1e10f3e fix go fmt
add d6f0f24 mod changed the way of setting default parameters
add 4640167 Merge pull request #1073 from cjphaha/develop
add d8b440e merge 1.5
add cfd384c add rpcinvocation_test.go
add 99d3d4f Merge pull request #1078 from tweitjss/master
add e703ce9 Improve config center
add 4f60f69 Merge pull request #1030 from
luckyxiaoqiang/feature/improve_config_center
add f54ea24 Merge remote-tracking branch 'upstream/3.0' into 3.0
add 0b3c7bc fix: add two feature to readme
add 9234948 Fix: add file system
add 68a9c62 Merge pull request #1085 from LaurenceLiZhixin/fix/readme
add 2aa489a Merge pull request #981 from lzp0412/develop
add 3120a22 Merge remote-tracking branch 'upstream/develop' into
fix_zk_too_many_tcp_conn
add 33dc7d4 try to fix zk too many connections
add 984a1ae remove close function in service_discovery
add 06b1cd1 remove unused code
add 16a43ac try to fix lint
add 186a8e7 fix imports format and ut
add a53ed2b fix import fmt
add bd59cfc fix ut error
add ead5951 fix ut error
add 55f40f7 Merge remote-tracking branch 'upstream/develop' into
fix_zk_too_many_tcp_conn
add bb84695 fix ut
add 394cbb2 fix lint
add 930a15b try to fix ut
add 7df6426 fix ut
add 93ae337 fix ut
add 2cb436b so tired to fix the ut
add 543721c fix lint
add 2bc815a remove client close from registry
add 0a215ac fix provider not started
add f1c5ee4 Merge remote-tracking branch 'upstream/1.5' into
fix_zk_too_many_tcp_conn
add 43280d7 change some comments
add 6fa3fea fix facade ut
add 132ca25 Merge remote-tracking branch 'upstream/1.5' into
fix_zk_too_many_tcp_conn
add 93374a2 fix glint
add 991ef61 Merge remote-tracking branch 'upstream/1.5' into
fix_zk_too_many_tcp_conn
add cb8b665 fix restart can't find provider error
add 3fdbb01 try to fix provider lost
add ef8966c try to fix provider lost
add ca647ab try to fix provider can't find error
add 3a05f71 fix compile error
add ae6a138 change type error
add a8bc4e1 fix comments
add 972a91a move zk to gost
add 0ebe79c fix lint
add 46801c3 replace grpc version
add 364be20 update gost version
add 786e843 fix compile error
add 9d8c910 fix comments
add 98ba75e fix comments
add a231789 upgrade hession version
add 6f74ff9 Merge pull request #1010 from
wenxuwan/fix_zk_too_many_tcp_conn
add a078cd9 upgrade hession version
add 15db1fc remove hessian2 version history in go.sum
add 587753b Merge pull request #1088 from
wenxuwan/fix_zk_too_many_tcp_conn
add 45ca4f3 dubbo-go 拆包bug fix
add 6108ed0 Merge branch 'master' of https://github.com/xiejiajun/dubbo-go
add 57f7b4e bug fix: getty RpcServerPackageHandler decode tcp pkg failed
because of the body buffer is smaller than the size marked by header
add 160b834 keep error caller stack
add 80a24cb code improve: use the `errors.Is()` to determine the type of
err
add 40a9f7c getty RpcServerPackageHandler decode incomplete tcp package
unit test
add 8e18ffb getty RpcServerPackageHandler decode incomplete tcp package
unit test
add da44eee RpcClientPackageHandler error compare code improve
add 3afacb4 ut ci failed fix
add 0583f46 readwriter_test ci failed fix
add 51f6d0f readwriter_test import code improve
add c6a448b code improve
add ae5743a Merge pull request #1090 from xiejiajun/issue-1089
add 2cc9f13 Merge pull request #3 from apache/1.5
add a0276f8 fix: grpc connectTimeout
add d47777f Merge pull request #1 from kzhan/feature/grcp_connect_timeout
add 98a8afa grpc-register&openServer code style
add 31724cf import sort
add bcb4a62 remove time.format and replace local relative path dependency
add eba1c2c add dependency and trigger ci
add 277d1c1 trigger ci again
add c7690fe fix grpc ut failure
add 6762cd2 remove log
add bc32e98 trigger ci
add eb7f50a up 1.5.6 version
add 0a6fe2d Merge pull request #1097 from cityiron/feature/update1.5.6
add 11ef2e8 up:更新go.sum
add 0f6b82c Merge pull request #1106 from zhaoyunxing92/fix-nacos-1.5
add 699e0e2 bugfix: Give it an initial value when attachments is nil
add a773c5f Merge pull request #1087 from rockXiaofeng/Ftr/nilAttachments
add 09fa89a add samples
add 20e2f41 add samples
add 5614e8d remove useless field
add e271c45 console.nacos.io has updated to nacos 2.0 and serviceName has
changed in 2.0, so ignore temporarily.
add 5b981f6 update submodule config
add 9610074 Merge pull request #1102 from zouyx/addSamples
add 7984ce3 fix:map iteration order
add ad3a6c4 Merge pull request #1109 from zhaoyunxing92/fix-map
add cde0d80 Merge pull request #2 from apache/1.5
add 05e103d add lock when destroy
add 9ce7b15 Merge pull request #1112 from ztelur/feature-grpc-register
add cb2a10c up 1.5.6 changelist
add c2d86a4 Merge pull request #1113 from cityiron/feature/up-changelist
add 3cf3f1b upstream nacos version
add 50042b9 Merge pull request #1116 from xiaoliu10/upgrade_nacos_version
add 7ff77bc Merge remote-tracking branch 'upstream/1.5' into merge1.5to3.0
add 33e1908 fix provider init error
add d7036a5 Merge pull request #1120 from wenxuwan/merge1.5to3.0
add 73bd3c1 feat: format use gofumpt
add 759bea2 Merge pull request #1121 from georgehao/3.0
add da1c4d6 fix bad type check logic
add e0c3fdb Merge remote-tracking branch 'upstream/3.0' into
fix_type_error
add 78bea16 Merge pull request #1118 from wenxuwan/fix_type_error
No new revisions were added by this update.
Summary of changes:
.gitmodules | 3 +
CHANGE.md | 20 +-
README.md | 5 +
README_CN.md | 5 +
.../cluster_impl/available_cluster_invoker_test.go | 6 +-
cluster/cluster_impl/base_cluster_invoker.go | 15 +-
cluster/cluster_impl/broadcast_cluster_invoker.go | 1 +
.../cluster_impl/broadcast_cluster_invoker_test.go | 6 +-
cluster/cluster_impl/failback_cluster_invoker.go | 6 +-
cluster/cluster_impl/failback_cluster_test.go | 6 +-
cluster/cluster_impl/failfast_cluster_invoker.go | 1 +
cluster/cluster_impl/failfast_cluster_test.go | 6 +-
cluster/cluster_impl/failover_cluster_invoker.go | 13 +-
cluster/cluster_impl/failover_cluster_test.go | 1 +
cluster/cluster_impl/failsafe_cluster_invoker.go | 7 +-
cluster/cluster_impl/failsafe_cluster_test.go | 6 +-
cluster/cluster_impl/forking_cluster_test.go | 8 +-
cluster/cluster_impl/zone_aware_cluster_invoker.go | 1 -
.../zone_aware_cluster_invoker_test.go | 22 +-
cluster/directory/base_directory_test.go | 1 -
cluster/directory/static_directory.go | 2 +-
cluster/loadbalance/consistent_hash.go | 5 +-
cluster/loadbalance/least_active.go | 3 +-
cluster/loadbalance/random.go | 3 +-
cluster/loadbalance/round_robin.go | 2 +-
cluster/loadbalance/util.go | 2 +-
cluster/router/chain/chain_test.go | 45 +-
cluster/router/condition/app_router_test.go | 13 +-
cluster/router/condition/factory_test.go | 2 -
cluster/router/condition/listenable_router.go | 3 +-
cluster/router/condition/router.go | 22 +-
cluster/router/conncheck/conn_check_route_test.go | 1 -
cluster/router/conncheck/conn_health_check.go | 3 +-
cluster/router/conncheck/factory.go | 3 +-
cluster/router/healthcheck/default_health_check.go | 1 -
.../healthcheck/default_health_check_test.go | 2 -
cluster/router/healthcheck/factory.go | 3 +-
.../router/healthcheck/health_check_route_test.go | 1 -
cluster/router/local/factory.go | 3 +-
cluster/router/local/self_priority_route.go | 2 +-
cluster/router/tag/file.go | 2 +-
cluster/router/tag/file_test.go | 1 -
cluster/router/tag/router_rule.go | 4 +-
cluster/router/tag/tag_router.go | 5 +-
cluster/router/tag/tag_router_test.go | 14 +-
common/config/environment.go | 20 +-
common/config/environment_test.go | 23 +
common/constant/default.go | 9 +-
common/constant/key.go | 3 +-
common/constant/time.go | 8 +-
common/constant/version.go | 4 +-
common/extension/cluster.go | 4 +-
common/extension/config_center.go | 5 +-
common/extension/config_center_factory.go | 4 +-
common/extension/config_post_processor.go | 4 +-
common/extension/configurator.go | 6 +-
common/extension/conn_checker.go | 4 +-
common/extension/event_dispatcher.go | 4 +-
common/extension/event_dispatcher_test.go | 7 +-
common/extension/graceful_shutdown.go | 4 +-
common/extension/health_checker.go | 4 +-
common/extension/health_checker_test.go | 3 +-
common/extension/loadbalance.go | 4 +-
common/extension/metadata_report_factory.go | 4 +-
common/extension/metadata_service_proxy_factory.go | 4 +-
common/extension/metrics.go | 8 +-
common/extension/metrics_test.go | 3 +-
common/extension/protocol.go | 4 +-
common/extension/proxy_factory.go | 4 +-
common/extension/registry.go | 5 +-
common/extension/rest_client.go | 4 +-
common/extension/rest_server.go | 4 +-
common/extension/service_discovery.go | 5 +-
common/extension/service_instance_customizer.go | 4 +-
.../extension/service_instance_selector_factory.go | 4 +-
common/extension/service_name_mapping.go | 4 +-
common/logger/logger.go | 7 +-
.../observer/dispatcher/mock_event_dispatcher.go | 3 +-
common/observer/listenable_test.go | 1 -
common/proxy/proxy.go | 7 +-
common/proxy/proxy_factory/default.go | 9 +-
common/proxy/proxy_factory/default_test.go | 3 +-
common/proxy/proxy_test.go | 2 -
common/rpc_service_test.go | 17 +-
common/url.go | 2 +-
common/yaml/yaml.go | 2 +-
config/base_config.go | 14 +-
config/base_config_test.go | 12 +-
config/config_api_test.go | 16 +-
config/config_center_config.go | 11 +-
config/config_center_config_test.go | 6 +-
config/config_loader.go | 77 ++-
config/config_loader_test.go | 37 +-
config/consumer_config.go | 12 +-
config/graceful_shutdown.go | 8 +-
config/graceful_shutdown_signal_darwin.go | 12 +-
config/graceful_shutdown_signal_linux.go | 12 +-
config/graceful_shutdown_signal_windows.go | 6 +-
config/graceful_shutdown_test.go | 3 +-
config/instance/metadata_report_test.go | 6 +-
config/metric_config.go | 4 +-
config/provider_config.go | 4 +-
config/reference_config.go | 10 +-
config/reference_config_test.go | 10 +-
config/registry_config.go | 2 +-
config/remote_config_test.go | 1 +
config/router_config.go | 4 +-
config/router_config_test.go | 9 +-
config/service.go | 5 +
config/service_config_test.go | 5 +-
config_center/apollo/factory.go | 1 -
config_center/apollo/impl_test.go | 8 +-
config_center/apollo/listener.go | 1 -
config_center/base_dynamic_configuration.go | 3 +-
config_center/configurator/override_test.go | 2 -
config_center/file/factory.go | 3 +-
config_center/file/impl.go | 4 +-
config_center/file/listener.go | 3 +-
config_center/mock_dynamic_config.go | 8 +-
config_center/nacos/client.go | 4 +-
config_center/nacos/facade.go | 1 +
config_center/nacos/factory.go | 4 +-
config_center/nacos/impl.go | 3 -
config_center/nacos/impl_test.go | 3 +-
config_center/parser/configuration_parser.go | 4 +-
config_center/zookeeper/factory.go | 4 +-
config_center/zookeeper/impl.go | 16 +-
config_center/zookeeper/impl_test.go | 18 +-
config_center/zookeeper/listener.go | 5 +-
filter/filter_impl/access_log_filter.go | 4 +-
filter/filter_impl/active_filter.go | 3 +-
filter/filter_impl/active_filter_test.go | 2 -
filter/filter_impl/auth/accesskey_storage.go | 3 +-
filter/filter_impl/auth/consumer_sign.go | 5 +-
filter/filter_impl/auth/default_authenticator.go | 8 +-
.../filter_impl/auth/default_authenticator_test.go | 5 +-
filter/filter_impl/auth/provider_auth.go | 3 +-
filter/filter_impl/auth/provider_auth_test.go | 1 -
filter/filter_impl/auth/sign_util_test.go | 1 -
filter/filter_impl/execute_limit_filter.go | 6 +-
filter/filter_impl/generic_filter.go | 6 +-
filter/filter_impl/generic_service_filter_test.go | 3 +-
filter/filter_impl/graceful_shutdown_filter.go | 4 +-
.../filter_impl/graceful_shutdown_filter_test.go | 1 -
filter/filter_impl/hystrix_filter.go | 15 +-
filter/filter_impl/hystrix_filter_test.go | 11 +-
filter/filter_impl/metrics_filter.go | 4 +-
filter/filter_impl/metrics_filter_test.go | 1 -
filter/filter_impl/sentinel_filter.go | 2 +
filter/filter_impl/sentinel_filter_test.go | 2 +-
.../tps/tps_limit_fix_window_strategy.go | 1 -
.../filter_impl/tps/tps_limiter_method_service.go | 8 +-
.../tps/tps_limiter_method_service_test.go | 1 +
filter/filter_impl/tps_limit_filter.go | 4 +-
filter/filter_impl/tps_limit_filter_test.go | 1 -
filter/filter_impl/tracing_filter.go | 7 +-
.../handler/rejected_execution_handler_only_log.go | 12 +-
.../rejected_execution_handler_only_log_test.go | 1 +
go.mod | 22 +-
go.sum | 135 +++--
metadata/definition/mock.go | 3 +-
metadata/identifier/base_metadata_identifier.go | 2 -
.../mapping/dynamic/service_name_mapping_test.go | 1 -
metadata/mapping/memory/service_name_mapping.go | 7 +-
metadata/report/consul/report.go | 7 +-
metadata/report/delegate/delegate_report.go | 2 -
metadata/report/delegate/delegate_report_test.go | 2 +-
metadata/report/etcd/report_test.go | 1 -
metadata/report/factory/report_factory.go | 3 +-
metadata/report/nacos/report.go | 3 +-
metadata/report/zookeeper/report.go | 19 +-
.../service/exporter/configurable/exporter_test.go | 6 +-
.../metadata_service_proxy_factory_test.go | 6 +-
metadata/service/inmemory/service_proxy.go | 3 +-
metadata/service/inmemory/service_proxy_test.go | 2 -
metadata/service/remote/service.go | 2 +-
metadata/service/remote/service_proxy.go | 2 +-
metadata/service/remote/service_proxy_test.go | 8 +-
metadata/service/remote/service_test.go | 6 +-
protocol/dubbo/dubbo_codec.go | 23 +-
protocol/dubbo/dubbo_invoker.go | 18 +-
protocol/dubbo/dubbo_invoker_test.go | 10 +-
protocol/dubbo/dubbo_protocol.go | 18 +-
protocol/dubbo/dubbo_protocol_test.go | 3 +-
protocol/dubbo/hessian2/hessian_dubbo.go | 3 -
protocol/dubbo/hessian2/hessian_dubbo_test.go | 2 +-
protocol/dubbo/hessian2/hessian_request.go | 1 -
protocol/dubbo/hessian2/hessian_response.go | 9 +-
protocol/dubbo/hessian2/hessian_response_test.go | 3 +-
protocol/dubbo/impl/codec.go | 4 +-
protocol/dubbo/impl/hessian.go | 9 +-
protocol/dubbo/opentracing.go | 3 +-
protocol/grpc/client.go | 19 +-
protocol/grpc/client_test.go | 6 +-
protocol/grpc/config.go | 3 +-
protocol/grpc/grpc_invoker.go | 8 +-
protocol/grpc/grpc_invoker_test.go | 7 +-
protocol/grpc/grpc_protocol.go | 41 +-
protocol/grpc/grpc_protocol_test.go | 36 ++
protocol/grpc/internal/client.go | 2 +-
protocol/grpc/internal/helloworld.pb.go | 25 +-
protocol/grpc/internal/server.go | 4 +-
.../protoc-gen-dubbo/examples/helloworld.pb.go | 25 +-
protocol/grpc/server.go | 101 +++-
protocol/invocation/rpcinvocation.go | 3 +-
protocol/invocation/rpcinvocation_test.go | 74 +++
protocol/jsonrpc/http.go | 3 +-
protocol/jsonrpc/http_test.go | 5 +-
protocol/jsonrpc/json.go | 2 +-
protocol/jsonrpc/json_test.go | 2 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 1 -
protocol/jsonrpc/jsonrpc_protocol.go | 6 +-
protocol/jsonrpc/server.go | 13 +-
protocol/protocol.go | 1 -
.../protocol_filter_wrapper_test.go | 2 +-
protocol/rest/config/reader/rest_config_reader.go | 3 +-
protocol/rest/rest_invoker_test.go | 2 +-
protocol/rest/rest_protocol.go | 6 +-
protocol/rest/rest_protocol_test.go | 3 +-
.../rest/server/server_impl/go_restful_server.go | 1 -
protocol/rpc_status.go | 2 +-
protocol/rpc_status_test.go | 2 -
registry/base_configuration_listener.go | 4 +-
registry/base_registry.go | 19 +-
registry/consul/service_discovery.go | 8 +-
registry/consul/service_discovery_test.go | 10 +-
registry/consul/utils_test.go | 5 +-
registry/directory/directory.go | 10 +-
registry/directory/directory_test.go | 18 +-
registry/etcdv3/listener.go | 1 -
registry/etcdv3/listener_test.go | 2 -
registry/etcdv3/registry.go | 5 +-
registry/etcdv3/registry_test.go | 14 +-
registry/etcdv3/service_discovery.go | 10 +-
.../customizable_service_instance_listener.go | 3 +-
.../customizable_service_instance_listener_test.go | 7 +-
.../event_publishing_service_deiscovery_test.go | 8 +-
.../event/event_publishing_service_discovery.go | 1 -
registry/event/log_event_listener.go | 9 +-
.../metadata_service_url_params_customizer.go | 2 -
.../metadata_service_url_params_customizer_test.go | 1 -
.../event/protocol_ports_metadata_customizer.go | 3 +-
registry/event/service_revision_customizer.go | 8 +-
registry/file/listener.go | 4 +-
registry/file/service_discovery.go | 2 +-
registry/file/service_discovery_test.go | 4 +-
registry/kubernetes/listener.go | 1 -
registry/kubernetes/listener_test.go | 1 -
registry/kubernetes/registry.go | 18 +-
registry/kubernetes/registry_test.go | 11 +-
registry/mock_registry.go | 1 -
registry/nacos/listener.go | 2 +-
registry/nacos/registry.go | 6 +-
registry/nacos/registry_test.go | 9 +-
registry/nacos/service_discovery.go | 1 -
registry/nacos/service_discovery_test.go | 12 +-
registry/protocol/protocol.go | 4 +-
registry/protocol/protocol_test.go | 2 -
.../random/random_service_instance_selector.go | 6 +-
.../instance/service_instance_selector.go | 2 +-
.../servicediscovery/service_discovery_registry.go | 15 +-
.../service_discovery_registry_test.go | 13 +-
.../rest/rest_subscribed_urls_synthesizer.go | 5 +-
registry/zookeeper/listener.go | 22 +-
registry/zookeeper/listener_test.go | 3 +-
registry/zookeeper/registry.go | 43 +-
registry/zookeeper/registry_test.go | 23 +-
registry/zookeeper/service_discovery.go | 16 +-
registry/zookeeper/service_discovery_test.go | 19 +-
remoting/codec.go | 4 +-
remoting/etcdv3/client_test.go | 15 -
remoting/etcdv3/facade.go | 5 +-
remoting/etcdv3/listener.go | 2 -
remoting/etcdv3/listener_test.go | 3 +-
remoting/exchange.go | 2 +-
remoting/exchange_client.go | 27 +-
remoting/exchange_server.go | 4 +-
remoting/getty/config.go | 3 +-
remoting/getty/dubbo_codec_for_test.go | 21 +-
remoting/getty/getty_client_test.go | 33 +-
remoting/getty/getty_server.go | 6 +-
remoting/getty/listener.go | 1 -
remoting/getty/opentracing.go | 3 +-
remoting/getty/pool.go | 10 +-
remoting/getty/readwriter.go | 11 +-
remoting/getty/readwriter_test.go | 173 ++++++
remoting/kubernetes/client.go | 9 +-
remoting/kubernetes/client_test.go | 18 +-
remoting/kubernetes/facade_test.go | 6 +-
remoting/kubernetes/listener.go | 3 -
remoting/kubernetes/listener_test.go | 3 +-
remoting/kubernetes/registry_controller.go | 15 +-
remoting/kubernetes/watch.go | 6 -
remoting/kubernetes/watch_test.go | 2 -
remoting/listener.go | 2 +-
remoting/zookeeper/client.go | 580 +--------------------
remoting/zookeeper/client_test.go | 166 ------
.../curator_discovery/service_discovery.go | 6 +-
remoting/zookeeper/facade.go | 59 +--
remoting/zookeeper/facade_test.go | 33 +-
remoting/zookeeper/listener.go | 33 +-
remoting/zookeeper/listener_test.go | 20 +-
samples | 1 +
test/integrate/dubbo/go-client/client.go | 4 +-
test/integrate/dubbo/go-client/go.mod | 7 +
test/integrate/dubbo/go-client/version.go | 4 +-
test/integrate/dubbo/go-server/go.mod | 7 +
test/integrate/dubbo/go-server/server.go | 5 +-
test/integrate/dubbo/go-server/user.go | 3 +-
test/integrate/dubbo/go-server/version.go | 4 +-
tools/cli/client/client.go | 4 +-
tools/cli/common/protocol.go | 4 +-
tools/cli/example/server/main.go | 4 +-
tools/cli/example/server/user.go | 3 +-
tools/cli/main.go | 22 +-
tools/cli/protocol/dubbo/codec.go | 4 +-
tools/cli/protocol/dubbo/dubbo_protocol.go | 3 +-
317 files changed, 1520 insertions(+), 2014 deletions(-)
create mode 100644 .gitmodules
create mode 100644 protocol/invocation/rpcinvocation_test.go
create mode 100644 remoting/getty/readwriter_test.go
delete mode 100644 remoting/zookeeper/client_test.go
create mode 160000 samples
