mirror of
https://github.com/alibaba/higress.git
synced 2026-05-27 06:07:27 +08:00
fix: Fix incorrect logging functions used in eureka registry integration (#563)
This commit is contained in:
@@ -69,11 +69,11 @@ func (p *Plan) watch(ch <-chan fargo.AppUpdate) {
|
|||||||
return
|
return
|
||||||
case updateItem := <-ch:
|
case updateItem := <-ch:
|
||||||
if updateItem.Err != nil {
|
if updateItem.Err != nil {
|
||||||
log.Error("get eureka application failed, error : %v", updateItem.Err)
|
log.Errorf("get eureka application failed, error : %v", updateItem.Err)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if err := p.handler(updateItem.App); err != nil {
|
if err := p.handler(updateItem.App); err != nil {
|
||||||
log.Error("handle eureka application failed, error : %v", err)
|
log.Errorf("handle eureka application failed, error : %v", err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -147,7 +147,7 @@ func (w *watcher) Run() {
|
|||||||
case <-ticker.C:
|
case <-ticker.C:
|
||||||
w.doFullRefresh()
|
w.doFullRefresh()
|
||||||
case <-w.stop:
|
case <-w.stop:
|
||||||
log.Info("eureka watcher(%v) is stopping ...", w.Name)
|
log.Infof("eureka watcher(%v) is stopping ...", w.Name)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user