You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by fa...@apache.org on 2020/05/16 17:06:15 UTC
[dubbo-go] branch feature/protocol updated (bde7db3 -> 84b38fe)
This is an automated email from the ASF dual-hosted git repository.
fangyc pushed a change to branch feature/protocol
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from bde7db3 Merge pull request #414 from Patrick0308/gorestful-filter
add f8c3aed Mod: readme.md & change.md
add 5267222 Merge pull request #448 from fangyincheng/develop
add ce2155e Mod:enhance url init code
add 9102dd8 Mod:format code
add 7903d54 Del:rm osx in travis.yml
add 9a2cc81 Merge pull request #443 from hxmhlt/code_enhance_of_urlinit
add 09db044 Mod:release key
add c43d705 Merge pull request #452 from hxmhlt/code_enhance_of_urlinit
add 3ce0905 parent bde7db3b33067ee4115ea3f8666ec1169226a5de author pantianying <60...@qq.com> 1583982179 +0800 committer pantianying <60...@qq.com> 1584417587 +0800
add 6ee83c7 repair according to code review
add 31bc678 Improved code style
add 9edd794 complement UT
add 50a1609 code optimization
add 030a008 add comment for tagRouter Create
add ffd7685 add comment
add 4ca4e0c delete router util
add 49223eb fix import
add 9002b99 Merge pull request #415 from pantianying/tagRouter
add c0d143f add license checker
add 010b249 add license checker to travis
add 5b7790c fix travis problem
add cd23859 fix script download problem
add 334774e fix validate script problem
add 85b5500 fix validate script problem
add 21aa371 add before validate script and fix travis problem
add 59e4497 fix travis problem
add 913ebac fix travis validate license problem
add 9ec288f Merge branch 'develop' into feature/addLicenseChecker
add bdfc980 fix travis problem and test license checker
add 9900e4d add ignore file to .gitignore
add 83f1285 put validate license before before_ut.sh
add a4423a3 Update .travis.yml
add cfc29d4 Update config_reader.go
add 7fbea82 modify .gitignore
add 0a6462c debug travis
add c6b781c modify travis script
add ef257b6 modify travis script
add 2d90871 Update .travis.yml
add b4df9ad Update .gitignore
add a17dfd6 move checker to /tmp
add 4c6d523 delete old lisence
add 2a60e2b Merge pull request #433 from zouyx/feature/addLicenseChecker
add 4657f3d Add: GetInterface for rpc_service.go
add 04ee0b9 Mod: fix comments
add 1479852 Merge pull request #454 from fangyincheng/improve-rpcservice
add c25cfee optimized code
add cf0961c use adapter model to modify restServer
add f8e2978 remove adapter
add baa1125 optimize header transmit in RestClient and RestServer
add dacdada add some comments
add e7999f5 modify some comments and when parsing parameters occurred error, return error immediately
add a606b64 modify comments
add 6bd3ac6 remove new function
add dcc2d26 modify some comments
add ad958fa modify some comments and modify some logger's message
add 97c9c22 upgrade the dubbo-go architecture png
add ee40cd4 changed the architecture png
add f94b4ff changed some short naming
add b910c18 add the architecture extend png.
add 9340e82 Merge pull request #457 from Isaac-Zhang/develop
add e151ab2 Fix: bug of subscribe
add 2bdbce5 Fix: bug of subscribe
add 805ffd6 Merge pull request #462 from hxmhlt/fix_subscribe_bug
add 487c8b7 Mod: README.md
add 6c0afbe Merge pull request #463 from fangyincheng/modify-readme
add b2f70f6 Merge branch 'develop' into rest-modify
add 7a5b916 optimized code
add 183b70a remove the category
add 57c58d8 remove the reference url category
add 7ab3493 Merge pull request #460 from Patrick0308/rest-modify
add 64d8751 Fix: remove category key
add 284aa48 Merge pull request #465 from hxmhlt/rm_category_key
add e10ef06 Modify registryProtocol as a singleton to fix graceful shutdown
add d3f3af0 fix notification confusion caused by multiple references sharing the same zk listener
add db27238 fix fmt failure
add 5e99201 use the once.do to init the registryprotocol
add 8588bda use the once.do to init the registryprotocol
add 7a17cab add mutex when use subscribed map
add 43972d9 fix comments
add 2d14439 fix comments
add 319ca56 fix comments
add 52354fb fix the zk HandleClientRestart issues
add 9657b39 change some comments
add c808d5c change some comments
add 774bd01 remove unused import
add 68cc420 remove consumer category in referenceConfig
add ff0f376 fix not delete the node when shutdown gracefully and compare the path when subscribe the providers
add a530ed5 rm debug logs and fix ut
add 08e9d84 fix ut
add bda0ddc Merge pull request #432 from CodingSinger/BUG_FIX
add 0dcd48f Publish Config
add 16274df Fix import
add 4af9282 Add:metadata report config
add 5ce2598 Add necessary interface definition
add 0bf2fca Merge branch 'feature/dubbo-2.7.5' of github.com:apache/dubbo-go into service-discovery
add 23e1268 Upgrade gost
add bc31a84 Merge pull request #385 from flycash/service-discovery
add e35dffd Merge remote-tracking branch 'apache/feature/dubbo-2.7.5' into metadata_report
add dd2abb9 Add:interface definition of metadata
add 1f5bd64 Mod:recycle refer
add 28bcd48 Mod:resolve ci
add d37f512 Mod:resolve conflict
add c86b2f2 Merge pull request #405 from hxmhlt/metadata_report
add 47db94d Merge dubbo2.7.5 branch
add 2402b8e Merge develop
add 9d47547 Merge pull request #442 from flycash/devTo2.7.5
add 7382a11 Merge develop
add ffc8f7b Fix review
add c12ca7a Fix Review
add adae0d7 Add publish config method into DynamicConfiguration
add 0f17847 service name mapping support
add 21512be Fix Review
add 1167e74 Fix review
add e3e0ba9 implement the NacosServiceDiscovery
add 1aaeb4c Fix Review
add 9ab5068 Merge branch 'service-name' into nacos-discovery
add fce412d test nacos service discovery
add 6c44338 Test CRUD for instance methods
add 54d0509 Fix Review
add 0142254 Merge branch 'service-name' into nacos-discovery
add c6e1507 Tested nacos discovery
add e3a4992 Merge pull request #453 from flycash/service-name
add 5e5c43b Merge branch 'feature/dubbo-2.7.5' of github.com:apache/dubbo-go into nacos-discovery
add 093026b Add comment
add 6aedd1a rename baseRegistry to nacosBaseRegistry
add e4e5ff7 Merge pull request #461 from flycash/nacos-discovery
add ae5ec56 Merge branch 'feature/dubbo-2.7.5' into develop
add ed2fa0c Add:registry directory extension
add 54dc74a Mod: upper RegistryDirectory for inherit
add eac6b63 Add:new func type
add 6b58f6c Update registry/directory/directory.go
add 5d630ca Update registry/directory/directory.go
add 57fa801 Update registry/directory/directory.go
add 34c52a1 Update registry/directory/directory.go
add a4e9a02 Merge branch 'extension_directory' of https://github.com/hxmhlt/dubbo-go into extension_directory
add c979fca Merge pull request #466 from hxmhlt/extension_directory
add cf80d06 Update: hessian2 & getty version
add 2532b49 Mod: gofmt all go files
add d6ab9d1 Add: license header
add b330db7 Fix: add PATH_SEPARATOR
add 862bf03 Merge pull request #473 from divebomb/develop
add 68602ee add start provider with random port
add a2a3adc modify test
add 3c19887 modify start provider with random port
add cc1f480 modify start provider with random port
add 2810c63 modify test
add f9eeb8b modify random port implement
add 5076a4f fix test case error
add 74212fd modify implement
add c05e5c1 modify implement
add d7b02cd Mod: readme.md & change.md
add b9a94e5 Mod: release note
add 39098b8 Del: delete osx in .travis.yml
add 2253ad0 Merge pull request #449 from fangyincheng/1.4
add 42447f8 add license
add 320e307 Merge pull request #451 from zouyx/1.4-fix-license
add 86dfd94 update v1.4.0 tag link in readme
add c50325b add v1.4.0 link in readme
add 9e06cc2 add simplified attribute in registry config
add ef33eb1 go fmt
add 4ea624b add license
add 01bbba5 improve code
add b25b628 fix
add 0098b2b fix
add b57ba60 fix
add 71e2e17 Merge branch 'develop' into simplified
add 258a6e9 fix
add 8d92fcb go mod
add c8f66ac Merge pull request #474 from dubbo-x/simplified
add ceb0292 a little refactor
add b4df125 extract router init to func
add 5bdbf08 Merge pull request #481 from cch123/develop
add 59d0da3 merge develop to 1.4
add 50ad24f Merge pull request #486 from wongoo/1.4
add 58dd5bd Add comments for ServiceMethodLimiter
add 42dbf0d Merge pull request #490 from flycash/doc-comments
add f04c170 Mod: add comment and modify log level
add b5d169c Merge pull request #492 from fangyincheng/add-comment
add 5582a70 Add comments
add bc6cc20 Merge pull request #496 from flycash/doc-comments
add 5d7a277 Merge branch 'develop' into feature/randomPort
add af29f5b travis trigger
add e4fc89d travis trigger
add 7711df8 change variable name
add fcaa44a fix review comments
add 94414e4 fix review comments
add 24e7205 Merge pull request #476 from zouyx/feature/randomPort
add d1e6d85 filter registry url params starting with dot
add be8dd32 add unit test
add d90c20e Merge pull request #509 from CodingSinger/HIDE_KEY
add 861a9cd provider can get attachment in ctx
add c6be554 fix
add 2e0e802 delete meaningless code
add d82e10f fix ut
add 84b38fe Merge pull request #508 from pantianying/provider_getattachment_in_context
No new revisions were added by this update.
Summary of changes:
.travis.yml | 6 +-
CHANGE.md | 1 +
README.md | 15 +-
README_CN.md | 16 +-
before_validate_license.sh | 26 ++
cluster/cluster_impl/available_cluster.go | 30 +--
cluster/cluster_impl/available_cluster_invoker.go | 30 +--
.../cluster_impl/available_cluster_invoker_test.go | 30 +--
cluster/cluster_impl/broadcast_cluster.go | 30 +--
cluster/cluster_impl/broadcast_cluster_invoker.go | 30 +--
.../cluster_impl/broadcast_cluster_invoker_test.go | 30 +--
cluster/cluster_impl/failback_cluster_test.go | 30 +--
cluster/cluster_impl/failfast_cluster.go | 30 +--
cluster/cluster_impl/failfast_cluster_invoker.go | 30 +--
cluster/cluster_impl/failfast_cluster_test.go | 30 +--
cluster/cluster_impl/failsafe_cluster_test.go | 30 +--
cluster/cluster_impl/forking_cluster.go | 30 +--
cluster/cluster_impl/forking_cluster_invoker.go | 30 +--
cluster/cluster_impl/forking_cluster_test.go | 30 +--
cluster/router/condition/app_router_test.go | 2 +-
cluster/router/condition/file.go | 2 +-
cluster/router/condition/listenable_router.go | 2 +-
cluster/router/condition/router.go | 9 +-
cluster/router/condition/router_rule.go | 20 +-
cluster/router/condition/router_rule_test.go | 14 +-
cluster/router/match/match_utils.go | 63 -----
cluster/router/match/match_utils_test.go | 46 ----
cluster/router/router.go | 2 +-
cluster/router/{healthcheck => tag}/factory.go | 24 +-
.../router/tag/factory_test.go | 19 +-
cluster/router/tag/file.go | 82 ++++++
cluster/router/{condition => tag}/file_test.go | 50 ++--
cluster/router/{condition => tag}/router_rule.go | 29 +-
.../router/tag/router_rule_test.go | 17 +-
cluster/router/tag/tag_router.go | 94 +++++++
cluster/router/tag/tag_router_test.go | 147 ++++++++++
common/constant/key.go | 40 ++-
common/extension/auth.go | 17 ++
.../{loadbalance.go => metadata_report_factory.go} | 21 +-
.../{registry.go => registry_directory.go} | 24 +-
common/extension/router_factory.go | 6 +-
.../{registry.go => service_discovery.go} | 24 +-
common/proxy/proxy.go | 13 +-
common/proxy/proxy_factory.go | 2 +-
common/proxy/proxy_factory/default.go | 1 +
common/rpc_service.go | 105 ++++++--
common/rpc_service_test.go | 22 +-
common/url.go | 71 +++--
common/yaml/yaml.go | 4 +
common/yaml/yaml_test.go | 12 +
config/application_config.go | 1 +
config/config_loader.go | 210 ++++++++-------
config/config_loader_test.go | 7 +-
config/consumer_config.go | 2 +
.../instance/metedata_report.go | 26 +-
config/interfaces/config_reader.go | 17 ++
config/metadata_report_config.go | 110 ++++++++
...nfig_test.go => metadata_report_config_test.go} | 44 ++-
config/provider_config.go | 7 +-
config/reference_config.go | 9 +-
config/registry_config.go | 39 ++-
...condition_router_config.go => router_config.go} | 5 +-
...router_config_test.go => router_config_test.go} | 0
config/service_config.go | 42 ++-
config/service_config_test.go | 37 +++
config_center/apollo/factory.go | 30 +--
config_center/apollo/impl.go | 47 ++--
config_center/apollo/listener.go | 30 +--
config_center/dynamic_configuration.go | 22 +-
config_center/mock_dynamic_config.go | 11 +
config_center/nacos/impl.go | 56 +++-
config_center/nacos/impl_test.go | 17 +-
config_center/nacos/listener.go | 10 +-
config_center/zookeeper/impl.go | 54 +++-
config_center/zookeeper/impl_test.go | 21 ++
doc/pic/arch/dubbo-go-arch.png | Bin 215602 -> 131372 bytes
doc/pic/arch/dubbo-go-ext.png | Bin 0 -> 122231 bytes
filter/filter_impl/access_log_filter.go | 30 ++-
filter/filter_impl/active_filter_test.go | 17 ++
filter/filter_impl/generic_service_filter_test.go | 2 +-
filter/filter_impl/token_filter.go | 30 +--
filter/filter_impl/token_filter_test.go | 30 +--
filter/filter_impl/tps/tps_limit_strategy_mock.go | 31 +--
.../filter_impl/tps/tps_limiter_method_service.go | 25 +-
filter/filter_impl/tps/tps_limiter_mock.go | 31 +--
filter/handler/rejected_execution_handler_mock.go | 31 +--
.../handler/rejected_execution_handler_only_log.go | 6 +-
filter/rejected_execution_handler.go | 2 +
filter/tps_limit_strategy.go | 10 +-
filter/tps_limiter.go | 1 +
go.mod | 10 +-
go.sum | 22 +-
.../definition/definition.go | 31 ++-
.../configurator.go => metadata/exporter.go | 11 +-
metadata/identifier/base_metadata_identifier.go | 92 +++++++
.../identifier/metadata_identifier.go | 27 +-
.../identifier/service_metadata_identifier.go | 27 +-
.../identifier/subscribe_metadata_identifier.go | 21 +-
.../namemapping/dynamic/service_name_mapping.go | 82 ++++++
.../dynamic/service_name_mapping_test.go | 44 ++-
.../namemapping/memory/service_name_mapping.go | 22 +-
.../health_checker.go => metadata/report.go | 29 +-
.../configurator.go => metadata/report_factory.go | 12 +-
.../proxy/proxy_factory.go => metadata/service.go | 24 +-
.../service_name_mapping.go | 25 +-
protocol/dubbo/client.go | 27 +-
protocol/dubbo/client_test.go | 2 +-
protocol/dubbo/codec.go | 10 +-
protocol/dubbo/config.go | 6 +-
protocol/dubbo/dubbo_exporter.go | 9 +-
protocol/dubbo/dubbo_invoker.go | 13 +-
protocol/dubbo/dubbo_protocol.go | 12 +-
protocol/dubbo/listener.go | 4 +-
protocol/dubbo/readwriter.go | 10 +-
protocol/dubbo/server.go | 19 +-
protocol/grpc/client.go | 30 +--
protocol/grpc/client_test.go | 30 +--
protocol/grpc/common_test.go | 30 +--
protocol/grpc/grpc_exporter.go | 33 +--
protocol/grpc/grpc_invoker.go | 30 +--
protocol/grpc/grpc_invoker_test.go | 30 +--
protocol/grpc/grpc_protocol.go | 30 +--
protocol/grpc/grpc_protocol_test.go | 30 +--
protocol/grpc/internal/client.go | 30 +--
protocol/grpc/internal/doc.go | 30 +--
protocol/grpc/internal/helloworld.pb.go | 30 +--
protocol/grpc/internal/server.go | 30 +--
.../protoc-gen-dubbo/examples/helloworld.pb.go | 30 +--
protocol/grpc/protoc-gen-dubbo/main.go | 30 +--
protocol/grpc/protoc-gen-dubbo/plugin/dubbo/doc.go | 30 +--
.../grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go | 30 +--
protocol/grpc/server.go | 30 +--
protocol/jsonrpc/http_test.go | 2 +-
protocol/jsonrpc/jsonrpc_exporter.go | 3 +-
protocol/jsonrpc/jsonrpc_invoker_test.go | 2 +-
protocol/mock/mock_invoker.go | 31 +--
protocol/rest/client/client_impl/resty_client.go | 16 +-
protocol/rest/client/rest_client.go | 12 +-
protocol/rest/rest_exporter.go | 3 +-
protocol/rest/rest_invoker.go | 26 +-
protocol/rest/rest_invoker_test.go | 4 +-
protocol/rest/rest_protocol.go | 4 +-
protocol/rest/rest_protocol_test.go | 4 +-
protocol/rest/server/rest_server.go | 297 ++++++++++++++++++++-
.../rest/server/server_impl/go_restful_server.go | 291 +++++---------------
protocol/rpc_status_test.go | 17 ++
registry/base_registry.go | 19 +-
registry/directory/directory.go | 74 +++--
registry/directory/directory_test.go | 15 +-
registry/etcdv3/registry.go | 4 +-
registry/etcdv3/registry_test.go | 2 +-
registry/event.go | 67 ++++-
registry/{event.go => event_listener.go} | 35 ++-
registry/kubernetes/registry.go | 5 +-
registry/nacos/base_registry.go | 102 +++++++
registry/nacos/registry.go | 64 +----
registry/nacos/service_discovery.go | 285 ++++++++++++++++++++
registry/nacos/service_discovery_test.go | 122 +++++++++
registry/protocol/protocol.go | 51 +++-
registry/protocol/protocol_test.go | 9 +
registry/service_discovery.go | 86 ++++++
registry/service_instance.go | 89 ++++++
registry/zookeeper/listener.go | 71 +++--
registry/zookeeper/listener_test.go | 8 +-
registry/zookeeper/registry.go | 96 ++++---
registry/zookeeper/registry_test.go | 2 +-
remoting/zookeeper/client.go | 24 +-
remoting/zookeeper/facade.go | 4 +-
remoting/zookeeper/facade_test.go | 12 +-
remoting/zookeeper/listener.go | 22 +-
remoting/zookeeper/listener_test.go | 2 +-
171 files changed, 3848 insertions(+), 1806 deletions(-)
create mode 100644 before_validate_license.sh
delete mode 100644 cluster/router/match/match_utils.go
delete mode 100644 cluster/router/match/match_utils_test.go
copy cluster/router/{healthcheck => tag}/factory.go (61%)
copy config_center/parser/configuration_parser_test.go => cluster/router/tag/factory_test.go (68%)
create mode 100644 cluster/router/tag/file.go
copy cluster/router/{condition => tag}/file_test.go (53%)
copy cluster/router/{condition => tag}/router_rule.go (71%)
copy config/metric_config_test.go => cluster/router/tag/router_rule_test.go (75%)
create mode 100644 cluster/router/tag/tag_router.go
create mode 100644 cluster/router/tag/tag_router_test.go
copy common/extension/{loadbalance.go => metadata_report_factory.go} (59%)
copy common/extension/{registry.go => registry_directory.go} (60%)
copy common/extension/{registry.go => service_discovery.go} (56%)
copy filter/handler/rejected_execution_handler_only_log_test.go => config/instance/metedata_report.go (67%)
create mode 100644 config/metadata_report_config.go
copy config/{graceful_shutdown_config_test.go => metadata_report_config_test.go} (55%)
rename config/{condition_router_config.go => router_config.go} (89%)
rename config/{condition_router_config_test.go => router_config_test.go} (100%)
create mode 100644 doc/pic/arch/dubbo-go-ext.png
copy config/generic_service.go => metadata/definition/definition.go (61%)
copy config_center/configurator.go => metadata/exporter.go (84%)
create mode 100644 metadata/identifier/base_metadata_identifier.go
copy config/mock_rpcservice.go => metadata/identifier/metadata_identifier.go (65%)
copy filter/handler/rejected_execution_handler_only_log_test.go => metadata/identifier/service_metadata_identifier.go (61%)
copy config_center/configurator.go => metadata/identifier/subscribe_metadata_identifier.go (65%)
create mode 100644 metadata/namemapping/dynamic/service_name_mapping.go
copy filter/filter_impl/auth/accesskey_storage_test.go => metadata/namemapping/dynamic/service_name_mapping_test.go (50%)
copy config/mock_rpcservice.go => metadata/namemapping/memory/service_name_mapping.go (63%)
copy common/extension/health_checker.go => metadata/report.go (54%)
copy config_center/configurator.go => metadata/report_factory.go (84%)
copy common/proxy/proxy_factory.go => metadata/service.go (57%)
copy cluster/cluster_impl/failsafe_cluster.go => metadata/service_name_mapping.go (61%)
copy registry/{event.go => event_listener.go} (57%)
create mode 100644 registry/nacos/base_registry.go
create mode 100644 registry/nacos/service_discovery.go
create mode 100644 registry/nacos/service_discovery_test.go
create mode 100644 registry/service_discovery.go
create mode 100644 registry/service_instance.go