This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
from b7e348319 build(deps): bump github.com/emicklei/go-restful/v3 from
3.7.4 to 3.8.0 (#1929)
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)
new c62236c0c Merge branch 'master' of https://github.com/apache/dubbo-go
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:
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 | 14 +-
go.sum | 70 +++--
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, 1454 insertions(+), 1570 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%)
