You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2022/07/09 02:20:19 UTC
[dubbo-go] branch develop updated (07defad2e -> 1abbc2e77)
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 07defad2e Merge pull request #1919 from ray2011/master
add d127e5096 build(deps): bump google.golang.org/grpc from 1.46.2 to 1.47.0 (#1920)
add 0ccec74a1 build(deps): bump github.com/emicklei/go-restful/v3 from 3.7.4 to 3.8.0 (#1922)
add 35f4e8c19 fix: typo correction (#1924)
add e4690d1ea chore: remove apollo config center (#1932)
add dfe215b7c build(deps): bump github.com/RoaringBitmap/roaring from 1.1.0 to 1.2.0 (#1934)
add f21044aa4 build(deps): bump github.com/stretchr/testify from 1.7.1 to 1.7.3 (#1939)
add ae18c8220 build(deps): bump github.com/hashicorp/vault/sdk from 0.3.0 to 0.5.2 (#1942)
add e10e2087a Fix: fix revision calc (#1926)
add 48fad4bd9 feat: Grpc based Health check. (#1935)
add c52fa6119 build(deps): bump github.com/knadh/koanf from 1.4.1 to 1.4.2 (#1941)
add ada752c51 build(deps): bump github.com/stretchr/testify from 1.7.3 to 1.7.5 (#1944)
add f164c8105 build(deps): bump github.com/stretchr/testify from 1.7.5 to 1.8.0 (#1951)
add 148404b40 build(deps): bump github.com/dubbogo/gost from 1.11.25 to 1.12.5 (#1950)
add 53221faec reduce common directory (#1948)
add 1abbc2e77 fix(adaptive-service): remove useless time format. (#1955)
No new revisions were added by this update.
Summary of changes:
README.md | 2 +-
README_CN.md | 2 +-
cluster/cluster/adaptivesvc/cluster_invoker.go | 3 +-
cluster/cluster/base/cluster_invoker.go | 3 +-
cluster/cluster/broadcast/cluster_invoker.go | 5 +-
cluster/cluster/failback/cluster_invoker.go | 3 +-
cluster/cluster/failover/cluster_invoker.go | 3 +-
cluster/cluster/failsafe/cluster_invoker.go | 5 +-
cluster/cluster/forking/cluster_invoker.go | 3 +-
cluster/cluster/mock.go | 3 +-
cluster/loadbalance/p2c/loadbalance.go | 5 +-
cluster/loadbalance/ringhash/ringhash.go | 5 +-
cluster/router/chain/chain.go | 3 +-
cluster/router/meshrouter/meshrouter.go | 5 +-
cluster/router/tag/match.go | 5 +-
cluster/router/tag/router.go | 3 +-
common/{ => constant}/file/suffix.go | 0
common/constant/key.go | 8 +-
common/extension/proxy_factory.go | 7 +-
common/logger/file_log.yml | 36 ---
common/logger/logger.go | 172 -----------
common/logger/logging.go | 68 -----
common/metadata_info.go | 8 +-
common/observer/event.go | 68 -----
common/observer/event_listener.go | 50 ----
common/rpc_service.go | 6 +-
common/yaml/testdata/config.yml | 7 -
common/yaml/yaml.go | 61 ----
common/yaml/yaml_test.go | 70 -----
config/config_center_config.go | 3 +-
config/config_center_config_test.go | 90 ------
config/config_loader_options.go | 5 +-
config/config_loader_options_test.go | 2 +-
config/config_resolver.go | 2 +-
config/consumer_config.go | 3 +-
config/graceful_shutdown.go | 2 +-
config/graceful_shutdown_config.go | 3 +-
config/logger_config.go | 5 +-
config/logger_config_test.go | 6 +-
config/metadata_report_config.go | 3 +-
config/provider_config.go | 21 +-
config/provider_config_test.go | 3 +-
config/reference_config.go | 4 +-
config/reference_config_test.go | 2 +-
config/registry_config.go | 3 +-
config/root_config.go | 3 +-
config/root_config_test.go | 3 +-
config/service_config.go | 2 +-
config/service_config_test.go | 2 +-
config/testdata/config/center/apollo.yaml | 8 -
.../consumer_config_with_configcenter_apollo.yml | 24 --
config_center/apollo/doc.go | 19 --
config_center/apollo/factory.go | 45 ---
config_center/apollo/impl.go | 171 -----------
config_center/apollo/impl_test.go | 216 --------------
config_center/apollo/listener.go | 77 -----
config_center/apollo/mockDubbogo.yaml.json | 1 -
config_center/file/listener.go | 3 +-
config_center/nacos/client.go | 2 +-
config_center/nacos/facade.go | 2 +-
config_center/nacos/impl.go | 2 +-
config_center/nacos/listener.go | 3 +-
config_center/parser/configuration_parser.go | 3 +-
config_center/zookeeper/impl.go | 2 +-
filter/accesslog/filter.go | 5 +-
filter/active/filter.go | 5 +-
filter/adaptivesvc/filter.go | 3 +-
filter/adaptivesvc/limiter/hill_climbing.go | 2 +-
filter/adaptivesvc/limiter/utils.go | 2 +-
filter/auth/provider_auth_filter.go | 5 +-
filter/auth/sign_util.go | 2 +-
filter/exec_limit/filter.go | 3 +-
filter/generic/filter.go | 3 +-
filter/generic/generalizer/gson.go | 3 +-
filter/generic/generalizer/map.go | 3 +-
filter/generic/service_filter.go | 3 +-
filter/generic/util.go | 5 +-
filter/graceful_shutdown/consumer_filter.go | 5 +-
filter/graceful_shutdown/provider_filter.go | 5 +-
.../handler/rejected_execution_handler_only_log.go | 5 +-
filter/hystrix/filter.go | 3 +-
filter/seata/filter.go | 5 +-
filter/sentinel/filter.go | 3 +-
filter/tps/filter.go | 5 +-
filter/tps/limiter/method_service.go | 3 +-
filter/xds/cb/filter.go | 5 +-
go.mod | 16 +-
go.sum | 74 ++---
imports/imports.go | 4 +-
metadata/mapping/metadata/service_name_mapping.go | 2 +-
metadata/report/delegate/delegate_report.go | 3 +-
metadata/report/delegate/delegate_report_test.go | 3 +-
metadata/report/etcd/report.go | 2 +-
metadata/report/nacos/report.go | 2 +-
metadata/report/zookeeper/report.go | 2 +-
metadata/service/exporter/configurable/exporter.go | 5 +-
.../service/exporter/configurable/exporter_test.go | 2 +-
.../local/metadata_service_proxy_factory.go | 5 +-
metadata/service/local/service.go | 3 +-
metadata/service/local/service_proxy.go | 5 +-
metadata/service/remote/service.go | 3 +-
metadata/service/remote/service_test.go | 2 +-
metrics/prometheus/reporter.go | 3 +-
protocol/dubbo/dubbo_codec.go | 3 +-
protocol/dubbo/dubbo_exporter.go | 5 +-
protocol/dubbo/dubbo_invoker.go | 3 +-
protocol/dubbo/dubbo_invoker_test.go | 2 +-
protocol/dubbo/dubbo_protocol.go | 3 +-
protocol/dubbo/dubbo_protocol_test.go | 2 +-
protocol/dubbo/hessian2/hessian_request.go | 6 +-
protocol/dubbo/hessian2/hessian_response.go | 6 +-
protocol/dubbo/impl/codec.go | 3 +-
protocol/dubbo/impl/hessian.go | 3 +-
protocol/dubbo3/dubbo3_exporter.go | 3 +-
protocol/dubbo3/dubbo3_invoker.go | 3 +-
protocol/dubbo3/dubbo3_protocol.go | 3 +-
protocol/dubbo3/health/serverhealth.go | 186 ++++++++++++
.../dubbo3/health/triple_health_v1/health.pb.go | 314 +++++++++++++++++++++
.../dubbo3/health/triple_health_v1/health.proto | 62 ++++
.../health/triple_health_v1/health_triple.pb.go | 286 +++++++++++++++++++
protocol/dubbo3/internal/server.go | 7 +-
protocol/dubbo3/reflection/serverreflection.go | 30 +-
protocol/grpc/client.go | 3 +-
protocol/grpc/grpc_exporter.go | 5 +-
protocol/grpc/grpc_invoker.go | 3 +-
protocol/grpc/grpc_protocol.go | 5 +-
protocol/grpc/internal/helloworld/server.go | 6 +-
protocol/grpc/internal/routeguide/client.go | 5 +-
protocol/grpc/internal/routeguide/server.go | 6 +-
protocol/grpc/server.go | 3 +-
protocol/invoker.go | 3 +-
protocol/jsonrpc/http.go | 3 +-
protocol/jsonrpc/http_test.go | 2 +-
protocol/jsonrpc/jsonrpc_exporter.go | 5 +-
protocol/jsonrpc/jsonrpc_invoker.go | 5 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 2 +-
protocol/jsonrpc/jsonrpc_protocol.go | 5 +-
protocol/jsonrpc/server.go | 3 +-
protocol/protocol.go | 5 +-
.../protocolwrapper/protocol_filter_wrapper.go | 5 +-
.../protocol_filter_wrapper_test.go | 3 +-
protocol/rest/config/reader/rest_config_reader.go | 3 +-
.../rest/config/reader/rest_config_reader_test.go | 3 +-
protocol/rest/rest_exporter.go | 5 +-
protocol/rest/rest_protocol.go | 5 +-
protocol/rest/rest_protocol_test.go | 2 +-
protocol/rest/server/rest_server.go | 3 +-
.../rest/server/server_impl/go_restful_server.go | 3 +-
protocol/rpc_status.go | 3 +-
{common/proxy => proxy}/proxy.go | 3 +-
{common/proxy => proxy}/proxy_factory.go | 0
{common/proxy => proxy}/proxy_factory/default.go | 5 +-
.../proxy => proxy}/proxy_factory/default_test.go | 0
.../proxy => proxy}/proxy_factory/pass_through.go | 5 +-
.../proxy_factory/pass_through_test.go | 0
{common/proxy => proxy}/proxy_factory/utils.go | 0
{common/proxy => proxy}/proxy_test.go | 0
registry/base_configuration_listener.go | 3 +-
registry/base_registry.go | 3 +-
registry/directory/directory.go | 3 +-
registry/etcdv3/listener.go | 2 +-
registry/etcdv3/registry.go | 2 +-
registry/etcdv3/service_discovery.go | 2 +-
registry/event.go | 5 +-
registry/event/base_configuration_listener.go | 3 +-
.../metadata_service_url_params_customizer.go | 2 +-
.../event/protocol_ports_metadata_customizer.go | 5 +-
.../service_instances_changed_listener_impl.go | 4 +-
registry/event/service_revision_customizer.go | 5 +-
registry/mock_registry.go | 3 +-
registry/nacos/listener.go | 2 +-
registry/nacos/registry.go | 2 +-
registry/nacos/service_discovery.go | 6 +-
registry/polaris/listener.go | 2 +-
registry/polaris/registry.go | 3 +-
registry/polaris/service_discovery.go | 2 +-
registry/protocol/protocol.go | 6 +-
registry/service_instance.go | 2 +-
registry/service_instances_changed_listener.go | 5 +-
.../servicediscovery/service_discovery_registry.go | 2 +-
registry/xds/registry.go | 3 +-
registry/zookeeper/listener.go | 2 +-
registry/zookeeper/registry.go | 2 +-
registry/zookeeper/service_discovery.go | 2 +-
registry/zookeeper/service_discovery_test.go | 2 +-
remoting/etcdv3/client.go | 5 +-
remoting/etcdv3/facade.go | 2 +-
remoting/etcdv3/listener.go | 2 +-
remoting/exchange.go | 3 +-
remoting/exchange_client.go | 3 +-
remoting/getty/getty_client.go | 4 +-
remoting/getty/getty_client_test.go | 2 +-
remoting/getty/getty_server.go | 4 +-
remoting/getty/listener.go | 4 +-
remoting/getty/pool.go | 5 +-
remoting/getty/readwriter.go | 5 +-
remoting/getty/readwriter_test.go | 2 +-
remoting/nacos/builder.go | 2 +-
remoting/xds/client.go | 3 +-
remoting/xds/error.go | 2 +-
remoting/xds/ewatcher/ewatcher.go | 5 +-
remoting/xds/mapping/handler.go | 3 +-
remoting/zookeeper/client.go | 2 +-
.../curator_discovery/service_discovery.go | 2 +-
remoting/zookeeper/facade.go | 2 +-
remoting/zookeeper/listener.go | 2 +-
xds/balancer/cdsbalancer/cdsbalancer.go | 7 +-
xds/balancer/clusterimpl/clusterimpl.go | 7 +-
xds/balancer/clusterimpl/picker.go | 5 +-
.../clustermanager/balancerstateaggregator.go | 10 +-
xds/balancer/clustermanager/clustermanager.go | 7 +-
xds/balancer/clusterresolver/clusterresolver.go | 11 +-
xds/balancer/clusterresolver/configbuilder.go | 7 +-
xds/balancer/orca/orca.go | 3 +-
xds/balancer/priority/balancer.go | 7 +-
xds/balancer/ringhash/picker.go | 10 +-
xds/balancer/ringhash/ringhash.go | 9 +-
xds/client/authority.go | 5 +-
xds/client/bootstrap/bootstrap.go | 15 +-
xds/client/client.go | 7 +-
xds/client/controller.go | 5 +-
xds/client/controller/controller.go | 7 +-
xds/client/controller/version/v2/client.go | 7 +-
xds/client/controller/version/v3/client.go | 7 +-
xds/client/controller/version/version.go | 5 +-
xds/client/pubsub/pubsub.go | 9 +-
xds/client/resource/filter_chain.go | 7 +-
xds/client/resource/unmarshal.go | 8 +-
xds/client/resource/unmarshal_cds.go | 7 +-
xds/client/resource/unmarshal_eds.go | 7 +-
xds/client/resource/unmarshal_lds.go | 13 +-
xds/client/resource/unmarshal_rds.go | 13 +-
xds/csds/csds.go | 8 +-
xds/resolver/watch_service.go | 9 +-
xds/resolver/xds_resolver.go | 7 +-
xds/server/listener_wrapper.go | 7 +-
xds/utils/balancergroup/balancergroup.go | 7 +-
xds/utils/grpclog/grpclog.go | 2 +-
xds/utils/serviceconfig/serviceconfig.go | 6 +-
239 files changed, 1457 insertions(+), 1573 deletions(-)
rename common/{ => constant}/file/suffix.go (100%)
delete mode 100644 common/logger/file_log.yml
delete mode 100644 common/logger/logger.go
delete mode 100644 common/logger/logging.go
delete mode 100644 common/observer/event.go
delete mode 100644 common/observer/event_listener.go
delete mode 100644 common/yaml/testdata/config.yml
delete mode 100644 common/yaml/yaml.go
delete mode 100644 common/yaml/yaml_test.go
delete mode 100644 config/config_center_config_test.go
delete mode 100644 config/testdata/config/center/apollo.yaml
delete mode 100644 config/testdata/consumer_config_with_configcenter_apollo.yml
delete mode 100644 config_center/apollo/doc.go
delete mode 100644 config_center/apollo/factory.go
delete mode 100644 config_center/apollo/impl.go
delete mode 100644 config_center/apollo/impl_test.go
delete mode 100644 config_center/apollo/listener.go
delete mode 100644 config_center/apollo/mockDubbogo.yaml.json
create mode 100644 protocol/dubbo3/health/serverhealth.go
create mode 100644 protocol/dubbo3/health/triple_health_v1/health.pb.go
create mode 100644 protocol/dubbo3/health/triple_health_v1/health.proto
create mode 100644 protocol/dubbo3/health/triple_health_v1/health_triple.pb.go
rename {common/proxy => proxy}/proxy.go (99%)
rename {common/proxy => proxy}/proxy_factory.go (100%)
rename {common/proxy => proxy}/proxy_factory/default.go (98%)
rename {common/proxy => proxy}/proxy_factory/default_test.go (100%)
rename {common/proxy => proxy}/proxy_factory/pass_through.go (97%)
rename {common/proxy => proxy}/proxy_factory/pass_through_test.go (100%)
rename {common/proxy => proxy}/proxy_factory/utils.go (100%)
rename {common/proxy => proxy}/proxy_test.go (100%)