Sok3t/descheduler
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/descheduler.git synced 2026-01-28 14:41:10 +01:00
Code Packages Releases Activity

Implement rescheduler's node lister.

Browse Source
This commit is contained in:
Avesh Agarwal
2017-07-31 01:18:18 -04:00
parent 00a30509d6
commit d3c5104cfe
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
cmd/rescheduler/app/server.go
View File

@@ -22,6 +22,7 @@ import (
"github.com/aveshagarwal/rescheduler/cmd/rescheduler/app/options" "github.com/aveshagarwal/rescheduler/cmd/rescheduler/app/options"
"github.com/aveshagarwal/rescheduler/pkg/rescheduler/client" "github.com/aveshagarwal/rescheduler/pkg/rescheduler/client"
"github.com/aveshagarwal/rescheduler/pkg/rescheduler/node"
//"github.com/golang/glog" //"github.com/golang/glog"
"github.com/spf13/cobra" "github.com/spf13/cobra"
@@ -50,10 +51,14 @@ func NewReschedulerCommand() *cobra.Command {
func Run(rs *options.ReschedulerServer) error { func Run(rs *options.ReschedulerServer) error {
rsclient, err := client.CreateClient(rs.KubeconfigFile) rsclient, err := client.CreateClient(rs.KubeconfigFile)
if err != nil { if err != nil {
return err return err
} }
rs.Client = rsclient rs.Client = rsclient
stopChannel := make(chan struct{})
nodes, err := ReadyNodes(rs.Client, stopChannel)
if err != nil {
return err
}
return nil return nil
} }