This is an automated email from the ASF dual-hosted git repository.
zhongxjian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-kubernetes.git
The following commit(s) were added to refs/heads/master by this push:
new 8d114438 [horus] Node restart or maintenance runtime logic (#368)
8d114438 is described below
commit 8d1144384877dd9ef8ab716eaa685bad3fa9a09e
Author: mfordjody <[email protected]>
AuthorDate: Mon Sep 23 08:52:36 2024 +0800
[horus] Node restart or maintenance runtime logic (#368)
---
app/horus/cmd/main.go | 18 ++++++++++++------
1 file changed, 12 insertions(+), 6 deletions(-)
diff --git a/app/horus/cmd/main.go b/app/horus/cmd/main.go
index aed1bc02..909ad234 100644
--- a/app/horus/cmd/main.go
+++ b/app/horus/cmd/main.go
@@ -118,12 +118,18 @@ func main() {
return nil
})
group.Add(func() error {
- if c.CustomModular.Enabled {
- klog.Info("horus down time manager start success.")
- err := horus.DownTimeManager(ctx)
- if err != nil {
- klog.Errorf("horus down time manager start
failed error:%v", err)
- }
+ klog.Info("horus down time manager start success.")
+ err := horus.DownTimeManager(ctx)
+ if err != nil {
+ klog.Errorf("horus down time manager start failed
error:%v", err)
+ }
+ return nil
+ })
+ group.Add(func() error {
+ klog.Info("horus down time restart manager start success.")
+ err := horus.DowntimeRestartManager(ctx)
+ if err != nil {
+ klog.Errorf("horus down time restart manager start
failed error:%v", err)
}
return nil
})
