From d3c5104cfec900055c5df53c8a4818edb599f401 Mon Sep 17 00:00:00 2001 From: Avesh Agarwal Date: Mon, 31 Jul 2017 01:18:18 -0400 Subject: [PATCH] Implement rescheduler's node lister. --- cmd/rescheduler/app/server.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/cmd/rescheduler/app/server.go b/cmd/rescheduler/app/server.go index e591899fe..1589a0d9d 100644 --- a/cmd/rescheduler/app/server.go +++ b/cmd/rescheduler/app/server.go @@ -22,6 +22,7 @@ import ( "github.com/aveshagarwal/rescheduler/cmd/rescheduler/app/options" "github.com/aveshagarwal/rescheduler/pkg/rescheduler/client" + "github.com/aveshagarwal/rescheduler/pkg/rescheduler/node" //"github.com/golang/glog" "github.com/spf13/cobra" @@ -50,10 +51,14 @@ func NewReschedulerCommand() *cobra.Command { func Run(rs *options.ReschedulerServer) error { rsclient, err := client.CreateClient(rs.KubeconfigFile) - if err != nil { return err } rs.Client = rsclient + stopChannel := make(chan struct{}) + nodes, err := ReadyNodes(rs.Client, stopChannel) + if err != nil { + return err + } return nil }