Function New

pkg/controllers/cloudshell_controller.go:93–155

(client client.Client, kubeClient kubernetes.Interface, config *rest.Config, wp *worerkpool.WorkerPool, cloudshellImage string,
	nodeSelector map[string]string, resources *cloudshellv1alpha1.ResourceSetting,
	cloudshellInformer cloudshellinformers.CloudShellInformer, podInformer informercorev1.PodInformer,
)

}

func New(client client.Client, kubeClient kubernetes.Interface, config *rest.Config, wp *worerkpool.WorkerPool, cloudshellImage string,
	nodeSelector map[string]string, resources *cloudshellv1alpha1.ResourceSetting,
	cloudshellInformer cloudshellinformers.CloudShellInformer, podInformer informercorev1.PodInformer,
) *Controller {
	controller := &Controller{
		Client:     client,
		kubeClient: kubeClient,
		config:     config,
		Scheme:     gclient.NewSchema(),
		workerPool: wp,
		queue: workqueue.NewRateLimitingQueue(
			workqueue.NewItemExponentialFailureRateLimiter(DefaultCloudShellBackOff, MaxCloudShellBackOff),
		),

		cloudshellInformer: cloudshellInformer.Informer(),
		lister:             cloudshellInformer.Lister(),
		podInformer:        podInformer.Informer(),
		podLister:          podInformer.Lister(),
		cloudshellImage:    cloudshellImage,
		nodeSelector:       nodeSelector,
		resources:          resources,
	}

	_, err := cloudshellInformer.Informer().AddEventHandler(
		cache.ResourceEventHandlerFuncs{
			AddFunc: func(obj interface{}) {
				controller.enqueue(obj)
			},
			UpdateFunc: func(oldObj, newObj interface{}) {
				older := oldObj.(*cloudshellv1alpha1.CloudShell)
				newer := newObj.(*cloudshellv1alpha1.CloudShell)
				if !reflect.DeepEqual(older.Spec, newer.Spec) || !newer.DeletionTimestamp.IsZero() {
					controller.enqueue(newObj)
				}
			},
			DeleteFunc: func(obj interface{}) {
				controller.enqueue(obj)
			},
		},
	)
	if err != nil {
		klog.ErrorS(err, "error when adding event handler to informer")
	}

	_, err = podInformer.Informer().AddEventHandler(
		cache.ResourceEventHandlerFuncs{
			AddFunc: func(obj interface{}) {
				controller.enqueueCloudshellForPod(obj)
			},
			UpdateFunc: func(_, newObj interface{}) {
				controller.enqueueCloudshellForPod(newObj)
			},
			DeleteFunc: func(obj interface{}) {
				controller.enqueueCloudshellForPod(obj)
			},
		},
	)
	if err != nil {