[dubbo-go] branch develop updated (81026a3 -> fdc9fd2)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 81026a3 Merge pull request #648 from pantianying/develop-fix-zk-noevent new 8c42b4c In memory service discovery support new c15a725 Add in-memory service-discovery support new 95b4658 align 2.7.8: direct event dispatcher new 259e3c1 dispatcher in extension new 8e2adc5 add unit test and move extension to observer new 357f536 fix import new ea24b17 add default eventDispatch type and handle eventType is ptr new 2925dd3 modify some comments and optimize code new a782838 optimize some code and fix imports new 2622827 move global dispatcher to extension package new a594afd Merge pull request #470 from apache/develop new 045f7f5 Merge remote-tracking branch 'upstream/feature/dubbo-2.7.5' into align-2.7.5 new b30bea6 Merge remote-tracking branch 'upstream/feature/dubbo-2.7.5' into align-2.7.5 new eca5628 fix imports new a8871fd modify and add licenses new a4ee287 Merge pull request #455 from Patrick0308/align-2.7.5 new 7c20ad3 Merge branch 'feature/dubbo-2.7.5' of github.com:apache/dubbo-go into inmemory-service-discovery new 6707dfb Fix format new 422b678 Merge pull request #469 from flycash/inmemory-service-discovery new 6e574cc Add:format dir new 79218a1 Mod:resolve conflict new 4cced63 Merge branch 'code_enhance_of_urlinit' into metadata_report new 485cd5f Mod:format mod new 690333b Mod:resolve conflict new 8cc8060 Merge branch 'feature/dubbo-2.7.5' into metadata_report new 0b0fde8 Add: add exporter new 8d3329f Merge branch 'develop' into metadata_report new 6a9591a Add:identifier ut new b3dddc8 Mod: move service name mapping new 863dd0f Mod:make ut run new 207e246 Mod:resolve conflict new 74d6dd9 Mod:format new dc405a7 Add:liscense new ef06c72 Mod:dir rename new 5d380d0 Mod:import pkg rename new f580027 Mod:rw problem new 851966e Merge branch 'feature/dubbo-2.7.5' into metadata_report new ace7899 Mod:rw problem new 4521e09 Mod:rw problem new 66aa1a0 Mod:rw problem new ad995d8 Add:add for resolve rw new 5067dae Mod:treeset to skiplist new f595f50 Mod:resolve conflict new 370681a Merge pull request #471 from hxmhlt/metadata_report new 5b10451 implement GetConfigKeysByGroup new c8920d3 Fix travis new c556232 Merge pull request #475 from flycash/nacos-batch-bk new 530f563 Implement event dispatcher new f09c991 Add extensiong for metadata service new ad18357 Merge pull request #1 from apache/feature/dubbo-2.7.5 new 5811136 Merge remote-tracking branch 'origin/feature/dubbo-2.7.5' into feature/dubbo-2.7.5 new ae7d706 support service discovery registry new 8022392 fix synthesizer bug new 71326c9 Merge branch 'feature/dubbo-2.7.5' of https://github.com/lzp0412/dubbo-go into 2.7.5-bk new 682f405 Add dynamic new a5da721 rename service => service discovery new 8b720aa Merge develop new 9b41e95 Merge pull request #497 from flycash/2.7.5 new 59365ec Merge develop new 212d886 merge develop new 6a558d8 Merge pull request #500 from flycash/2.7.5 new ffe69ca Merge branch 'feature/dubbo-2.7.5' of github.com:apache/dubbo-go into 2.7.5-bk new 08eb340 Export get BaseConfig new 4b8b4d7 Refactor service-discovery new 3aa0082 Merge pull request #2 from flycash/2.7.5-bk new 569e2b6 1、add comments 2、format imports new bcda4de fix review comments new 698c2b2 Merge remote-tracking branch 'remotes/dubbo-go/feature/dubbo-2.7.5' into feature/dubbo-2.7.5 new 1113bf1 Merge 2.7.5 new 3f1a52b Merge pull request #4 from flycash/2.7.5-bk new a784557 Add tests new 266e0b6 Add extensiong for metadata service new ed5693f Merge pull request #5 from flycash/2.7.5-bk new e73f3bf fix impl_test error new 393d12a fix import error new aaeabc6 fix import error new b87dbe2 Add:metadata report delegate & remote metadata service new 73f21fa Mod:for ut new f7dd531 Mod:resolve conflict new 2ac672f event_publishing_service_discovery.go init new 839e0dd add EventPublishingServiceDiscovery constructor new 3189b65 Merge remote-tracking branch 'upstream/feature/dubbo-2.7.5' into eventDispatchServiceDiscovery new a4cef09 Merge remote-tracking branch 'upstream/feature/dubbo-2.7.5' into eventDispatchServiceDiscovery new 99ac8c5 add Event new 2938f51 optimize code new ada27e2 add unit tests and modify event struct new 9f7e1f3 fix imports new c958389 Merge pull request #487 from Patrick0308/eventDispatchServiceDiscovery new 9788244 Merge
[dubbo-go] branch develop updated (9697b2b -> 547c299)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 9697b2b Merge pull request #641 from coffeehc/develop new 5ec0519 Merge pull request #15 from apache/develop new d32161e update nacos sdk version new 75776fb fix unitTest bug new 547c299 Merge pull request #646 from lzp0412/develop The 2243 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: common/constant/key.go | 2 + common/url.go | 5 +- config_center/nacos/client.go | 95 -- config_center/nacos/client_test.go | 2 +- go.mod | 16 ++- go.sum | 14 +++--- registry/nacos/base_registry.go| 3 ++ 7 files changed, 60 insertions(+), 77 deletions(-)
[dubbo-go] branch master updated: fix user images error
This is an automated email from the ASF dual-hosted git repository. flycash pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/dubbo-go.git The following commit(s) were added to refs/heads/master by this push: new 6950060 fix user images error new 2c830f7 Merge pull request #609 from zouyx/fix-logo-error 6950060 is described below commit 69500606908735823fa09d641e656ea8fb2ab14d Author: Joe Zou AuthorDate: Tue Jun 16 11:06:00 2020 +0800 fix user images error --- README.md| 2 +- README_CN.md | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index 0de082e..26e2ae8 100644 --- a/README.md +++ b/README.md @@ -188,7 +188,7 @@ If you are using [apache/dubbo-go](github.com/apache/dubbo-go) and think that it - https://raw.githubusercontent.com/dajiiu/photo/static/mirror/haozhuo_logo.png;> + https://user-images.githubusercontent.com/52339367/84628582-80512200-af1b-11ea-945a-c6b4b9ad31f2.png;> diff --git a/README_CN.md b/README_CN.md index 05a7a20..9770108 100644 --- a/README_CN.md +++ b/README_CN.md @@ -185,7 +185,7 @@ go test ./... -coverprofile=coverage.txt -covermode=atomic - https://raw.githubusercontent.com/dajiiu/photo/static/mirror/haozhuo_logo.png;> + https://user-images.githubusercontent.com/52339367/84628582-80512200-af1b-11ea-945a-c6b4b9ad31f2.png;>
[dubbo-go] branch develop updated (93a655f -> 1f66772)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 93a655f Merge pull request #602 from zouyx/feature/addProtocolComment new 5db2e24 Mod: add comments for remoting directory new 7537535 Mod: modify inappropriate comments after review new 1f66772 Merge pull request #605 from watermelo/featue/addCommentForRemoting The 2193 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: registry/etcdv3/registry.go| 6 ++-- remoting/etcdv3/client.go | 48 ++--- remoting/etcdv3/facade.go | 2 +- remoting/etcdv3/listener.go| 18 +-- remoting/kubernetes/client.go | 31 ++- remoting/kubernetes/listener.go| 8 ++--- remoting/kubernetes/registry_controller.go | 26 ++-- remoting/kubernetes/watch.go | 23 +- remoting/listener.go | 12 remoting/zookeeper/client.go | 49 +- remoting/zookeeper/facade.go | 2 +- remoting/zookeeper/listener.go | 10 +++--- 12 files changed, 100 insertions(+), 135 deletions(-)
[dubbo-go] branch feature/dubbo-2.7.5 updated (ff9eec7 -> 669301f)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/dubbo-2.7.5 in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from ff9eec7 Merge pull request #578 from zouyx/feature/addRegistryUnpub new df1a43d Finish code new 7c87c2a Merge branch 'feature/dubbo-2.7.5' of https://github.com/apache/dubbo-go into nacos-meta new bdd9b71 Add UT new 5f0084a Fix review new d997d51 fix review new 669301f Merge pull request #522 from flycash/nacos-meta The 2116 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: metadata/report/nacos/report.go| 202 + metadata/report/nacos/report_test.go | 115 registry/nacos/base_registry.go| 59 +- .../base_registry.go => remoting/nacos/builder.go | 51 +++--- 4 files changed, 344 insertions(+), 83 deletions(-) create mode 100644 metadata/report/nacos/report.go create mode 100644 metadata/report/nacos/report_test.go copy registry/nacos/base_registry.go => remoting/nacos/builder.go (68%)
[dubbo-go] branch develop updated (36076fa -> 4dac621)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 36076fa Merge pull request #586 from williamfeng323/feature/filter-comment-optimise new 044b134 improve nacos config-center and the parser of config-center code coverage new baf103d add dynamic_configuration_test.go and modify client_test.go new 4dac621 Merge pull request #587 from Patrick0308/config-center-nacos-parser-cover The 2156 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: .../dynamic_configuration_test.go | 21 +--- config_center/nacos/client_test.go | 59 ++ config_center/nacos/impl_test.go | 5 +- config_center/parser/configuration_parser_test.go | 55 4 files changed, 130 insertions(+), 10 deletions(-) copy cluster/router/tag/factory_test.go => config_center/dynamic_configuration_test.go (68%)
[dubbo-go] branch develop updated (a7af538 -> 106040d)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from a7af538 Merge pull request #584 from watermelo/featue/addCommentForCluster new 02e1ee4 Merge pull request #7 from apache/develop new b98f88c Add WIP tag new 7ab58c5 dubboRegisterController is abstracted, waiting for integration new c627aa7 clean code new 85308a1 add Run method for Client new 2a3c924 Add more rich debug log new 0d353db Add default namespace for watchedNamespaceList new fee3f3f init map new 78acb11 Wait fix bug, and print store content new 54191b5 add init watch-set method: new 590e6be add cache store debug new 65d7aec delete unused log new 8ea242c Wait for test new 5ba301c init need watched namespaces map new 775857c Finish ut for kubernetes new 3054b7f Cancel Provider's ListAndWatch function new 1669155 Add more comment for code new 667f4a0 provider and consumer pod use different label new f96091b fmt code new 16d4e8d reformart import block and add licence for new file new d07ebbc Fix comment and delete unreachable code new 9607894 Add more comment new 0f9a717 remove unused code new 106040d Merge pull request #577 from sxllwx/k8s_enhance The 2148 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: registry/kubernetes/listener.go| 2 +- registry/kubernetes/listener_test.go | 74 +--- registry/kubernetes/registry.go| 9 +- registry/kubernetes/registry_test.go | 253 ++-- remoting/kubernetes/client.go | 577 +++ remoting/kubernetes/client_test.go | 404 +-- remoting/kubernetes/facade.go | 3 + remoting/kubernetes/facade_test.go | 34 +- remoting/kubernetes/listener.go| 2 - remoting/kubernetes/listener_test.go | 10 +- remoting/kubernetes/registry_controller.go | 604 + remoting/kubernetes/watch.go | 37 +- remoting/listener.go | 2 +- remoting/zookeeper/client_test.go | 1 - test/integrate/dubbo/go-client/go.sum | 389 --- 15 files changed, 1116 insertions(+), 1285 deletions(-) create mode 100644 remoting/kubernetes/registry_controller.go delete mode 100644 test/integrate/dubbo/go-client/go.sum
[dubbo-go] branch develop updated (fdf51a1 -> d2eee54)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from fdf51a1 Merge pull request #529 from georgehao/feat/issue514-fix-shadow-analysis new dd2ff3e remove lock from url new 0f64e2c format code new f763779 Merge develop and resolve conflict new d2eee54 Merge pull request #519 from flycash/remove-url-lock The 2079 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: common/url.go | 103 ++--- config_center/configurator/override.go | 11 ++-- registry/protocol/protocol.go | 30 +- 3 files changed, 73 insertions(+), 71 deletions(-)
[dubbo-go] branch develop updated (84b38fe -> 99f6cf4)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 84b38fe Merge pull request #508 from pantianying/provider_getattachment_in_context new 544036a Merge pull request #1 from apache/develop new ebb1b0c Fix “compile errors caused by unsupported import packages” new cb9045c Fix “uncheck travis rules of go fmt” new 99f6cf4 Merge pull request #515 from xianlezheng/develop The 2016 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: go.mod | 2 -- go.sum | 4 registry/etcdv3/listener_test.go | 2 +- remoting/etcdv3/client_test.go | 2 +- 4 files changed, 2 insertions(+), 8 deletions(-)
[dubbo-go] branch feature/dubbo-2.7.5 updated: Implement event dispatcher
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a commit to branch feature/dubbo-2.7.5
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/feature/dubbo-2.7.5 by this
push:
new 530f563 Implement event dispatcher
new 9b41e95 Merge pull request #497 from flycash/2.7.5
530f563 is described below
commit 530f563498bcbb9b568cf86393c7bf85df2eb775
Author: flycash
AuthorDate: Tue Apr 28 22:23:47 2020 +0800
Implement event dispatcher
---
.../observer/dispatcher/mock_event_dispatcher.go | 58 ++
go.mod | 2 +-
go.sum | 2 +
registry/nacos/service_discovery.go| 2 +-
registry/nacos/service_discovery_test.go | 17 +--
5 files changed, 75 insertions(+), 6 deletions(-)
diff --git a/common/observer/dispatcher/mock_event_dispatcher.go
b/common/observer/dispatcher/mock_event_dispatcher.go
new file mode 100644
index 000..45cdaa7
--- /dev/null
+++ b/common/observer/dispatcher/mock_event_dispatcher.go
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package dispatcher
+
+import (
+ "github.com/apache/dubbo-go/common/observer"
+)
+
+// MockEventDispatcher will do nothing.
+// It is only used by tests
+// Now the implementation doing nothing,
+// But you can modify this if needed
+type MockEventDispatcher struct {
+}
+
+// AddEventListener do nothing
+func (m MockEventDispatcher) AddEventListener(listener observer.EventListener)
{
+}
+
+// AddEventListeners do nothing
+func (m MockEventDispatcher) AddEventListeners(listenersSlice
[]observer.EventListener) {
+}
+
+// RemoveEventListener do nothing
+func (m MockEventDispatcher) RemoveEventListener(listener
observer.EventListener) {
+}
+
+// RemoveEventListeners do nothing
+func (m MockEventDispatcher) RemoveEventListeners(listenersSlice
[]observer.EventListener) {
+}
+
+// GetAllEventListeners return empty list
+func (m MockEventDispatcher) GetAllEventListeners() []observer.EventListener {
+ return make([]observer.EventListener, 0)
+}
+
+// RemoveAllEventListeners do nothing
+func (m MockEventDispatcher) RemoveAllEventListeners() {
+}
+
+// Dispatch do nothing
+func (m MockEventDispatcher) Dispatch(event observer.Event) {
+}
diff --git a/go.mod b/go.mod
index 40e4aea..1c3c52d 100644
--- a/go.mod
+++ b/go.mod
@@ -29,7 +29,7 @@ require (
github.com/magiconair/properties v1.8.1
github.com/mitchellh/mapstructure v1.1.2
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd
- github.com/nacos-group/nacos-sdk-go v0.3.0
+ github.com/nacos-group/nacos-sdk-go v0.3.1
github.com/opentracing/opentracing-go v1.1.0
github.com/pkg/errors v0.9.1
github.com/prometheus/client_golang v1.1.0
diff --git a/go.sum b/go.sum
index ff5a38a..22370ce 100644
--- a/go.sum
+++ b/go.sum
@@ -388,6 +388,8 @@ github.com/nacos-group/nacos-sdk-go
v0.0.0-20191128082542-fe1b325b125c h1:WoCa3A
github.com/nacos-group/nacos-sdk-go v0.0.0-20191128082542-fe1b325b125c/go.mod
h1:CEkSvEpoveoYjA81m4HNeYQ0sge0LFGKSEqO3JKHllo=
github.com/nacos-group/nacos-sdk-go v0.3.0
h1:2v2QmihtyX6ZUXAN+ya+5h2pedn7R5M+WJwSJPFsuMY=
github.com/nacos-group/nacos-sdk-go v0.3.0/go.mod
h1:ESKb6yF0gxSc8GuS+0jaMBe+n8rJ5/k4ya6LyFG2xi8=
+github.com/nacos-group/nacos-sdk-go v0.3.1
h1:MI7bNDAN5m9UFcRRUTSPfJi4dCQo+TYG85qVB1rCHeg=
+github.com/nacos-group/nacos-sdk-go v0.3.1/go.mod
h1:ESKb6yF0gxSc8GuS+0jaMBe+n8rJ5/k4ya6LyFG2xi8=
github.com/nicolai86/scaleway-sdk v1.10.2-0.20180628010248-798f60e20bb2
h1:BQ1HW7hr4IVovMwWg0E0PYcyW8CzqDcVmaew9cujU4s=
github.com/nicolai86/scaleway-sdk v1.10.2-0.20180628010248-798f60e20bb2/go.mod
h1:TLb2Sg7HQcgGdloNxkrmtgDNR9uVYF3lfdFIN4Ro6Sk=
github.com/oklog/run v0.0.0-20180308005104-6934b124db28
h1:Hbr3fbVPXea52oPQeP7KLSxP52g6SFaNY1IqAmUyEW0=
diff --git a/registry/nacos/service_discovery.go
b/registry/nacos/service_discovery.go
index 7d3406c..fbd84ac 100644
--- a/registry/nacos/service_discovery.go
+++ b/registry/nacos/service_discovery.go
@@ -237,7 +237,7 @@
[dubbo-go] branch develop updated: Add comments
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/develop by this push:
new 5582a70 Add comments
new bc6cc20 Merge pull request #496 from flycash/doc-comments
5582a70 is described below
commit 5582a70b0aef386ca2a83f32833e8211490259a6
Author: flycash
AuthorDate: Mon Apr 27 22:13:08 2020 +0800
Add comments
---
filter/filter_impl/access_log_filter.go| 30 ++
.../handler/rejected_execution_handler_only_log.go | 6 +++--
filter/rejected_execution_handler.go | 2 ++
filter/tps_limit_strategy.go | 10 ++--
4 files changed, 39 insertions(+), 9 deletions(-)
diff --git a/filter/filter_impl/access_log_filter.go
b/filter/filter_impl/access_log_filter.go
index fbfe756..49cdc22 100644
--- a/filter/filter_impl/access_log_filter.go
+++ b/filter/filter_impl/access_log_filter.go
@@ -71,14 +71,18 @@ func init() {
*
* the value of "accesslog" can be "true" or "default" too.
* If the value is one of them, the access log will be record in log file
which defined in log.yml
+ * AccessLogFilter is designed to be singleton
*/
type AccessLogFilter struct {
logChan chan AccessLogData
}
-// Invoke ...
+// Invoke will check whether user wants to use this filter.
+// If we find the value of key constant.ACCESS_LOG_KEY, we will log the
invocation info
func (ef *AccessLogFilter) Invoke(ctx context.Context, invoker
protocol.Invoker, invocation protocol.Invocation) protocol.Result {
accessLog := invoker.GetUrl().GetParam(constant.ACCESS_LOG_KEY, "")
+
+ // the user do not
if len(accessLog) > 0 {
accessLogData := AccessLogData{data:
ef.buildAccessLogData(invoker, invocation), accessLog: accessLog}
ef.logIntoChannel(accessLogData)
@@ -86,7 +90,7 @@ func (ef *AccessLogFilter) Invoke(ctx context.Context,
invoker protocol.Invoker,
return invoker.Invoke(ctx, invocation)
}
-// it won't block the invocation
+// logIntoChannel won't block the invocation
func (ef *AccessLogFilter) logIntoChannel(accessLogData AccessLogData) {
select {
case ef.logChan <- accessLogData:
@@ -97,6 +101,7 @@ func (ef *AccessLogFilter) logIntoChannel(accessLogData
AccessLogData) {
}
}
+// buildAccessLogData builds the access log data
func (ef *AccessLogFilter) buildAccessLogData(_ protocol.Invoker, invocation
protocol.Invocation) map[string]string {
dataMap := make(map[string]string, 16)
attachments := invocation.Attachments()
@@ -130,11 +135,12 @@ func (ef *AccessLogFilter) buildAccessLogData(_
protocol.Invoker, invocation pro
return dataMap
}
-// OnResponse ...
+// OnResponse do nothing
func (ef *AccessLogFilter) OnResponse(_ context.Context, result
protocol.Result, _ protocol.Invoker, _ protocol.Invocation) protocol.Result {
return result
}
+// writeLogToFile actually write the logs into file
func (ef *AccessLogFilter) writeLogToFile(data AccessLogData) {
accessLog := data.accessLog
if isDefault(accessLog) {
@@ -156,6 +162,12 @@ func (ef *AccessLogFilter) writeLogToFile(data
AccessLogData) {
}
}
+// openLogFile will open the log file with append mode.
+// If the file is not found, it will create the file.
+// Actually, the accessLog is the filename
+// You may find out that, once we want to write access log into log file,
+// we open the file again and again.
+// It needs to be optimized.
func (ef *AccessLogFilter) openLogFile(accessLog string) (*os.File, error) {
logFile, err := os.OpenFile(accessLog,
os.O_CREATE|os.O_APPEND|os.O_RDWR, LogFileMode)
if err != nil {
@@ -169,6 +181,12 @@ func (ef *AccessLogFilter) openLogFile(accessLog string)
(*os.File, error) {
return nil, err
}
last := fileInfo.ModTime().Format(FileDateFormat)
+
+ // this is confused.
+ // for example, if the last = '2020-03-04'
+ // and today is '2020-03-05'
+ // we will create one new file to log access data
+ // By this way, we can split the access log based on days.
if now != last {
err = os.Rename(fileInfo.Name(), fileInfo.Name()+"."+now)
if err != nil {
@@ -180,11 +198,12 @@ func (ef *AccessLogFilter) openLogFile(accessLog string)
(*os.File, error) {
return logFile, err
}
+// isDefault check whether accessLog == true or accessLog == default
func isDefault(accessLog string) bool {
return strings.EqualFold("true", accessLog) ||
strings.EqualFold("default", accessLog)
}
-// GetAccessLogFilter ...
+// GetAccessLogFilter return the instance of AccessLogFilter
func GetAccessLogFilter() filter.Filter {
accessLog
[dubbo-go] branch develop updated: Mod: add comment and modify log level
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/develop by this push:
new f04c170 Mod: add comment and modify log level
new b5d169c Merge pull request #492 from fangyincheng/add-comment
f04c170 is described below
commit f04c1702f3d24894dc99e4c23bae04aa07b12fb7
Author: fangyincheng
AuthorDate: Sat Apr 25 19:27:43 2020 +0800
Mod: add comment and modify log level
---
common/proxy/proxy.go| 7 +++
common/proxy/proxy_factory.go| 2 +-
common/rpc_service.go| 23 +++
common/url.go| 4 ++--
protocol/dubbo/client.go | 27 ---
protocol/dubbo/codec.go | 10 +-
protocol/dubbo/config.go | 6 +++---
protocol/dubbo/dubbo_exporter.go | 6 +++---
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 +--
13 files changed, 71 insertions(+), 72 deletions(-)
diff --git a/common/proxy/proxy.go b/common/proxy/proxy.go
index 68ba3ff..f98a448 100644
--- a/common/proxy/proxy.go
+++ b/common/proxy/proxy.go
@@ -44,7 +44,7 @@ var (
typError = reflect.Zero(reflect.TypeOf((*error)(nil)).Elem()).Type()
)
-// NewProxy ...
+// NewProxy create service proxy.
func NewProxy(invoke protocol.Invoker, callBack interface{}, attachments
map[string]string) *Proxy {
return {
invoke: invoke,
@@ -59,7 +59,6 @@ func NewProxy(invoke protocol.Invoker, callBack interface{},
attachments map[str
// type XxxProvider struct {
// Yyy func(ctx context.Context, args []interface{}, rsp *Zzz)
error
// }
-
func (p *Proxy) Implement(v common.RPCService) {
// check parameters, incoming interface must be a elem's pointer.
@@ -202,12 +201,12 @@ func (p *Proxy) Implement(v common.RPCService) {
}
-// Get ...
+// Get get rpc service instance.
func (p *Proxy) Get() common.RPCService {
return p.rpc
}
-// GetCallback ...
+// GetCallback get callback.
func (p *Proxy) GetCallback() interface{} {
return p.callBack
}
diff --git a/common/proxy/proxy_factory.go b/common/proxy/proxy_factory.go
index 7b249a3..34fa3fd 100644
--- a/common/proxy/proxy_factory.go
+++ b/common/proxy/proxy_factory.go
@@ -22,7 +22,7 @@ import (
"github.com/apache/dubbo-go/protocol"
)
-// ProxyFactory ...
+// ProxyFactory interface.
type ProxyFactory interface {
GetProxy(invoker protocol.Invoker, url *common.URL) *Proxy
GetAsyncProxy(invoker protocol.Invoker, callBack interface{}, url
*common.URL) *Proxy
diff --git a/common/rpc_service.go b/common/rpc_service.go
index ebd1d02..d7d9007 100644
--- a/common/rpc_service.go
+++ b/common/rpc_service.go
@@ -59,7 +59,6 @@ type AsyncCallback func(response CallbackResponse)
// return map[string][string]{}
// }
const (
- // METHOD_MAPPER ...
METHOD_MAPPER = "MethodMapper"
)
@@ -68,7 +67,7 @@ var (
// because Typeof takes an empty interface value. This is annoying.
typeOfError = reflect.TypeOf((*error)(nil)).Elem()
- // ServiceMap ...
+ // ServiceMap store description of service.
// todo: lowerecas?
ServiceMap = {
serviceMap: make(map[string]map[string]*Service),
@@ -80,7 +79,7 @@ var (
// info of method
//
-// MethodType ...
+// MethodType is description of service method.
type MethodType struct {
methodreflect.Method
ctxType reflect.Type // request context
@@ -88,27 +87,27 @@ type MethodType struct {
replyType reflect.Type // return value, otherwise it is nil
}
-// Method ...
+// Method get @m.method.
func (m *MethodType) Method() reflect.Method {
return m.method
}
-// CtxType ...
+// CtxType get @m.ctxType.
func (m *MethodType) CtxType() reflect.Type {
return m.ctxType
}
-// ArgsType ...
+// ArgsType get @m.argsType.
func (m *MethodType) ArgsType() []reflect.Type {
return m.argsType
}
-// ReplyType ...
+// ReplyType get @m.replyType.
func (m *MethodType) ReplyType() reflect.Type {
return m.replyType
}
-// SuiteContext ...
+// SuiteContext tranfer @ctx to reflect.Value type or get it from @m.ctxType.
func (m *MethodType) SuiteContext(ctx context.Context) reflect.Value {
if contextv := reflect.ValueOf(ctx); contextv.IsValid() {
return contextv
@@ -120,7 +119,7 @@ func (m *MethodType) SuiteContext(ctx context.Context)
reflect.Value {
// info of service interface
//
-// Service ...
+// Service is description of service
[dubbo-go] branch feature/dubbo-2.7.5 updated (370681a -> c556232)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/dubbo-2.7.5 in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 370681a Merge pull request #471 from hxmhlt/metadata_report new 5b10451 implement GetConfigKeysByGroup new c8920d3 Fix travis new c556232 Merge pull request #475 from flycash/nacos-batch-bk The 1991 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: config_center/nacos/impl.go | 25 + config_center/nacos/impl_test.go | 30 +- go.mod | 16 +++- go.sum | 6 ++ 4 files changed, 59 insertions(+), 18 deletions(-)
[dubbo-go] branch develop updated: Add comments for ServiceMethodLimiter
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/develop by this push:
new 58dd5bd Add comments for ServiceMethodLimiter
new 42dbf0d Merge pull request #490 from flycash/doc-comments
58dd5bd is described below
commit 58dd5bdc4ee99bf1b1191562f0e4a6133ed87603
Author: flycash
AuthorDate: Thu Apr 23 21:53:15 2020 +0800
Add comments for ServiceMethodLimiter
---
.../filter_impl/tps/tps_limiter_method_service.go | 25 --
filter/tps_limiter.go | 1 +
2 files changed, 24 insertions(+), 2 deletions(-)
diff --git a/filter/filter_impl/tps/tps_limiter_method_service.go
b/filter/filter_impl/tps/tps_limiter_method_service.go
index 7fe8de9..2d44c68 100644
--- a/filter/filter_impl/tps/tps_limiter_method_service.go
+++ b/filter/filter_impl/tps/tps_limiter_method_service.go
@@ -115,7 +115,12 @@ type MethodServiceTpsLimiterImpl struct {
tpsState *concurrent.Map
}
-// IsAllowable ...
+// IsAllowable based on method-level and service-level.
+// The method-level has high priority which means that if there is any rate
limit configuration for the method,
+// the service-level rate limit strategy will be ignored.
+// The key point is how to keep thread-safe
+// This implementation use concurrent map + loadOrStore to make implementation
thread-safe
+// You can image that even multiple threads create limiter, but only one could
store the limiter into tpsState
func (limiter MethodServiceTpsLimiterImpl) IsAllowable(url common.URL,
invocation protocol.Invocation) bool {
methodConfigPrefix := "methods." + invocation.MethodName() + "."
@@ -123,23 +128,30 @@ func (limiter MethodServiceTpsLimiterImpl)
IsAllowable(url common.URL, invocatio
methodLimitRateConfig :=
url.GetParam(methodConfigPrefix+constant.TPS_LIMIT_RATE_KEY, "")
methodIntervalConfig :=
url.GetParam(methodConfigPrefix+constant.TPS_LIMIT_INTERVAL_KEY, "")
+ // service-level tps limit
limitTarget := url.ServiceKey()
// method-level tps limit
if len(methodIntervalConfig) > 0 || len(methodLimitRateConfig) > 0 {
+ // it means that if the method-level rate limit exist, we will
use method-level rate limit strategy
limitTarget = limitTarget + "#" + invocation.MethodName()
}
+ // looking up the limiter from 'cache'
limitState, found := limiter.tpsState.Load(limitTarget)
if found {
+ // the limiter has been cached, we return its result
return limitState.(filter.TpsLimitStrategy).IsAllowable()
}
+ // we could not find the limiter, and try to create one.
+
limitRate := getLimitConfig(methodLimitRateConfig, url, invocation,
constant.TPS_LIMIT_RATE_KEY,
constant.DEFAULT_TPS_LIMIT_RATE)
if limitRate < 0 {
+ // the limitTarget is not necessary to be limited.
return true
}
@@ -150,13 +162,20 @@ func (limiter MethodServiceTpsLimiterImpl)
IsAllowable(url common.URL, invocatio
panic(fmt.Sprintf("The interval must be positive, please check
your configuration! url: %s", url.String()))
}
+ // find the strategy config and then create one
limitStrategyConfig :=
url.GetParam(methodConfigPrefix+constant.TPS_LIMIT_STRATEGY_KEY,
url.GetParam(constant.TPS_LIMIT_STRATEGY_KEY,
constant.DEFAULT_KEY))
limitStateCreator :=
extension.GetTpsLimitStrategyCreator(limitStrategyConfig)
+
+ // we using loadOrStore to ensure thread-safe
limitState, _ = limiter.tpsState.LoadOrStore(limitTarget,
limitStateCreator.Create(int(limitRate), int(limitInterval)))
+
return limitState.(filter.TpsLimitStrategy).IsAllowable()
}
+// getLimitConfig will try to fetch the configuration from url.
+// If we can convert the methodLevelConfig to int64, return;
+// Or, we will try to look up server-level configuration and then convert it
to int64
func getLimitConfig(methodLevelConfig string,
url common.URL,
invocation protocol.Invocation,
@@ -172,6 +191,8 @@ func getLimitConfig(methodLevelConfig string,
return result
}
+ // actually there is no method-level configuration, so we use the
service-level configuration
+
result, err := strconv.ParseInt(url.GetParam(configKey, defaultVal), 0,
0)
if err != nil {
@@ -183,7 +204,7 @@ func getLimitConfig(methodLevelConfig string,
var methodServiceTpsLimiterInstance *MethodServiceTpsLimiterImpl
var methodServiceTpsLimiterOnce sync.Once
-// GetMethodServiceTpsLimiter ...
+// GetMethodServiceTpsLimiter will return an MethodServiceTpsLimite
[dubbo-go] branch develop updated: Add comments for ServiceMethodLimiter
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/develop by this push:
new 58dd5bd Add comments for ServiceMethodLimiter
new 42dbf0d Merge pull request #490 from flycash/doc-comments
58dd5bd is described below
commit 58dd5bdc4ee99bf1b1191562f0e4a6133ed87603
Author: flycash
AuthorDate: Thu Apr 23 21:53:15 2020 +0800
Add comments for ServiceMethodLimiter
---
.../filter_impl/tps/tps_limiter_method_service.go | 25 --
filter/tps_limiter.go | 1 +
2 files changed, 24 insertions(+), 2 deletions(-)
diff --git a/filter/filter_impl/tps/tps_limiter_method_service.go
b/filter/filter_impl/tps/tps_limiter_method_service.go
index 7fe8de9..2d44c68 100644
--- a/filter/filter_impl/tps/tps_limiter_method_service.go
+++ b/filter/filter_impl/tps/tps_limiter_method_service.go
@@ -115,7 +115,12 @@ type MethodServiceTpsLimiterImpl struct {
tpsState *concurrent.Map
}
-// IsAllowable ...
+// IsAllowable based on method-level and service-level.
+// The method-level has high priority which means that if there is any rate
limit configuration for the method,
+// the service-level rate limit strategy will be ignored.
+// The key point is how to keep thread-safe
+// This implementation use concurrent map + loadOrStore to make implementation
thread-safe
+// You can image that even multiple threads create limiter, but only one could
store the limiter into tpsState
func (limiter MethodServiceTpsLimiterImpl) IsAllowable(url common.URL,
invocation protocol.Invocation) bool {
methodConfigPrefix := "methods." + invocation.MethodName() + "."
@@ -123,23 +128,30 @@ func (limiter MethodServiceTpsLimiterImpl)
IsAllowable(url common.URL, invocatio
methodLimitRateConfig :=
url.GetParam(methodConfigPrefix+constant.TPS_LIMIT_RATE_KEY, "")
methodIntervalConfig :=
url.GetParam(methodConfigPrefix+constant.TPS_LIMIT_INTERVAL_KEY, "")
+ // service-level tps limit
limitTarget := url.ServiceKey()
// method-level tps limit
if len(methodIntervalConfig) > 0 || len(methodLimitRateConfig) > 0 {
+ // it means that if the method-level rate limit exist, we will
use method-level rate limit strategy
limitTarget = limitTarget + "#" + invocation.MethodName()
}
+ // looking up the limiter from 'cache'
limitState, found := limiter.tpsState.Load(limitTarget)
if found {
+ // the limiter has been cached, we return its result
return limitState.(filter.TpsLimitStrategy).IsAllowable()
}
+ // we could not find the limiter, and try to create one.
+
limitRate := getLimitConfig(methodLimitRateConfig, url, invocation,
constant.TPS_LIMIT_RATE_KEY,
constant.DEFAULT_TPS_LIMIT_RATE)
if limitRate < 0 {
+ // the limitTarget is not necessary to be limited.
return true
}
@@ -150,13 +162,20 @@ func (limiter MethodServiceTpsLimiterImpl)
IsAllowable(url common.URL, invocatio
panic(fmt.Sprintf("The interval must be positive, please check
your configuration! url: %s", url.String()))
}
+ // find the strategy config and then create one
limitStrategyConfig :=
url.GetParam(methodConfigPrefix+constant.TPS_LIMIT_STRATEGY_KEY,
url.GetParam(constant.TPS_LIMIT_STRATEGY_KEY,
constant.DEFAULT_KEY))
limitStateCreator :=
extension.GetTpsLimitStrategyCreator(limitStrategyConfig)
+
+ // we using loadOrStore to ensure thread-safe
limitState, _ = limiter.tpsState.LoadOrStore(limitTarget,
limitStateCreator.Create(int(limitRate), int(limitInterval)))
+
return limitState.(filter.TpsLimitStrategy).IsAllowable()
}
+// getLimitConfig will try to fetch the configuration from url.
+// If we can convert the methodLevelConfig to int64, return;
+// Or, we will try to look up server-level configuration and then convert it
to int64
func getLimitConfig(methodLevelConfig string,
url common.URL,
invocation protocol.Invocation,
@@ -172,6 +191,8 @@ func getLimitConfig(methodLevelConfig string,
return result
}
+ // actually there is no method-level configuration, so we use the
service-level configuration
+
result, err := strconv.ParseInt(url.GetParam(configKey, defaultVal), 0,
0)
if err != nil {
@@ -183,7 +204,7 @@ func getLimitConfig(methodLevelConfig string,
var methodServiceTpsLimiterInstance *MethodServiceTpsLimiterImpl
var methodServiceTpsLimiterOnce sync.Once
-// GetMethodServiceTpsLimiter ...
+// GetMethodServiceTpsLimiter will return an MethodServiceTpsLimite
[dubbo-go] branch feature/dubbo-2.7.5 updated (422b678 -> 370681a)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/dubbo-2.7.5
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 422b678 Merge pull request #469 from
flycash/inmemory-service-discovery
new 6e574cc Add:format dir
new 79218a1 Mod:resolve conflict
new 4cced63 Merge branch 'code_enhance_of_urlinit' into metadata_report
new 485cd5f Mod:format mod
new 690333b Mod:resolve conflict
new 8cc8060 Merge branch 'feature/dubbo-2.7.5' into metadata_report
new 0b0fde8 Add: add exporter
new 8d3329f Merge branch 'develop' into metadata_report
new 6a9591a Add:identifier ut
new b3dddc8 Mod: move service name mapping
new 863dd0f Mod:make ut run
new 207e246 Mod:resolve conflict
new 74d6dd9 Mod:format
new dc405a7 Add:liscense
new ef06c72 Mod:dir rename
new 5d380d0 Mod:import pkg rename
new f580027 Mod:rw problem
new 851966e Merge branch 'feature/dubbo-2.7.5' into metadata_report
new ace7899 Mod:rw problem
new 4521e09 Mod:rw problem
new 66aa1a0 Mod:rw problem
new ad995d8 Add:add for resolve rw
new 5067dae Mod:treeset to skiplist
new f595f50 Mod:resolve conflict
new 370681a Merge pull request #471 from hxmhlt/metadata_report
The 1988 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:
common/constant/key.go | 1 +
common/extension/metadata_report_factory.go| 8 +-
common/rpc_service.go | 5 +
config/base_config_test.go | 36
config/config_loader.go| 1 +
config/config_loader_test.go | 55 -
config/instance/metedata_report.go | 6 +-
config/service_config.go | 64 +-
config/service_config_test.go | 56 +
go.mod | 2 +-
go.sum | 9 +-
metadata/definition/definition.go | 48 +
metadata/identifier/base_metadata_identifier.go| 44 ++--
.../identifier/base_metadata_identifier_test.go| 26 ++-
metadata/identifier/metadata_identifier.go | 15 +-
.../identifier/metadata_identifier_test.go | 31 ++-
metadata/identifier/service_metadata_identifier.go | 17 +-
.../identifier/service_metadata_identifier_test.go | 32 ++-
.../identifier/subscribe_metadata_identifier.go| 15 +-
.../subscribe_metadata_identifier_test.go | 31 ++-
.../dynamic/service_name_mapping.go| 4 +-
.../dynamic/service_name_mapping_test.go | 0
.../memory/service_name_mapping.go | 0
metadata/{ => mapping}/service_name_mapping.go | 2 +-
metadata/{ => report/factory}/report_factory.go| 11 +-
metadata/{ => report}/report.go| 5 +-
metadata/service.go| 37
metadata/service/exporter/configurable/exporter.go | 103 +
.../service/exporter/configurable/exporter_test.go | 117 +++
metadata/{ => service/exporter}/exporter.go| 9 +-
metadata/service/inmemory/service.go | 232 +
metadata/service/inmemory/service_test.go | 125 +++
metadata/service/service.go| 63 ++
33 files changed, 944 insertions(+), 266 deletions(-)
copy config/config_utils_test.go =>
metadata/identifier/base_metadata_identifier_test.go (64%)
copy common/extension/metrics_test.go =>
metadata/identifier/metadata_identifier_test.go (62%)
copy common/extension/metrics_test.go =>
metadata/identifier/service_metadata_identifier_test.go (58%)
copy common/extension/health_checker_test.go =>
metadata/identifier/subscribe_metadata_identifier_test.go (59%)
rename metadata/{namemapping => mapping}/dynamic/service_name_mapping.go (97%)
rename metadata/{namemapping => mapping}/dynamic/service_name_mapping_test.go
(100%)
rename metadata/{namemapping => mapping}/memory/service_name_mapping.go (100%)
rename metadata/{ => mapping}/service_name_mapping.go (98%)
rename metadata/{ => report/factory}/report_factory.go (76%)
rename metadata/{ => report}/report.go (90%)
delete mode 100644 metadata/service.go
create mode 100644 metadata/service/exporter/configurable/exporter.go
create mode 100644 metadata/service/exporter/configurable/exporter_test.go
rename metadata/{ => service/exporter}/exporter.go (81%)
create mode 100644 metadata/service/inmemory/service.go
create mode 100644 metadata/service/inmemory/service_test.go
create mode 100644 metadata/service/service.go
[dubbo-go] branch develop updated (c8f66ac -> 5bdbf08)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from c8f66ac Merge pull request #474 from dubbo-x/simplified new ceb0292 a little refactor new b4df125 extract router init to func new 5bdbf08 Merge pull request #481 from cch123/develop The 1972 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: common/url.go | 10 ++- config/config_loader.go | 210 ++-- 2 files changed, 118 insertions(+), 102 deletions(-)
[dubbo-go] branch feature/dubbo-2.7.5 updated (a4ee287 -> 422b678)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/dubbo-2.7.5 in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from a4ee287 Merge pull request #455 from Patrick0308/align-2.7.5 new 8c42b4c In memory service discovery support new c15a725 Add in-memory service-discovery support new 7c20ad3 Merge branch 'feature/dubbo-2.7.5' of github.com:apache/dubbo-go into inmemory-service-discovery new 6707dfb Fix format new 422b678 Merge pull request #469 from flycash/inmemory-service-discovery The 1963 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: registry/inmemory/service_discovery.go | 162 registry/inmemory/service_discovery_test.go | 98 + registry/nacos/service_discovery.go | 2 +- 3 files changed, 261 insertions(+), 1 deletion(-) create mode 100644 registry/inmemory/service_discovery.go create mode 100644 registry/inmemory/service_discovery_test.go
[dubbo-go] branch feature/dubbo-2.7.5 updated (a594afd -> a4ee287)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/dubbo-2.7.5
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from a594afd Merge pull request #470 from apache/develop
new 95b4658 align 2.7.8: direct event dispatcher
new 259e3c1 dispatcher in extension
new 8e2adc5 add unit test and move extension to observer
new 357f536 fix import
new ea24b17 add default eventDispatch type and handle eventType is ptr
new 2925dd3 modify some comments and optimize code
new a782838 optimize some code and fix imports
new 2622827 move global dispatcher to extension package
new 045f7f5 Merge remote-tracking branch 'upstream/feature/dubbo-2.7.5'
into align-2.7.5
new b30bea6 Merge remote-tracking branch 'upstream/feature/dubbo-2.7.5'
into align-2.7.5
new eca5628 fix imports
new a8871fd modify and add licenses
new a4ee287 Merge pull request #455 from Patrick0308/align-2.7.5
The 1958 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:
common/constant/key.go | 1 +
common/extension/event_dispatcher.go | 62 ++
.../observer/dispatcher/direct_event_dispatcher.go | 64 ++
.../dispatcher/direct_event_dispatcher_test.go | 75
common/observer/event.go | 66 ++
.../observer/event_dispatcher.go | 17 ++-
{registry => common/observer}/event_listener.go| 8 +-
common/observer/listenable.go | 133 +
.../observer/listenable_test.go| 51
config/base_config.go | 15 ++-
config/config_loader.go| 12 ++
config/metadata_report_config_test.go | 17 +++
.../identifier/subscribe_metadata_identifier.go| 17 +++
registry/event.go | 47 +---
registry/event_listener.go | 32 ++---
15 files changed, 516 insertions(+), 101 deletions(-)
create mode 100644 common/extension/event_dispatcher.go
create mode 100644 common/observer/dispatcher/direct_event_dispatcher.go
create mode 100644 common/observer/dispatcher/direct_event_dispatcher_test.go
create mode 100644 common/observer/event.go
copy cluster/loadbalance.go => common/observer/event_dispatcher.go (78%)
copy {registry => common/observer}/event_listener.go (92%)
create mode 100644 common/observer/listenable.go
copy cluster/router/healthcheck/factory_test.go =>
common/observer/listenable_test.go (54%)
[dubbo-go] branch develop updated (862bf03 -> c8f66ac)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 862bf03 Merge pull request #473 from divebomb/develop new 9e06cc2 add simplified attribute in registry config new ef33eb1 go fmt new 4ea624b add license new 01bbba5 improve code new b25b628 fix new 0098b2b fix new b57ba60 fix new 71e2e17 Merge branch 'develop' into simplified new 258a6e9 fix new 8d92fcb go mod new c8f66ac Merge pull request #474 from dubbo-x/simplified The 1969 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: common/url.go | 57 ++- config/registry_config.go | 35 -- go.mod| 2 ++ go.sum| 14 --- registry/protocol/protocol.go | 22 + 5 files changed, 74 insertions(+), 56 deletions(-)
[dubbo-go] branch feature/dubbo-2.7.5 updated (e3a4992 -> e4e5ff7)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/dubbo-2.7.5
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from e3a4992 Merge pull request #453 from flycash/service-name
new e3e0ba9 implement the NacosServiceDiscovery
new 9ab5068 Merge branch 'service-name' into nacos-discovery
new fce412d test nacos service discovery
new 6c44338 Test CRUD for instance methods
new 0142254 Merge branch 'service-name' into nacos-discovery
new c6e1507 Tested nacos discovery
new 5e5c43b Merge branch 'feature/dubbo-2.7.5' of
github.com:apache/dubbo-go into nacos-discovery
new 093026b Add comment
new 6aedd1a rename baseRegistry to nacosBaseRegistry
new e4e5ff7 Merge pull request #461 from flycash/nacos-discovery
The 1853 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:
common/constant/key.go | 6 +
.../{registry.go => service_discovery.go} | 24 +-
go.mod | 4 +-
go.sum | 4 +
registry/event.go | 21 +-
registry/event_listener.go | 1 +
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/service_discovery.go | 13 +-
registry/service_instance.go | 50 +++-
12 files changed, 615 insertions(+), 81 deletions(-)
copy common/extension/{registry.go => service_discovery.go} (56%)
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
[dubbo-go] branch develop updated (6c0afbe -> 7ab3493)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 6c0afbe Merge pull request #463 from fangyincheng/modify-readme new c25cfee optimized code new cf0961c use adapter model to modify restServer new f8e2978 remove adapter new baa1125 optimize header transmit in RestClient and RestServer new dacdada add some comments new e7999f5 modify some comments and when parsing parameters occurred error, return error immediately new a606b64 modify comments new 6bd3ac6 remove new function new dcc2d26 modify some comments new ad958fa modify some comments and modify some logger's message new b2f70f6 Merge branch 'develop' into rest-modify new 7a5b916 optimized code new 183b70a remove the category new 57c58d8 remove the reference url category new 7ab3493 Merge pull request #460 from Patrick0308/rest-modify The 1887 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: config/reference_config.go | 1 - protocol/rest/client/client_impl/resty_client.go | 16 +- protocol/rest/client/rest_client.go| 12 +- protocol/rest/rest_invoker.go | 26 +- protocol/rest/rest_protocol.go | 4 +- protocol/rest/server/rest_server.go| 297 - .../rest/server/server_impl/go_restful_server.go | 291 +--- 7 files changed, 403 insertions(+), 244 deletions(-)
[dubbo-go] branch feature/dubbo-2.7.5 updated (adae0d7 -> e3a4992)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/dubbo-2.7.5
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from adae0d7 Add publish config method into DynamicConfiguration
new 0f17847 service name mapping support
new 21512be Fix Review
new 1167e74 Fix review
new 1aaeb4c Fix Review
new 54d0509 Fix Review
new e3a4992 Merge pull request #453 from flycash/service-name
The 1843 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:
common/constant/key.go | 3 +
config_center/apollo/impl.go | 6 ++
config_center/dynamic_configuration.go | 19 +++--
config_center/mock_dynamic_config.go | 7 ++
config_center/nacos/impl.go| 8 +++
config_center/zookeeper/impl.go| 23 +-
config_center/zookeeper/impl_test.go | 11 ++-
.../namemapping/dynamic/service_name_mapping.go| 82 ++
.../dynamic/service_name_mapping_test.go | 44
.../namemapping/memory/service_name_mapping.go | 22 +++---
.../{report_factory.go => service_name_mapping.go} | 14 ++--
11 files changed, 197 insertions(+), 42 deletions(-)
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 metadata/{report_factory.go => service_name_mapping.go} (62%)
[dubbo-go] branch develop updated (2a60e2b -> 1479852)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 2a60e2b Merge pull request #433 from zouyx/feature/addLicenseChecker new 4657f3d Add: GetInterface for rpc_service.go new 04ee0b9 Mod: fix comments new 1479852 Merge pull request #454 from fangyincheng/improve-rpcservice The 1862 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: common/rpc_service.go | 78 ++- common/rpc_service_test.go| 22 --- config/config_loader.go | 2 +- config/config_loader_test.go | 7 +- config/service_config.go | 2 +- filter/filter_impl/generic_service_filter_test.go | 2 +- protocol/dubbo/client_test.go | 2 +- protocol/dubbo/dubbo_exporter.go | 3 +- protocol/grpc/grpc_exporter.go| 3 +- protocol/jsonrpc/http_test.go | 2 +- protocol/jsonrpc/jsonrpc_exporter.go | 3 +- protocol/jsonrpc/jsonrpc_invoker_test.go | 2 +- protocol/rest/rest_exporter.go| 3 +- protocol/rest/rest_invoker_test.go| 4 +- protocol/rest/rest_protocol_test.go | 4 +- 15 files changed, 97 insertions(+), 42 deletions(-)
[dubbo-go] 01/01: Add publish config method into DynamicConfiguration
This is an automated email from the ASF dual-hosted git repository. flycash pushed a commit to branch feature/dubbo-2.7.5 in repository https://gitbox.apache.org/repos/asf/dubbo-go.git commit adae0d729b94852bda855eeb78276ce48a8acde7 Merge: 9d47547 c12ca7a Author: Ming Deng AuthorDate: Tue Mar 24 14:38:23 2020 +0800 Add publish config method into DynamicConfiguration config_center/apollo/impl.go | 11 +--- config_center/dynamic_configuration.go | 3 +++ config_center/mock_dynamic_config.go | 4 +++ config_center/nacos/impl.go| 48 +++--- config_center/nacos/impl_test.go | 17 +++- config_center/nacos/listener.go| 10 +++ config_center/zookeeper/impl.go| 29 ++-- config_center/zookeeper/impl_test.go | 12 + remoting/zookeeper/client.go | 12 +++-- 9 files changed, 119 insertions(+), 27 deletions(-)
[dubbo-go] branch feature/dubbo-2.7.5 updated (9d47547 -> adae0d7)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/dubbo-2.7.5 in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 9d47547 Merge pull request #442 from flycash/devTo2.7.5 add 0dcd48f Publish Config add 16274df Fix import add 47db94d Merge dubbo2.7.5 branch add 7382a11 Merge develop add ffc8f7b Fix review add c12ca7a Fix Review new adae0d7 Add publish config method into DynamicConfiguration 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: config_center/apollo/impl.go | 11 +--- config_center/dynamic_configuration.go | 3 +++ config_center/mock_dynamic_config.go | 4 +++ config_center/nacos/impl.go| 48 +++--- config_center/nacos/impl_test.go | 17 +++- config_center/nacos/listener.go| 10 +++ config_center/zookeeper/impl.go| 29 ++-- config_center/zookeeper/impl_test.go | 12 + remoting/zookeeper/client.go | 12 +++-- 9 files changed, 119 insertions(+), 27 deletions(-)
[dubbo-go] branch develop updated (36fdb01 -> e8f7526)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 36fdb01 Merge pull request #413 from flycash/release_not
new 456f58f Release 1.2.0
new daa1fc3 Release 1.2.0
new fe43eec Merge branch 'master' into 1.2.0-release
new 11878c4 Release 1.2.0
new 55ab09e Fix kubernetes import block and make map param
new 32e5758 Fix the kubernetes && etcd registry race-condition
new 723aa68 Fix bool value return
new 2ec84e5 Delete the unused check block
new daac5e1 Add apache license
new 347124d Fix test embed etcd-server workdir
new 460fed6 Delete the etcd test-server workdir after ut
new 156bf40 Fix etcd work-dir conflict
new 04ee311 fix latest issue
new 5975ca0 Fix registry concurrent close panic
new 00b1fb1 Merge pull request #289 from sxllwx/k8s
new 7a71b3a Merge develop branch
new 4e5debc Add ut for remote/kubernetes
new 60eaf55 Delete unused method
new 34ebc72 adapte for new registry
new 29c Add ut for registry/kubernetes
new f29c788 Fix ci client close race condition
new f11f6fb Fix remote/kubernetes unit-test race condition
new e5c3ff5 Fix nil init
new 9af6c53 Fix latest comment
new ae667e9 Fix latest alex comment
new 059f9b8 Add double check for RWMutex
new d7ae998 Fix registry package unit test cover
new 3349096 Add test cover for remote/kubernetes
new dfa8267 sync watch unit goroutine
new c7474fa Fix method name bug,and handle the del event in
config-listener.
new d776f8e Fix remote/kubernetes sendMsg locker
new 0886257 delete unused http pprof suite
new bf8bf85 Rename watcher and store name
new bc536bb Fix named err
new 7b13b44 Fix named err
new b9bf7d9 Fix time gap
new aee4f90 delete unused select case
new 06b0da8 Add more rich log
new 83d3975 move handle-client-restart from remote to registry
new 603c1b9 Fix wg bug, add(1) out of goroutine
new 8773a7d Fix interest url slice-> map
new 59fe063 Fix lock scop
new 168a978 Fix kubernetes registry configListener nil condition
new 92f9ea2 Fix zookeeper wg bug
new 6b04b96 Fix create-path and push to test
new 25f366c Fix listener slice -> map
new 5b87f8e Fix missing protocol scheme bug
new b7af875 Fix nil point, the make slice will import a nil object in
slice
new 1ed3e91 Fix go.sum conflict
new 8941796 Merge pull request #1 from apache/develop
new a47cf73 Fix go.sum conflict
new 46f5c9a Fix CHANGE.md
new d7a37ba Fix CHANGE.md
new b88cf66 Mod: split long line codes
new 35624ed Imp: set the init len for a map
new eeaa817 Fix latest comment
new 5a60988 Fix ci flow block issue
new 14ba4ff etcdv3 unit test, adapte for windows
new ab7db8a simple the client validate method
new cef0d5d short test time-cost for watch set
new 938d5ed Add more rich unit-test
new 52a9e28 etcdv3 unit test, adapte for windows
new 0769966 Fix ut nil pointer issue
new 2eeb732 Fix kubernetes registry ut block issue
new 164bf89 Fix kubernetes registry ut block issue
new e48b698 Add new registry block time, wait the watch groutine start
new e8f7526 Merge pull request #400 from sxllwx/k8s_merge
The 1808 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:
go.mod | 4 +
go.sum | 48 +-
registry/etcdv3/listener.go| 14 +-
registry/etcdv3/listener_test.go | 13 +-
registry/etcdv3/registry_test.go | 4 +-
registry/{etcdv3 => kubernetes}/listener.go| 30 +-
registry/kubernetes/listener_test.go | 259
registry/kubernetes/registry.go| 237 +++
registry/kubernetes/registry_test.go | 147 +
registry/zookeeper/listener.go | 12 +-
remoting/etcdv3/client_test.go | 13 +-
remoting/etcdv3/listener.go| 7 +-
remoting/kubernetes/client.go | 692 +
remoting/kubernetes/client_test.go | 513 +++
common/node.go => remoting/kubernetes/facade.go| 10 +-
.../kubernetes/facade_test.go | 67 +-
remoting/{etcdv3 => kubernetes}/listener.go| 146 ++---
remoting/{etcdv3 => kubernetes}/listener_test.go | 42 +-
remoting/kubernetes/watch.go | 336
[dubbo-go] branch feature/rest updated (46af97f -> dafc2f4)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/rest
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 46af97f Merge pull request #399 from Patrick0308/rest
new fea9106 modify rest config
new c77e8ff modify rest interface dir
new f5fdc0e modify rest
new 007dd79 modify default reader
new 3271f08 modify error info
new 3364d36 modify
new e9fc1f8 modify
new dafc2f4 Merge pull request #402 from Patrick0308/rest
The 1694 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:
common/extension/rest_client.go| 8 +--
common/extension/rest_config_reader.go | 8 +--
common/extension/rest_server.go| 8 +--
config/config_loader.go| 11 ++-
.../reader_impl}/default_config_reader.go | 33 +
.../reader_impl}/default_config_reader_test.go | 8 ++-
.../reader_impl}/testdata/consumer_config.yml | 0
.../reader_impl}/testdata/provider_config.yml | 0
.../rest/config_reader}/rest_config_reader.go | 8 ++-
.../rest_interface => config/rest}/rest_config.go | 6 +-
.../rest_config_loader.go | 78 +-
.../rest_config_loader_test.go | 12 ++--
.../client_impl}/resty_client.go | 10 +--
.../rest/{rest_interface => client}/rest_client.go | 2 +-
protocol/rest/rest_invoker.go | 11 +--
protocol/rest/rest_invoker_test.go | 33 -
protocol/rest/rest_protocol.go | 40 ++-
protocol/rest/rest_protocol_test.go| 18 ++---
.../rest/{rest_interface => server}/rest_server.go | 7 +-
.../server_impl}/go_restful_server.go | 17 ++---
20 files changed, 179 insertions(+), 139 deletions(-)
rename {protocol/rest/rest_config_reader =>
config/rest/config_reader/reader_impl}/default_config_reader.go (64%)
rename {protocol/rest/rest_config_reader =>
config/rest/config_reader/reader_impl}/default_config_reader_test.go (90%)
rename {protocol/rest/rest_config_reader =>
config/rest/config_reader/reader_impl}/testdata/consumer_config.yml (100%)
rename {protocol/rest/rest_config_reader =>
config/rest/config_reader/reader_impl}/testdata/provider_config.yml (100%)
rename {protocol/rest/rest_interface =>
config/rest/config_reader}/rest_config_reader.go (82%)
rename {protocol/rest/rest_interface => config/rest}/rest_config.go (97%)
rename protocol/rest/rest_config_initializer.go =>
config/rest_config_loader.go (64%)
rename protocol/rest/rest_config_initializer_test.go =>
config/rest_config_loader_test.go (87%)
rename protocol/rest/{rest_client => client/client_impl}/resty_client.go (86%)
rename protocol/rest/{rest_interface => client}/rest_client.go (98%)
rename protocol/rest/{rest_interface => server}/rest_server.go (82%)
rename protocol/rest/{rest_server => server/server_impl}/go_restful_server.go
(94%)
[dubbo-go] branch feature/rest updated (182a367 -> 84a2b65)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/rest in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 182a367 Merge pull request #392 from Patrick0308/rest_protocol new 1829072 modify rest new 3a46e04 add rest unit tests new fa27aa2 modify rest protocol new 84a2b65 Merge pull request #394 from Patrick0308/rest The 1479 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: protocol/rest/rest_config_initializer.go | 28 +-- protocol/rest/rest_config_initializer_test.go | 19 .../testdata/consumer_config.yml | 55 +- .../testdata/provider_config.yml | 50 +++- protocol/rest/rest_interface/rest_config.go| 22 - protocol/rest/rest_invoker_test.go | 12 +++-- protocol/rest/rest_protocol.go | 29 protocol/rest/rest_protocol_test.go| 8 ++-- 8 files changed, 104 insertions(+), 119 deletions(-)
[dubbo-go] branch feature/rest updated: fix haven't read error msg
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a commit to branch feature/rest
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/feature/rest by this push:
new b40361e fix haven't read error msg
new 182a367 Merge pull request #392 from Patrick0308/rest_protocol
b40361e is described below
commit b40361e9088ee565f0c965a81527fc503d626239
Author: Patrick
AuthorDate: Fri Mar 6 20:29:58 2020 +0800
fix haven't read error msg
---
protocol/rest/rest_client/resty_client.go | 16 +---
protocol/rest/rest_invoker_test.go| 12
protocol/rest/rest_protocol_test.go | 5 +
3 files changed, 30 insertions(+), 3 deletions(-)
diff --git a/protocol/rest/rest_client/resty_client.go
b/protocol/rest/rest_client/resty_client.go
index cdfddcf..88c3cc7 100644
--- a/protocol/rest/rest_client/resty_client.go
+++ b/protocol/rest/rest_client/resty_client.go
@@ -26,6 +26,10 @@ import (
)
import (
+ perrors "github.com/pkg/errors"
+)
+
+import (
"github.com/go-resty/resty/v2"
)
@@ -65,16 +69,22 @@ func NewRestyClient(restOption *rest_interface.RestOptions)
*RestyClient {
}
func (rc *RestyClient) Do(restRequest *rest_interface.RestRequest, res
interface{}) error {
- _, err := rc.client.R().
+ r, err := rc.client.R().
SetHeader("Content-Type", restRequest.Consumes).
SetHeader("Accept", restRequest.Produces).
SetPathParams(restRequest.PathParams).
SetQueryParams(restRequest.QueryParams).
+ SetHeaders(restRequest.Headers).
SetBody(restRequest.Body).
SetResult(res).
- SetHeaders(restRequest.Headers).
Execute(restRequest.Method,
"http://"+path.Join(restRequest.Location, restRequest.Path))
- return err
+ if err != nil {
+ return perrors.WithStack(err)
+ }
+ if r.IsError() {
+ return perrors.New(r.String())
+ }
+ return nil
}
func GetRestyClient(restOptions *rest_interface.RestOptions)
rest_interface.RestClient {
diff --git a/protocol/rest/rest_invoker_test.go
b/protocol/rest/rest_invoker_test.go
index d2e350e..2ec71b7 100644
--- a/protocol/rest/rest_invoker_test.go
+++ b/protocol/rest/rest_invoker_test.go
@@ -112,6 +112,14 @@ func TestRestInvoker_Invoke(t *testing.T) {
QueryParamsMap: nil,
Body: 0,
}
+ methodConfigMap["GetUserFive"] = _interface.RestMethodConfig{
+ InterfaceName: "",
+ MethodName:"GetUserFive",
+ Path: "/GetUserFive",
+ Produces: "*/*",
+ Consumes: "*/*",
+ MethodType:"GET",
+ }
methodConfigMap["GetUser"] = _interface.RestMethodConfig{
InterfaceName: "",
MethodName: "GetUser",
@@ -175,6 +183,10 @@ func TestRestInvoker_Invoke(t *testing.T) {
assert.NoError(t, res.Error())
assert.NotNil(t, res.Result())
assert.Equal(t, "username", res.Result().(*User).Name)
+ inv =
invocation.NewRPCInvocationWithOptions(invocation.WithMethodName("GetUserFive"),
invocation.WithReply(user))
+ res = invoker.Invoke(context.Background(), inv)
+ assert.Error(t, res.Error(), "test error")
+
err = common.ServiceMap.UnRegister(url.Protocol,
"com.ikurento.user.UserProvider")
assert.NoError(t, err)
}
diff --git a/protocol/rest/rest_protocol_test.go
b/protocol/rest/rest_protocol_test.go
index 0c3628d..28250d0 100644
--- a/protocol/rest/rest_protocol_test.go
+++ b/protocol/rest/rest_protocol_test.go
@@ -19,6 +19,7 @@ package rest
import (
"context"
+ "errors"
"fmt"
"strings"
"testing"
@@ -173,6 +174,10 @@ func (p *UserProvider) GetUserFour(ctx context.Context,
user []interface{}, id s
return u, nil
}
+func (p *UserProvider) GetUserFive(ctx context.Context, user []interface{})
(*User, error) {
+ return nil, errors.New("test error")
+}
+
type User struct {
Id int
Time *time.Time
[dubbo-go] branch feature/rest updated (4738480 -> 4b01d83)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/rest in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 4738480 Merge pull request #370 from Patrick0308/rest_protocol new 4e6aa04 add licenses new 3b46dce split import new 5add5e2 remove x/tools new 4b01d83 Merge pull request #387 from Patrick0308/rest_protocol The 1473 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: common/extension/rest_client.go | 17 + common/extension/rest_config_reader.go| 17 + common/extension/rest_server.go | 17 + go.mod| 1 - go.sum| 17 - protocol/rest/rest_config_initializer_test.go | 5 - 6 files changed, 55 insertions(+), 19 deletions(-)
[dubbo-go] branch feature/metrics updated (ba71941 -> 5e491c1)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/metrics
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from ba71941 Merge pull request #320 from flycash/feature/MetricsFilter
new 44cf7ed dubbo go compass metrics Prometheus support
new df880b1 make func GetMetricRegistry can be reached
new 25584ab run go fmt
new 5e491c1 Merge pull request #322 from flixgithub/feature/metrics
The 1297 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:
go.mod | 2 +-
metrics/{counting.go => histogram.go} | 23 +++---
metrics/impl/default_metric_manager.go | 6 +--
metrics/impl/histogram_impl.go | 77 +++
monitor/collector/collector.go | 83 ++
monitor/dubbogo_exporter.go| 63 ++
6 files changed, 244 insertions(+), 10 deletions(-)
copy metrics/{counting.go => histogram.go} (75%)
create mode 100644 metrics/impl/histogram_impl.go
create mode 100644 monitor/collector/collector.go
create mode 100644 monitor/dubbogo_exporter.go
[dubbo-go] branch develop updated (dd1a3c2 -> ff8ea17)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from dd1a3c2 Rem: stargazers new 3ceab17 change log new 60c608a check log new 6573221 fix new ff8ea17 Merge pull request #374 from pantianying/ftr_log The 1434 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: common/proxy/proxy.go | 2 +- protocol/dubbo/dubbo_invoker.go | 2 +- protocol/dubbo/pool.go | 2 +- registry/directory/directory.go | 7 +++ registry/zookeeper/listener.go | 2 +- remoting/zookeeper/client.go| 2 +- remoting/zookeeper/listener.go | 2 +- 7 files changed, 9 insertions(+), 10 deletions(-)
[dubbo-go] branch feature/dubbo-2.7.5 created (now 67ccfb2)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/dubbo-2.7.5 in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. at 67ccfb2 Merge pull request #369 from zouyx/hotfix/FixReviewComment No new revisions were added by this update.
[dubbo-go] branch develop updated (2d4022d -> 2d70b6f)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 2d4022d Merge pull request #359 from hxmhlt/mod_zk_listen new 0713fc1 add Rlock for dubbo Invoker new 6da0921 add code new c250592 update new 7f6fd6a add Notes new 0ee1cd4 fix bug new 167d221 fix bug new 873c7d9 fix proprem new 2d70b6f Merge pull request #358 from pantianying/addRlockForDubboInvoker The 1420 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: protocol/dubbo/dubbo_invoker.go | 35 ++- registry/directory/directory.go | 39 --- 2 files changed, 58 insertions(+), 16 deletions(-)
[dubbo-go] branch feature/rest updated (d93a2a3 -> bc64aed)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/rest in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from d93a2a3 Merge pull request #329 from Patrick0308/rest_protocol new 114fe40 change service key to path key new 01361a6 fix serviceKey new 8b884cc support req[] new fd0a076 fix when args is req[] new b67b76a fix path bug new b692796 modify server default consumes and produces new bc64aed Merge pull request #353 from Patrick0308/rest_protocol The 1376 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: protocol/rest/rest_config_initializer.go | 16 ++-- protocol/rest/rest_config_initializer_test.go | 4 +- protocol/rest/rest_interface/rest_config.go| 8 +- protocol/rest/rest_invoker_test.go | 59 - protocol/rest/rest_protocol.go | 10 +-- protocol/rest/rest_protocol_test.go| 24 +- protocol/rest/rest_server/go_restful_server.go | 112 +++-- 7 files changed, 188 insertions(+), 45 deletions(-)
[dubbo-go] branch develop updated (33f82cd -> d0d3ac1)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 33f82cd Fix: https://github.com/AlexStocks/getty/issues/27
new e0c29a5 add nacos configcenter
new befdd61 fix:gofmt nacos configcenter
new d72c385 fix:nacos test server addr
new f7a267c fix: Code normalization
new 3fd3cf8 add config_center nacos client_test.go
new a992d0b Merge branch 'develop' into feature/nacos
new c0b96f3 fix test case
new e167f6c fix code problems
new b302272 fix test case
new abc8d64 add comment
new bd165e5 fix test case
new a7b3fd8 fix review comment
new b2584ae fix code problems
new f7c588d fix review comment
new f0a4d8f fix review comment
new d0d3ac1 Merge pull request #357 from zouyx/feature/nacos
The 1406 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:
config_center/nacos/client.go | 217 +
config_center/nacos/client_test.go | 31 +++
.../zookeeper => config_center/nacos}/facade.go| 68 ---
config_center/{zookeeper => nacos}/factory.go | 11 +-
config_center/nacos/impl.go| 166
config_center/nacos/impl_test.go | 117 +++
config_center/nacos/listener.go| 62 ++
7 files changed, 636 insertions(+), 36 deletions(-)
create mode 100644 config_center/nacos/client.go
create mode 100644 config_center/nacos/client_test.go
copy {remoting/zookeeper => config_center/nacos}/facade.go (50%)
copy config_center/{zookeeper => nacos}/factory.go (72%)
create mode 100644 config_center/nacos/impl.go
create mode 100644 config_center/nacos/impl_test.go
create mode 100644 config_center/nacos/listener.go
[dubbo-go] branch develop updated (bfef9d2 -> 0074a01)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from bfef9d2 Merge pull request #351 from pantianying/change_zk_version
new 9298c7e Implemented prometheus reporter
new 9cb3965 Tested prometheus
new fcae1b7 Add protocol.Result into Report method
new 061eb82 Rearrange imports
new 8ceeefd Fix review
new 10d0ac8 Fix BUG
new 2d66552 Support histogram
new 9d5943a Lazy initialization
new 83d3ca6 Remove remote key and local key
new b22c9a3 Merge branch 'develop' of github.com:apache/dubbo-go into
feature/prometheus
new 5e74a2c fmt code
new d4ee2bf Move GetXXXConfig to config_load file
new 6404fbb fmt comments
new 3810992 Merge branch 'develop' of github.com:apache/dubbo-go into
feature/prometheus
new 229e027 fix review
new 31ca039 Merge develop
new 0074a01 Merge pull request #342 from flycash/feature/prometheus
The 1366 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:
common/{node.go => constant/time.go} | 15 +-
common/extension/{registry.go => metrics.go} | 27 +--
.../extension/metrics_test.go | 32 ++--
config/base_config.go | 4 +-
config/config_loader.go| 56 ++-
config/consumer_config.go | 9 -
...shutdown_signal_windows.go => metric_config.go} | 26 +--
cluster/cluster.go => config/metric_config_test.go | 14 +-
config/provider_config.go | 9 -
filter/filter_impl/metrics_filter.go | 93 +++
...acing_filter_test.go => metrics_filter_test.go} | 51 --
go.mod | 2 +-
metrics/prometheus/reporter.go | 184 +
.../prometheus/reporter_test.go| 56 +++
filter/filter.go => metrics/reporter.go| 17 +-
15 files changed, 469 insertions(+), 126 deletions(-)
copy common/{node.go => constant/time.go} (88%)
copy common/extension/{registry.go => metrics.go} (52%)
copy config/config_utils_test.go => common/extension/metrics_test.go (62%)
copy config/{graceful_shutdown_signal_windows.go => metric_config.go} (59%)
copy cluster/cluster.go => config/metric_config_test.go (82%)
create mode 100644 filter/filter_impl/metrics_filter.go
copy filter/filter_impl/{tracing_filter_test.go => metrics_filter_test.go}
(63%)
create mode 100644 metrics/prometheus/reporter.go
copy filter/filter_impl/access_log_filter_test.go =>
metrics/prometheus/reporter_test.go (62%)
copy filter/filter.go => metrics/reporter.go (74%)
[dubbo-go] branch feature/rest updated (e899345 -> d93a2a3)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/rest
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from e899345 Merge pull request #347 from apache/develop
new 64b9439 init rest protocol
new 5cbba12 rest configs and invoker
new 2d3a6f7 fix
new 69020c0 fixed
new b3fabce Merge branch 'develop' into rest_protocol
new 547372f init rest exporter and modify rest invoker
new 5120254 header params
new d5fccd6 resty add header params
new c31030f fix
new cbc59d3 go restful server and some unit tests
new f1908a0 modify
new 567acb1 modify test
new 55655d3 fix bug
new 415d590 ptr zk.lock
new cb9cc37 fix bug
new d654f3a Merge pull request #346 from pantianying/zk_develop
new 9acc7aa Merge branch 'develop' into rest_protocol
new 6a6717f Merge branch 'feature/rest' into rest_protocol
new f48a644 fix
new eb1d850 fix tests
new 756f87f use "default" constant and remove default timeout options
new 88300f4 add licenses
new d9c61c4 fmt imports
new 9538a34 fix config initializer
new f51ae5d add some unit tests
new 8d1dc02 add testdata about rest config file
new a957054 add licenses
new d93a2a3 Merge pull request #329 from Patrick0308/rest_protocol
The 1369 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:
common/constant/default.go | 2 +
common/extension/rest_client.go| 20 ++
common/extension/rest_config_reader.go | 24 ++
common/extension/rest_server.go| 20 ++
config/consumer_config.go | 1 +
config/provider_config.go | 1 +
go.mod | 3 +
go.sum | 23 +-
protocol/rest/rest_client/resty_client.go | 82 +++
protocol/rest/rest_config_initializer.go | 156 +
.../rest/rest_config_initializer_test.go | 22 +-
.../rest_config_reader/default_config_reader.go| 108 +
.../default_config_reader_test.go | 22 +-
.../testdata/consumer_config.yml | 197 +
.../testdata/provider_config.yml | 200 -
.../dubbo_exporter.go => rest/rest_exporter.go}| 22 +-
.../rest/rest_interface/rest_client.go | 31 +--
protocol/rest/rest_interface/rest_config.go| 112 ++
.../rest/rest_interface/rest_config_reader.go | 12 +-
.../rest/rest_interface/rest_server.go | 12 +-
protocol/rest/rest_invoker.go | 109 +
protocol/rest/rest_invoker_test.go | 123 +++
protocol/rest/rest_protocol.go | 140
protocol/rest/rest_protocol_test.go| 159 +
protocol/rest/rest_server/go_restful_server.go | 246 +
remoting/zookeeper/client.go | 83 ---
remoting/zookeeper/listener.go | 7 +-
27 files changed, 1655 insertions(+), 282 deletions(-)
create mode 100644 common/extension/rest_client.go
create mode 100644 common/extension/rest_config_reader.go
create mode 100644 common/extension/rest_server.go
create mode 100644 protocol/rest/rest_client/resty_client.go
create mode 100644 protocol/rest/rest_config_initializer.go
copy config_center/parser/configuration_parser_test.go =>
protocol/rest/rest_config_initializer_test.go (56%)
create mode 100644 protocol/rest/rest_config_reader/default_config_reader.go
copy config_center/parser/configuration_parser_test.go =>
protocol/rest/rest_config_reader/default_config_reader_test.go (59%)
copy {config => protocol/rest/rest_config_reader}/testdata/consumer_config.yml
(95%)
copy {config => protocol/rest/rest_config_reader}/testdata/provider_config.yml
(96%)
copy protocol/{dubbo/dubbo_exporter.go => rest/rest_exporter.go} (70%)
copy config/mock_rpcservice.go => protocol/rest/rest_interface/rest_client.go
(65%)
create mode 100644 protocol/rest/rest_interface/rest_config.go
copy cluster/cluster.go => protocol/rest/rest_interface/rest_config_reader.go
(85%)
copy cluster/directory.go => protocol/rest/rest_interface/rest_server.go (80%)
create mode 100644 protocol/rest/rest_invoker.go
create mode 100644 protocol/rest/rest_invoker_test.go
create mode 100644 protocol/rest/rest_protocol.go
create mode 100644 protocol/rest/rest_protocol_test.go
create mode 100644 protocol/rest/rest_server/go_restful_server.go
[dubbo-go] branch develop updated (c291d2c -> d654f3a)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from c291d2c Merge pull request #344 from flycash/feature/dubbo-context new 55655d3 fix bug new 415d590 ptr zk.lock new cb9cc37 fix bug new d654f3a Merge pull request #346 from pantianying/zk_develop The 1344 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: remoting/zookeeper/client.go | 83 ++ remoting/zookeeper/listener.go | 7 +++- 2 files changed, 58 insertions(+), 32 deletions(-)
[dubbo-go] branch feature/rest updated (932e149 -> e899345)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/rest in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 932e149 Mod: upgrade hessian2 add cabd56a Fix: readme add c268f8f Fix: fix jsonprc about 'HTTP/1.1' add 2c5a4f6 fix zookeeper config center namespace default value invalid add cd37e52 Merge pull request #326 from zouyx/feature/fixConfigCenter add 979acb2 Merge pull request #305 from apache/develop add 35abd82 feat(grpc): 支持client grpc 调用 add c47b089 support grpc server add ae67fa1 stash for cli & server test add 4cd0a60 move some to internal add 1fb4d91 fmt add c7d140d stop for client test add ac47753 add new client test add 3e839f3 add invoker test add ddb3c64 use another port add 68fea4b change port add dd5273f add doc add 8f5c6c3 feat(client): add dubbo proto generate add 9617d26 feat(client): add dubbo proto generate add e9017cb fmt add ebcb9f6 fmt & tidy add 7a5be71 bug fix add 7fa1bbd fmt add 5029e32 Merge pull request #275 from xujianhai666/feature/grpc-client add 47131f2 resolve conflicts add 78818e8 Merge pull request #312 from flycash/grpc add d9d334a Mod: modidfy Refer params and add licence add 2d6f7f3 Fmt: package add 1c0e422 Merge pull request #317 from fangyincheng/feature/grpc add 3897328 Merge pull request #311 from apache/feature/grpc add 748ed1c Merge remote-tracking branch 'apache/develop' into develop add 0b74040 Fix: omitted param add 45363f2 Mod: README.md add 7c3178e modify add ff410ac Merge pull request #327 from fangyincheng/develop add 8d34495 Add: travis dingding add 5d1797b supplement rpc stats add df48230 fix unit test add 5bc05b9 fix ci add 436924f fix comment issue add ae41f5a fix comment issue add 3aa39fd fix some naming error add f8d1ecd Merge pull request #328 from CodingSinger/tolerance add 5212a3d GOLINT: add comment for exported (checked by golint) add e2dc717 Add: dingding robot in travis yml add f5c2390 Merge branch 'develop' of https://github.com/apache/dubbo-go into develop add da6d29a Context support add e945c66 format code add a81c012 Fix review: context.TODO => context.Backgroud add ab69968 Fix review: split imports add 29c195d Fix Review add 1fa4bf6 Merge pull request #330 from flycash/feature/context add adf366a update license and notice add bc23f7c Merge pull request #336 from zouyx/feature/UpdateLicense add d63631b Add opentracing dependency add a8e952e define TracingFilter add e556b01 Doing tracing filter add 833000b Doing tracing filter add 5c78245 tested tracing filter add 5216fb1 rearrnage imports add e07ca04 Move context to the invocation add 0c19b52 Using default context.Context. add cc7fc72 Merge origin develop add e071810 Pass Context from client add 37d517e Merge context add 70a7436 Merge develop add c48b3cb JsonRPC tracing chain add aec964d Split import add 0196c0e Remove TODO add d9075ad Merge pull request #335 from flycash/feature/Opentracing add c07e4e3 Merge commit 'd9075ad' into feature/add_comment_for_exported_by_golint add c8b6fdd Merge pull request #333 from weiwei-xiao/feature/add_comment_for_exported_by_golint add c9ab3f2 Update Changes.md add 0128e85 Merge pull request #338 from zouyx/feature/UpdateChanges add 351e1ae Imp: reduce lock scope add 93f865c Mod: gofmt add 5dd99c6 Merge pull request #318 from divebomb/develop add d7ff97b Merge branch 'develop' add c028651 Fix: by goreportcard.com add ddd70ee Fix: add type for var add e019139 Mod: go fmt add 6ec3894 Merge branch 'develop' add ea95e04 Fix: golint by goreportcard.com add deb9ea1 Merge branch 'develop' add 5a71b39 Add: log/comment rule add bd84cfa add unit_test add 6809d8d a add 82fe079 Merge remote-tracking branch 'apache/develop' into develop add 0804c09 modify zk ListenServiceEvent add ade85d6 modify zk ListenServiceEvent add 13ddacc Mod:rm chinese add 0d5e447 Mod:rm rather than comment add 4de49ef Merge pull request #343 from hxmhlt/modify_zk add df79a5c Extract add a283aeb Transfer context for dubbo protocol by attachment add d96c241 Rearrange imports add 3db2f4d Remove context key add 0e57187 Fix review add c291d2c Merge pull request #344 from flycash/feature/dubbo-context new e899345 Merge pull request #347 from apache/develop The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "
[dubbo-go] 01/01: Merge pull request #347 from apache/develop
This is an automated email from the ASF dual-hosted git repository. flycash pushed a commit to branch feature/rest in repository https://gitbox.apache.org/repos/asf/dubbo-go.git commit e899345e6482dab1c46bfa20751e1a41b2c3f840 Merge: 932e149 c291d2c Author: Ming Deng AuthorDate: Sun Feb 2 12:15:45 2020 +0800 Merge pull request #347 from apache/develop Develop to feature/rest .travis.yml| 3 + CHANGE.md | 38 +++ LICENSE| 13 + NOTICE | 2 +- README.md | 7 +- README_CN.md | 7 +- cluster/cluster.go | 1 + cluster/cluster_impl/available_cluster.go | 1 + cluster/cluster_impl/available_cluster_invoker.go | 6 +- .../cluster_impl/available_cluster_invoker_test.go | 4 +- cluster/cluster_impl/broadcast_cluster.go | 1 + cluster/cluster_impl/broadcast_cluster_invoker.go | 7 +- .../cluster_impl/broadcast_cluster_invoker_test.go | 4 +- cluster/cluster_impl/failback_cluster.go | 1 + cluster/cluster_impl/failback_cluster_invoker.go | 11 +- cluster/cluster_impl/failback_cluster_test.go | 12 +- cluster/cluster_impl/failfast_cluster.go | 1 + cluster/cluster_impl/failfast_cluster_invoker.go | 7 +- cluster/cluster_impl/failfast_cluster_test.go | 4 +- cluster/cluster_impl/failover_cluster.go | 1 + cluster/cluster_impl/failover_cluster_invoker.go | 5 +- cluster/cluster_impl/failover_cluster_test.go | 16 +- cluster/cluster_impl/failsafe_cluster.go | 1 + cluster/cluster_impl/failsafe_cluster_invoker.go | 7 +- cluster/cluster_impl/failsafe_cluster_test.go | 12 +- cluster/cluster_impl/forking_cluster.go| 1 + cluster/cluster_impl/forking_cluster_invoker.go| 17 +- cluster/cluster_impl/forking_cluster_test.go | 6 +- cluster/cluster_impl/mock_cluster.go | 1 + cluster/cluster_impl/registry_aware_cluster.go | 1 + .../cluster_impl/registry_aware_cluster_invoker.go | 9 +- .../cluster_impl/registry_aware_cluster_test.go| 8 +- cluster/directory.go | 3 +- cluster/directory/base_directory.go| 8 + cluster/directory/static_directory.go | 1 + cluster/loadbalance.go | 3 +- cluster/loadbalance/consistent_hash.go | 13 +- cluster/loadbalance/least_active.go| 16 +- cluster/loadbalance/random.go | 1 + cluster/loadbalance/round_robin.go | 10 +- cluster/loadbalance/util.go| 1 + cluster/router.go | 4 + cluster/router/condition_router.go | 21 +- cluster/router/condition_router_test.go| 10 +- cluster/router/router_factory.go | 4 + common/config/environment.go | 20 +- common/constant/env.go | 5 +- common/constant/key.go | 4 + common/constant/version.go | 7 +- common/extension/cluster.go| 2 + common/extension/config_center.go | 2 + common/extension/config_center_factory.go | 2 + common/extension/configurator.go | 12 +- common/extension/filter.go | 4 + common/extension/graceful_shutdown.go | 2 + common/extension/loadbalance.go| 2 + common/extension/protocol.go | 2 + common/extension/proxy_factory.go | 11 +- common/extension/registry.go | 2 + common/extension/router_factory.go | 2 + common/extension/tps_limit.go | 4 + common/logger/logger.go| 9 + common/logger/logging.go | 15 + common/node.go | 1 + common/proxy/proxy.go | 41 ++- common/proxy/proxy_factory.go | 2 + common/proxy/proxy_factory/default.go | 13 +- common/rpc_service.go | 39 ++- common/rpc_service_test.go | 5 +- common/url.go | 50 ++- config/application_config.go | 8 + config/base_config.go | 10 +- config/config_center_config.go | 5 +- config/config_loader.go| 8 +- config/consumer_config.go | 7 + config/generic_service.go | 4
[dubbo-go] branch feature/k8s updated (11878c4 -> 00b1fb1)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/k8s
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 11878c4 Release 1.2.0
new 55ab09e Fix kubernetes import block and make map param
new 32e5758 Fix the kubernetes && etcd registry race-condition
new 723aa68 Fix bool value return
new 2ec84e5 Delete the unused check block
new daac5e1 Add apache license
new 347124d Fix test embed etcd-server workdir
new 460fed6 Delete the etcd test-server workdir after ut
new 156bf40 Fix etcd work-dir conflict
new 04ee311 fix latest issue
new 5975ca0 Fix registry concurrent close panic
new 00b1fb1 Merge pull request #289 from sxllwx/k8s
The 1061 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:
go.mod | 6 +
go.sum | 32 +
registry/etcdv3/listener_test.go | 12 +-
registry/etcdv3/registry.go| 17 +-
registry/{etcdv3 => kubernetes}/listener.go| 17 +-
.../{zookeeper => kubernetes}/listener_test.go | 2 +-
registry/{etcdv3 => kubernetes}/registry.go| 123 ++--
.../kubernetes/registry_test.go| 19 +-
remoting/etcdv3/client_test.go | 8 +-
remoting/etcdv3/listener.go| 2 +-
remoting/kubernetes/client.go | 654 +
remoting/{etcdv3 => kubernetes}/facade.go | 33 +-
remoting/{etcdv3 => kubernetes}/listener.go| 109 ++--
.../kubernetes}/listener_test.go | 25 +-
remoting/kubernetes/store.go | 322 ++
remoting/kubernetes/store_test.go | 83 +++
16 files changed, 1275 insertions(+), 189 deletions(-)
copy registry/{etcdv3 => kubernetes}/listener.go (85%)
copy registry/{zookeeper => kubernetes}/listener_test.go (99%)
copy registry/{etcdv3 => kubernetes}/registry.go (70%)
copy cluster/loadbalance.go => registry/kubernetes/registry_test.go (80%)
create mode 100644 remoting/kubernetes/client.go
copy remoting/{etcdv3 => kubernetes}/facade.go (68%)
copy remoting/{etcdv3 => kubernetes}/listener.go (61%)
copy {registry/consul => remoting/kubernetes}/listener_test.go (71%)
create mode 100644 remoting/kubernetes/store.go
create mode 100644 remoting/kubernetes/store_test.go
[dubbo-go] branch develop updated (f5c2390 -> 1fa4bf6)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from f5c2390 Merge branch 'develop' of https://github.com/apache/dubbo-go into develop new da6d29a Context support new e945c66 format code new a81c012 Fix review: context.TODO => context.Backgroud new ab69968 Fix review: split imports new 29c195d Fix Review new 1fa4bf6 Merge pull request #330 from flycash/feature/context The 1291 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: cluster/cluster_impl/available_cluster_invoker.go | 5 +++-- cluster/cluster_impl/available_cluster_invoker_test.go | 4 ++-- cluster/cluster_impl/broadcast_cluster_invoker.go | 7 +-- cluster/cluster_impl/broadcast_cluster_invoker_test.go | 4 ++-- cluster/cluster_impl/failback_cluster_invoker.go| 11 ++- cluster/cluster_impl/failback_cluster_test.go | 12 ++-- cluster/cluster_impl/failfast_cluster_invoker.go| 7 +-- cluster/cluster_impl/failfast_cluster_test.go | 4 ++-- cluster/cluster_impl/failover_cluster_invoker.go| 5 +++-- cluster/cluster_impl/failover_cluster_test.go | 10 +- cluster/cluster_impl/failsafe_cluster_invoker.go| 7 +-- cluster/cluster_impl/failsafe_cluster_test.go | 4 ++-- cluster/cluster_impl/forking_cluster_invoker.go | 5 +++-- cluster/cluster_impl/forking_cluster_test.go| 6 +++--- cluster/cluster_impl/registry_aware_cluster_invoker.go | 9 ++--- cluster/cluster_impl/registry_aware_cluster_test.go | 8 cluster/router/condition_router_test.go | 2 +- common/proxy/proxy.go | 3 ++- common/proxy/proxy_factory/default.go | 3 ++- filter/filter.go| 7 +-- filter/filter_impl/access_log_filter.go | 7 --- filter/filter_impl/access_log_filter_test.go| 6 +++--- filter/filter_impl/active_filter.go | 7 --- filter/filter_impl/active_filter_test.go| 4 ++-- filter/filter_impl/echo_filter.go | 9 ++--- filter/filter_impl/echo_filter_test.go | 7 +++ filter/filter_impl/execute_limit_filter.go | 9 + filter/filter_impl/execute_limit_filter_test.go | 7 --- filter/filter_impl/generic_filter.go| 9 + filter/filter_impl/generic_service_filter.go| 9 + filter/filter_impl/generic_service_filter_test.go | 6 +++--- filter/filter_impl/graceful_shutdown_filter.go | 7 --- filter/filter_impl/graceful_shutdown_filter_test.go | 5 +++-- filter/filter_impl/hystrix_filter.go| 9 + filter/filter_impl/hystrix_filter_test.go | 13 +++-- filter/filter_impl/token_filter.go | 9 + filter/filter_impl/token_filter_test.go | 17 + filter/filter_impl/tps_limit_filter.go | 11 +++ filter/filter_impl/tps_limit_filter_test.go | 17 +++-- protocol/dubbo/dubbo_invoker.go | 3 ++- protocol/dubbo/dubbo_invoker_test.go| 9 + protocol/dubbo/listener.go | 3 ++- protocol/grpc/common_test.go| 4 ++-- protocol/grpc/grpc_invoker.go | 2 +- protocol/grpc/grpc_invoker_test.go | 2 +- .../grpc/protoc-gen-dubbo/examples/helloworld.pb.go | 4 ++-- protocol/invoker.go | 7 +-- protocol/jsonrpc/jsonrpc_invoker.go | 6 +++--- protocol/jsonrpc/jsonrpc_invoker_test.go| 2 +- protocol/jsonrpc/server.go | 2 +- protocol/mock/mock_invoker.go | 3 ++- protocol/protocolwrapper/protocol_filter_wrapper.go | 7 --- .../protocolwrapper/protocol_filter_wrapper_test.go | 7 --- registry/protocol/protocol.go | 5 +++-- 54 files changed, 205 insertions(+), 152 deletions(-)
[dubbo-go] branch feature/tracing created (now cabd56a)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/tracing in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. at cabd56a Fix: readme No new revisions were added by this update.
[dubbo-go] branch tracing created (now cabd56a)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch tracing in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. at cabd56a Fix: readme No new revisions were added by this update.
[dubbo-go] branch feature/metrics updated (93e356f -> ba71941)
This is an automated email from the ASF dual-hosted git repository.
flycash pushed a change to branch feature/metrics
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git.
from 93e356f Merge pull request #319 from flycash/feature/Reservoir
new 62e7207 revert filter dir
new c95940a modify filter dir
new a92d606 modify filter dir & version
new 70aed98 delete mock json
new e7aa7e5 delete mock json in apollo test case
new e8cc8c7 Merge pull request #304 from zouyx/feature/deleteMockJson
new 8c24e5e upgrade gost v1.5
new 8dd1b0d Merge pull request #296 from micln/upgrade
new 9ef93b8 Revert "upgrade hessian2 & gost v1.5"
new ab78c63 Merge pull request #299 from apache/revert-296-upgrade
new ad79b88 gost 1.5.1
new b0dbcb8 upgrade hessian2
new d451c2d Merge remote-tracking branch 'upstream/develop' into dev
new 03c6a4a Merge pull request #307 from micln/dev
new 92af46e Merge remote-tracking branch 'apache/develop' into develop
new 47066c2 Merge branch 'develop' of https://github.com/apache/dubbo-go
into apache-develop
new 5f5cfb7 Merge branch 'develop' of https://github.com/apache/dubbo-go
into apache-develop
new ebb35e8 Merge branch 'develop' of https://github.com/apache/dubbo-go
into apache-develop
new 411435c Merge branch 'develop' of https://github.com/apache/dubbo-go
into apache-develop
new 9723e7b add code for request_timeout
new 400c388 add code
new 8517ede Merge branch 'apache-develop' into develop_req_timeout_config
new 625c571 merge code
new 9bdc231 fix bug
new 52fbe96 fix bug
new 311135a fix bug
new 4226997 modify the format of the incoming package
new b2b66c3 remove one const
new bfa60ea Merge pull request #284 from
pantianying/develop_req_timeout_config
new 3110d49 add GenericServiceFilter in README.md
new 2c86ec0 Merge pull request #310 from Patrick0308/modify-readme
new e31ffd6 Merge remote-tracking branch 'apache/develop' into develop
new 1980135 fix ut
new 1d7e21f Mod: modify date
new 20ca967 Fix: ut
new 4bd2851 Merge pull request #306 from fangyincheng/develop
new d01b5ee When protocol config don't have right config, remind user to
check warning.
new a109609 Merge pull request #314 from Patrick0308/add_protocol_warning
new 5117a84 Imp: check consumerConfig.RequestTimeout by
getty.MaxWheelTimeSpan
new dff4870 Mod: upgrade gost/getty version
new f691f24 Mod: change gost/getty version in go.sum
new 5ff8d34 Imp: check sessin timeout; change default client conf params
new dab215a Fmt: protocol/dubbo/config
new 932e149 Mod: upgrade hessian2
new dffc784 Merge develop and resolve conflict
new 75e9bff Add Enables into MetricConfig
new 0884c96 Mod: Refactor the MetricFilter so that we can specify the
metrics which we want to be collected
new 7df1037 Add method GetCompasses and GetFastCompasses
new ba71941 Merge pull request #320 from flycash/feature/MetricsFilter
The 1293 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:
.gitignore | 1 +
README.md | 1 +
cluster/router/condition_router.go | 2 +-
common/constant/version.go | 4 +-
common/url.go | 30 +++
common/url_test.go | 4 +-
config/consumer_config.go | 5 ++
config/graceful_shutdown.go| 2 +-
config/method_config.go| 1 +
config/metric_config.go| 51
config/metric_config_test.go | 11 +++
config/reference_config.go | 49 +++-
config/service_config.go | 8 +-
config/service_config_test.go | 24 ++
config/testdata/consumer_config.yml| 23 +-
config_center/apollo/impl_test.go | 13 +++
config_center/configurator/override.go | 2 +-
.../{filter => filter_impl}/access_log_filter.go | 2 +-
.../access_log_filter_test.go | 2 +-
filter/{filter => filter_impl}/active_filter.go| 2 +-
filter/{filter => filter_impl}/echo_filter.go | 2 +-
filter/{filter => filter_impl}/echo_filter_test.go | 2 +-
.../execute_limit_filter.go| 4 +-
.../execute_limit_filter_test.go | 2 +-
filter/{filter => filter_impl}/generic_filter.go | 2 +-
..
[dubbo-go] branch feature/metrics updated (be433d5 -> 93e356f)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/metrics in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from be433d5 Merge pull request #309 from flycash/feature/Compass new 385950f define ExponentiallyDecayingReservoir and implementing rescale() new 962b73b Implementing Update in ExponentiallyDecayingReservoir new 9f99ff6 Tested weighted_snapshot new 6a48e31 Testing ExponentiallyDecayingReservoir new f657c3e Finish ExponentiallyDecayingReservoir new 93e356f Merge pull request #319 from flycash/feature/Reservoir The 1244 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: cluster/router/condition_router.go | 2 +- common/url.go | 2 +- config/graceful_shutdown.go| 2 +- config_center/configurator/override.go | 2 +- go.mod | 3 +- go.sum | 17 +- metrics/impl/default_compass.go| 9 +- metrics/impl/default_compass_test.go | 4 +- metrics/impl/exponentially_decaying_reservoir.go | 216 ++ .../impl/exponentially_decaying_reservoir_test.go | 249 + metrics/impl/uniform_snapshot_test.go | 5 +- metrics/impl/weighted_snapshot.go | 228 +++ metrics/impl/weighted_snapshot_test.go | 141 metrics/reservoir.go | 1 + registry/protocol/protocol.go | 2 +- 15 files changed, 855 insertions(+), 28 deletions(-) create mode 100644 metrics/impl/exponentially_decaying_reservoir.go create mode 100644 metrics/impl/exponentially_decaying_reservoir_test.go create mode 100644 metrics/impl/weighted_snapshot.go create mode 100644 metrics/impl/weighted_snapshot_test.go
[dubbo-go] branch feature/rest created (now 932e149)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/rest in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. at 932e149 Mod: upgrade hessian2 No new revisions were added by this update.
[dubbo-go] branch feature/metrics updated (2ce0708 -> be433d5)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/metrics in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 2ce0708 Merge pull request #278 from flycash/feature/MetricsFilter new 42beed7 Implementing Metered interface new a58f6db Fix Review: elapsed could be 0 new be433d5 Merge pull request #309 from flycash/feature/Compass The 1238 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: metrics/impl/default_compass.go | 28 metrics/impl/default_compass_test.go | 9 + metrics/metered.go | 29 + 3 files changed, 66 insertions(+)
[dubbo-go] branch feature/grpc updated (979acb2 -> 5029e32)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/grpc in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 979acb2 Merge pull request #305 from apache/develop new 35abd82 feat(grpc): 支持client grpc 调用 new c47b089 support grpc server new ae67fa1 stash for cli & server test new 4cd0a60 move some to internal new 1fb4d91 fmt new c7d140d stop for client test new ac47753 add new client test new 3e839f3 add invoker test new ddb3c64 use another port new 68fea4b change port new dd5273f add doc new 8f5c6c3 feat(client): add dubbo proto generate new 9617d26 feat(client): add dubbo proto generate new e9017cb fmt new ebcb9f6 fmt & tidy new 7a5be71 bug fix new 7fa1bbd fmt new 5029e32 Merge pull request #275 from xujianhai666/feature/grpc-client The 1217 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: common/proxy/proxy.go | 25 +- config/config_loader.go| 2 +- config/reference_config.go | 8 +- config/reference_config_test.go| 20 +- go.mod | 1 + go.sum | 1 + protocol/dubbo/dubbo_invoker_test.go | 4 +- protocol/dubbo/dubbo_protocol.go | 2 +- protocol/dubbo/dubbo_protocol_test.go | 2 +- .../apollo/factory.go => protocol/grpc/client.go | 44 ++- protocol/grpc/client_test.go | 55 protocol/grpc/common_test.go | 112 +++ .../grpc/grpc_exporter.go | 34 +- protocol/grpc/grpc_invoker.go | 97 ++ protocol/grpc/grpc_invoker_test.go | 57 protocol/grpc/grpc_protocol.go | 104 +++ protocol/grpc/grpc_protocol_test.go| 86 + .../grpc/internal/client.go| 25 +- .../grpc/internal/doc.go | 25 +- protocol/grpc/internal/helloworld.pb.go| 210 + .../factory.go => protocol/grpc/internal/server.go | 49 ++- protocol/grpc/protoc-gen-dubbo/examples/Makefile | 4 + .../protoc-gen-dubbo/examples/helloworld.pb.go | 284 + .../protoc-gen-dubbo/examples/helloworld.proto | 37 +++ protocol/grpc/protoc-gen-dubbo/main.go | 74 + .../grpc/protoc-gen-dubbo/plugin/dubbo/doc.go | 25 +- .../grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go| 346 + protocol/grpc/server.go| 101 ++ protocol/invocation.go | 1 + protocol/invocation/rpcinvocation.go | 27 +- protocol/jsonrpc/jsonrpc_protocol.go | 2 +- protocol/jsonrpc/jsonrpc_protocol_test.go | 2 +- protocol/protocol.go | 4 +- protocol/protocolwrapper/mock_protocol_filter.go | 2 +- .../protocolwrapper/protocol_filter_wrapper.go | 4 +- .../protocol_filter_wrapper_test.go| 2 +- registry/directory/directory.go| 8 +- registry/directory/directory_test.go | 6 +- registry/protocol/protocol.go | 4 +- registry/protocol/protocol_test.go | 6 +- registry/zookeeper/registry.go | 1 + remoting/zookeeper/client.go | 1 + remoting/zookeeper/listener.go | 4 + 43 files changed, 1749 insertions(+), 159 deletions(-) copy config_center/apollo/factory.go => protocol/grpc/client.go (54%) create mode 100644 protocol/grpc/client_test.go create mode 100644 protocol/grpc/common_test.go copy cluster/cluster_impl/forking_cluster.go => protocol/grpc/grpc_exporter.go (54%) create mode 100644 protocol/grpc/grpc_invoker.go create mode 100644 protocol/grpc/grpc_invoker_test.go create mode 100644 protocol/grpc/grpc_protocol.go create mode 100644 protocol/grpc/grpc_protocol_test.go copy cluster/cluster_impl/forking_cluster.go => protocol/grpc/internal/client.go (62%) copy cluster/cluster_impl/forking_cluster.go => protocol/grpc/internal/doc.go (61%) create mode 100644 protocol/grpc/internal/helloworld.pb.go copy config_center/apollo/factory.go => protocol/grpc/internal/server.go (50%) create mode 100644 protocol/grpc/protoc-gen-dubbo/examples/Makefile create mode 100644 protocol/grpc/protoc-gen-dubbo/examples/helloworld.pb.go create mode 100644 protocol/grpc/protoc-gen-dubbo/examples/helloworld.proto
[dubbo-go] branch feature/metrics updated (3fe96d3 -> 2ce0708)
This is an automated email from the ASF dual-hosted git repository. flycash pushed a change to branch feature/metrics in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from 3fe96d3 Merge pull request #277 from xujianhai666/fix-dep new e885bc3 Define many interfaces new 0b3238d Impl metrics_filter new 6db26ea Tested metrics filter new d84776a Add Counter,Bucket...interfaces and Implement the Counter, Clock interface new 8d62d00 impl bucket queue and tested new 33786be impl bucket_counter_impl and ManualClock & tested them new 673996b impl FastCompass and tested new a78e280 define MetricRegistry & import prometheus dependiencies new ac581fd Merge branch 'develop' of https://github.com/apache/dubbo-go into feature/MetricsFilter new 1399fd7 impl MetricRegistry & DefaultMetricManager & Nop new b9407cf Finish coding and tests new c378d55 Format the import new 9b3ec29 Add UT for metric config new a966fc1 Merge branch 'develop' of https://github.com/apache/dubbo-go into feature/MetricsFilter new 525d83d Fix BUG: create the NopFastCompass when we are over max metric count limitation in MetricRegistryImpl new 720def0 Ftr: replace func(rate, interval) with TpsStrategyCreator interface new eb434b6 Merge pull request #280 from flycash/feature/StrategyCreator new d024a3c Fix BUG: The RegistryConfigurationListener will be closed twice sometimes new d65659f Merge pull request #281 from flycash/bug/negativeWGC new 02031fe Merge branch 'develop' of https://github.com/apache/dubbo-go into feature/MetricsFilter new 1300821 define the EWMA new 09dd27c implementing EWMA new 638150a Add ewma_test new f5d4a9a Finish ewma testing new 4552d20 define the snapshot interface new a5c2bc6 implements BucketSnapshot new 8a9c212 Finish testing new 7fb327e consistent hash load balance new 80e5bf5 fix comment. new c27f733 Merge pull request #261 from imxyb/consistent-hash-lb new 222a036 Update README.md new a8e6de6 Update README_CN.md new 81fb648 Update README.md new 39f9052 Update README_CN.md new 8703390 Merge branch 'master' into develop new 23a25a7 Merge branch 'master-dubbo-go-apache' into feature/addAsyncCall new 4a49f8c add async callback new 64815e8 fix case new 0020ac4 fix case new df36097 Merge branch 'master-dubbo-go-apache' into feature/addAsyncCall new d0f16d2 add async callback new 5bf5fc1 fix case new ae50c05 fix case new dba634e Merge remote-tracking branch 'origin/feature/addAsyncCall' into feature/addAsyncCall new 498453c modify async callback new f89f642 fix case new ce62359 fix case new 13f15ea fix review problems new 25d2c23 add test case for async call new 9c83f5e Merge pull request #272 from zouyx/feature/addAsyncCall new c0839f0 support zkpath urlencoder new 5a50da7 Merge pull request #283 from xujianhai666/feat-urlencoder new 56cb00a Merge branch 'develop' of https://github.com/apache/dubbo-go into develop new 3c1a96f support sticky connection new 9604e7a Merge pull request #270 from CodingSinger/sticky new d1da7ba change the position of the lock new 16aff1f fix bug for reverseRegistryProtocol new e6e0e14 Modify code according to code review new 8d46ac0 Merge pull request #286 from pantianying/develop_gettyPool_lock new 4ce2ea8 Mod: modify README new 944e6dc add lock for invocation attachment new 382169c Merge pull request #288 from xujianhai666/fix-map-attach new be1dba2 Merge branch 'develop' of https://github.com/apache/dubbo-go into feature/MetricsFilter new b0d4a50 Fix Review new 3edfbda Merge branch 'feature/MetricsFilter' of https://github.com/flycash/dubbo-go into feature/Compass new 6da0bb2 re-arrange imports new addb7ff Add error as result type for Snapshot interface new 2927fdb Fix UT new 89982f6 Implementing SlidingWindowReservoir new 282124c Implemented uniform_snapshot new 1632d5a Add uniform reservoir new f1b5d12 Fix: receive heartbeat from server new 4409354 optimize code style new b74bb2f fix code new ba0b1a3 bug fix new c6f6377 Merge pull request #293 from pantianying/develop_generic_code_fix new e0e015c Merge branch 'develop' into heartbeat_for_server new 53bb7fb add notes new 01f84dc Merge pull request #302 from fangyincheng/heartbeat_for_server new 11b6141 Merge branch 'develop' of https://github.com/apache/dubbo-go into feature/MetricsFilter new 88f696a Implement Compass & tested new b4d116a generic service filter new 131ad2d go.mod modify new 1ac170a reponse fix new 5ef93c3 optimize code new fe314db fix new 6aca4f5 m
