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 ")
 )

Reply via email to