1
0
mirror of https://github.com/kubernetes-sigs/descheduler.git synced 2026-01-28 06:29:29 +01:00

Fix rescheduler node implementation.

This commit is contained in:
Avesh Agarwal
2017-07-31 01:31:43 -04:00
parent 568d898372
commit f8f7876e84

View File

@@ -17,13 +17,15 @@ limitations under the License.
package node package node
import ( import (
"fmt"
"time" "time"
"k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/fields"
corelisters "k8s.io/client-go/listers/core/v1" "k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/cache"
"k8s.io/kubernetes/pkg/api/v1" "k8s.io/kubernetes/pkg/api/v1"
"k8s.io/kubernetes/pkg/client/clientset_generated/clientset" "k8s.io/kubernetes/pkg/client/clientset_generated/clientset"
corelisters "k8s.io/kubernetes/pkg/client/listers/core/v1"
) )
// ReadyNodes returns ready nodes irrespective of whether they are // ReadyNodes returns ready nodes irrespective of whether they are
@@ -59,7 +61,7 @@ func IsReady(node *v1.Node) bool {
// - NodeOutOfDisk condition status is ConditionFalse, // - NodeOutOfDisk condition status is ConditionFalse,
// - NodeNetworkUnavailable condition status is ConditionFalse. // - NodeNetworkUnavailable condition status is ConditionFalse.
if cond.Type == v1.NodeReady && cond.Status != v1.ConditionTrue { if cond.Type == v1.NodeReady && cond.Status != v1.ConditionTrue {
glog.V(4).Infof("Ignoring node %v with %v condition status %v", node.Name, cond.Type, cond.Status) fmt.Printf("Ignoring node %v with %v condition status %v", node.Name, cond.Type, cond.Status)
return false return false
} /*else if cond.Type == v1.NodeOutOfDisk && cond.Status != v1.ConditionFalse { } /*else if cond.Type == v1.NodeOutOfDisk && cond.Status != v1.ConditionFalse {
glog.V(4).Infof("Ignoring node %v with %v condition status %v", node.Name, cond.Type, cond.Status) glog.V(4).Infof("Ignoring node %v with %v condition status %v", node.Name, cond.Type, cond.Status)