Commit ea2d19f5 authored by gmarek's avatar gmarek

Remove unused argument to NodeController.Run

parent 177a6840
...@@ -242,7 +242,7 @@ func StartControllers(s *options.CMServer, kubeClient *client.Client, kubeconfig ...@@ -242,7 +242,7 @@ func StartControllers(s *options.CMServer, kubeClient *client.Client, kubeconfig
if err != nil { if err != nil {
glog.Fatalf("Failed to initialize nodecontroller: %v", err) glog.Fatalf("Failed to initialize nodecontroller: %v", err)
} }
nodeController.Run(s.NodeSyncPeriod.Duration) nodeController.Run()
time.Sleep(wait.Jitter(s.ControllerStartInterval.Duration, ControllerStartJitter)) time.Sleep(wait.Jitter(s.ControllerStartInterval.Duration, ControllerStartJitter))
serviceController, err := servicecontroller.New(cloud, clientset.NewForConfigOrDie(restclient.AddUserAgent(kubeconfig, "service-controller")), s.ClusterName) serviceController, err := servicecontroller.New(cloud, clientset.NewForConfigOrDie(restclient.AddUserAgent(kubeconfig, "service-controller")), s.ClusterName)
......
...@@ -164,7 +164,7 @@ func (s *CMServer) Run(_ []string) error { ...@@ -164,7 +164,7 @@ func (s *CMServer) Run(_ []string) error {
if err != nil { if err != nil {
glog.Fatalf("Failed to initialize nodecontroller: %v", err) glog.Fatalf("Failed to initialize nodecontroller: %v", err)
} }
nodeController.Run(s.NodeSyncPeriod.Duration) nodeController.Run()
nodeStatusUpdaterController := node.NewStatusUpdater(clientset.NewForConfigOrDie(restclient.AddUserAgent(kubeconfig, "node-status-controller")), s.NodeMonitorPeriod.Duration, time.Now) nodeStatusUpdaterController := node.NewStatusUpdater(clientset.NewForConfigOrDie(restclient.AddUserAgent(kubeconfig, "node-status-controller")), s.NodeMonitorPeriod.Duration, time.Now)
if err := nodeStatusUpdaterController.Run(wait.NeverStop); err != nil { if err := nodeStatusUpdaterController.Run(wait.NeverStop); err != nil {
......
...@@ -383,7 +383,7 @@ func NewNodeControllerFromClient( ...@@ -383,7 +383,7 @@ func NewNodeControllerFromClient(
} }
// Run starts an asynchronous loop that monitors the status of cluster nodes. // Run starts an asynchronous loop that monitors the status of cluster nodes.
func (nc *NodeController) Run(period time.Duration) { func (nc *NodeController) Run() {
go nc.nodeController.Run(wait.NeverStop) go nc.nodeController.Run(wait.NeverStop)
go nc.podController.Run(wait.NeverStop) go nc.podController.Run(wait.NeverStop)
go nc.daemonSetController.Run(wait.NeverStop) go nc.daemonSetController.Run(wait.NeverStop)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment