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 <601666...@qq.com> 1583982179 +0800 committer pantianying <601666...@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