func StartController()

in pkg/localcontroller/controller.go [224:243]

• 15 lines of code
• 3 McCabe index (conditional complexity)

func StartController(ctx context.Context, kubeclientset *kubernetes.Clientset) {
	stopCh := make(chan struct{})
	defer close(stopCh)

	nodeInformer := coreV1informers.NewNodeInformer(kubeclientset, 0, cache.Indexers{})

	controller := NewController(kubeclientset, nodeInformer)

	go nodeInformer.Run(stopCh)

	if err := controller.Run(1, stopCh); err != nil {
		klog.Fatalf("Error running controller: %s", err.Error())
		return
	}

	select {
	case <-ctx.Done():
		return
	}
}