Function StartControllers

cmd/app/cloudshell-manager.go:142–170

(c *config.Config, stopCh <-chan struct{})

}

func StartControllers(c *config.Config, stopCh <-chan struct{}) error {
	ownerExist, err := labels.NewRequirement(constants.WorkerOwnerLabelKey, selection.Exists, nil)
	if err != nil {
		return err
	}

	labelsSelector := labels.NewSelector().Add(*ownerExist)

	factory := informers.NewSharedInformerFactoryWithOptions(c.KubeClient, 0,
		informers.WithTweakListOptions(func(opts *metav1.ListOptions) {
			opts.LabelSelector = labelsSelector.String()
		}))

	podInformer := factory.Core().V1().Pods()
	pool := worerkpool.New(c.Client, c.CoreWorkerLimit, c.MaxWorkerLimit, podInformer)

	informerFactory := externalversions.NewSharedInformerFactory(c.CloudShellClient, 0)
	informer := informerFactory.Cloudshell().V1alpha1().CloudShells()
	controller := controllers.New(c.Client, c.KubeClient, c.Kubeconfig, pool, c.CloudShellImage, c.NodeSelector, c.Resources, informer, podInformer)

	factory.Start(stopCh)
	informerFactory.Start(stopCh)

	go pool.Run(stopCh)
	go controller.Run(1, stopCh)

	<-stopCh
	return nil
}