This is an automated email from the ASF dual-hosted git repository.
baerwang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
The following commit(s) were added to refs/heads/main by this push:
new 5e774eca0 modify (#2738)
5e774eca0 is described below
commit 5e774eca0f141ead2e5feabe706eedc62be488ec
Author: 王聪洋 <[email protected]>
AuthorDate: Tue Oct 29 17:31:29 2024 +0800
modify (#2738)
---
cluster/router/affinity/router.go | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/cluster/router/affinity/router.go
b/cluster/router/affinity/router.go
index 1ced13dcd..49555c7aa 100644
--- a/cluster/router/affinity/router.go
+++ b/cluster/router/affinity/router.go
@@ -61,7 +61,7 @@ func (s *ServiceAffinityRoute) Notify(invokers
[]protocol.Invoker) {
dynamicConfiguration := conf.GetEnvInstance().GetDynamicConfiguration()
if dynamicConfiguration == nil {
- logger.Infof("Config center does not start, Condition router
will not be enabled")
+ logger.Infof("Config center does not start, Affinity router
will not be enabled")
return
}
@@ -101,19 +101,19 @@ func (s *ApplicationAffinityRoute) Notify(invokers
[]protocol.Invoker) {
}
url := invokers[0].GetURL()
if url == nil {
- logger.Error("Failed to notify a dynamically condition rule,
because url is empty")
+ logger.Error("Failed to notify a dynamically affinity rule,
because url is empty")
return
}
dynamicConfiguration := conf.GetEnvInstance().GetDynamicConfiguration()
if dynamicConfiguration == nil {
- logger.Infof("Config center does not start, Condition router
will not be enabled")
+ logger.Infof("Config center does not start, Affinity router
will not be enabled")
return
}
providerApplication := url.GetParam("application", "")
if providerApplication == "" || providerApplication ==
s.currentApplication {
- logger.Warn("condition router get providerApplication is empty,
will not subscribe to provider app rules.")
+ logger.Warn("Affinity router get providerApplication is empty,
will not subscribe to provider app rules.")
return
}
@@ -127,7 +127,7 @@ func (s *ApplicationAffinityRoute) Notify(invokers
[]protocol.Invoker) {
dynamicConfiguration.AddListener(key, s)
value, err := dynamicConfiguration.GetRule(key)
if err != nil {
- logger.Errorf("Failed to query condition rule, key=%s,
err=%v", key, err)
+ logger.Errorf("Failed to query affinity rule, key=%s,
err=%v", key, err)
return
}