You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by zh...@apache.org on 2024/09/13 07:30:53 UTC
(dubbo-kubernetes) branch master updated: [horus] Add recovery node features (#342)
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 5e5f3ebc [horus] Add recovery node features (#342)
5e5f3ebc is described below
commit 5e5f3ebc4cd837d5a5f3cafb1e2ec51bdaadb5dc
Author: mfordjody <11...@qq.com>
AuthorDate: Fri Sep 13 15:30:49 2024 +0800
[horus] Add recovery node features (#342)
* [horus] Add recovery node features
* fix typo
---
app/horus/core/horuser/action.go | 29 +++++++++++++++++++++++++++++
1 file changed, 29 insertions(+)
diff --git a/app/horus/core/horuser/action.go b/app/horus/core/horuser/action.go
index 3df16c58..f438258e 100644
--- a/app/horus/core/horuser/action.go
+++ b/app/horus/core/horuser/action.go
@@ -50,6 +50,35 @@ func (h *Horuser) Cordon(nodeName, clusterName string) (err error) {
return nil
}
+func (h *Horuser) UnCordon(nodeName, clusterName string) (err error) {
+ kubeClient := h.kubeClientMap[clusterName]
+ if kubeClient == nil {
+ klog.Errorf("node UnCordon kubeClient by clusterName empty.")
+ klog.Infof("nodeName:%v,clusterName:%v", nodeName, clusterName)
+ return err
+ }
+
+ ctxFirst, cancelFirst := h.GetK8sContext()
+ defer cancelFirst()
+ node, err := kubeClient.CoreV1().Nodes().Get(ctxFirst, nodeName, v1.GetOptions{})
+ if err != nil {
+ klog.Errorf("node UnCordon get err nodeName:%v clusterName:%v", nodeName, clusterName)
+ return err
+ }
+
+ node.Spec.Unschedulable = false
+
+ ctxSecond, cancelSecond := h.GetK8sContext()
+ defer cancelSecond()
+ node, err = kubeClient.CoreV1().Nodes().Update(ctxSecond, node, v1.UpdateOptions{})
+ if err != nil {
+ klog.Errorf("node UnCordon update err nodeName:%v clusterName:%v", nodeName, clusterName)
+ return err
+ }
+ klog.Infof("node UnCordon success nodeName:%v clusterName:%v", nodeName, clusterName)
+ return nil
+}
+
func (h *Horuser) Drain(nodeName, clusterName string) (err error) {
kubeClient := h.kubeClientMap[clusterName]
if kubeClient == nil {