(dubbo-kubernetes) branch master updated: [horus] delete model plugin (#336)

[zhongxjian]

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 e0b88044 [horus] delete model plugin (#336)
e0b88044 is described below

commit e0b88044a5a6def91c10d569fd2c6cb15b44b6b8
Author: mfordjody <11638...@qq.com>
AuthorDate: Thu Sep 12 10:55:29 2024 +0800

    [horus] delete model plugin (#336)
---
 app/horus/core/horuser/action.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/app/horus/core/horuser/action.go b/app/horus/core/horuser/action.go
index c02876ac..4dc040df 100644
--- a/app/horus/core/horuser/action.go
+++ b/app/horus/core/horuser/action.go
@@ -20,11 +20,11 @@ import (
        "k8s.io/klog/v2"
 )
 
-func (h *Horuser) Cordon(nodeName, clusterName, modelName string) (err error) {
+func (h *Horuser) Cordon(nodeName, clusterName string) (err error) {
        kubeClient := h.kubeClientMap[clusterName]
        if kubeClient == nil {
                klog.Errorf("node Cordon kubeClient by clusterName empty.")
-               klog.Infof("nodeName:%v,clusterName:%v,modelName:%v", nodeName, 
clusterName, modelName)
+               klog.Infof("nodeName:%v,clusterName:%v", nodeName, clusterName)
                return err
        }
 
@@ -32,7 +32,7 @@ func (h *Horuser) Cordon(nodeName, clusterName, modelName 
string) (err error) {
        defer cancelFirst()
        node, err := kubeClient.CoreV1().Nodes().Get(ctxFirst, nodeName, 
v1.GetOptions{})
        if err != nil {
-               klog.Errorf("node Cordon get err nodeName:%v clusterName:%v 
modelName:%v", nodeName, clusterName, modelName)
+               klog.Errorf("node Cordon get err nodeName:%v clusterName:%v", 
nodeName, clusterName)
                return err
        }
 
@@ -42,10 +42,10 @@ func (h *Horuser) Cordon(nodeName, clusterName, modelName 
string) (err error) {
        defer cancelSecond()
        node, err = kubeClient.CoreV1().Nodes().Update(ctxSecond, node, 
v1.UpdateOptions{})
        if err != nil {
-               klog.Errorf("node Cordon update err nodeName:%v clusterName:%v 
modelName:%v", nodeName, clusterName, modelName)
+               klog.Errorf("node Cordon update err nodeName:%v 
clusterName:%v", nodeName, clusterName)
                return err
        }
-       klog.Infof("node Cordon success nodeName:%v clusterName:%v 
modelName:%v", nodeName, clusterName, modelName)
+       klog.Infof("node Cordon success nodeName:%v clusterName:%v", nodeName, 
clusterName)
        return nil
 }