This is an automated email from the ASF dual-hosted git repository.
alexstocks pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/3.0 by this push:
new 35f4e8c19 fix: typo correction (#1924)
35f4e8c19 is described below
commit 35f4e8c19e90aac9430352a33b4dcb6ad42e7076
Author: yuez <[email protected]>
AuthorDate: Fri Jun 10 13:07:17 2022 +0800
fix: typo correction (#1924)
* fix: typo correction
* fix: replace magic string with constant
---
config/reference_config.go | 2 +-
remoting/xds/error.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/config/reference_config.go b/config/reference_config.go
index f370691b0..c53bc5242 100644
--- a/config/reference_config.go
+++ b/config/reference_config.go
@@ -192,7 +192,7 @@ func (rc *ReferenceConfig) Refer(srv interface{}) {
invokers := make([]protocol.Invoker, len(rc.urls))
for i, u := range rc.urls {
if u.Protocol == constant.ServiceRegistryProtocol {
- invoker = extension.GetProtocol("registry").Refer(u)
+ invoker =
extension.GetProtocol(constant.RegistryProtocol).Refer(u)
} else {
invoker = extension.GetProtocol(u.Protocol).Refer(u)
}
diff --git a/remoting/xds/error.go b/remoting/xds/error.go
index 2711cf7a7..29c899c9f 100644
--- a/remoting/xds/error.go
+++ b/remoting/xds/error.go
@@ -22,6 +22,6 @@ import (
)
var (
- DiscoverLocalError = errors.New("Discovery local Pod's host from
xds, failed please register service with endpoint to k8s ")
+ DiscoverLocalError = errors.New("Discovery local Pod's host from
xds failed, please register service with endpoint to k8s ")
DiscoverIstiodPodIpError = errors.New("Discovery istiod Pod's ip from
xds failed, please register service with endpoint to k8s ")
)