Method Run

pkg/controllers/cloudshell_controller.go:219–255

(workers int, stopCh <-chan struct{})

}

func (c *Controller) Run(workers int, stopCh <-chan struct{}) {
	defer utilruntime.HandleCrash()
	defer c.queue.ShutDown()

	klog.InfoS("Start CloudShell Controller")
	defer klog.InfoS("Shutting down CloudShell Controller")

	if !cache.WaitForCacheSync(stopCh, c.cloudshellInformer.HasSynced) {
		klog.Errorf("cloudshell manager: wait for cloushell informer factory failed")
	}
	if !cache.WaitForCacheSync(stopCh, c.podInformer.HasSynced) {
		klog.Errorf("cloudshell manager: wait for pod informer factory failed")
	}
	currentNS := util.GetCurrentNSOrDefault()
	configs, err := c.kubeClient.CoreV1().ConfigMaps(currentNS).List(context.TODO(), metav1.ListOptions{LabelSelector: CloudshellConfigMapLabel})
	if err != nil {
		klog.ErrorS(err, "failed to list CloudShell ConfigMap")
	} else {
		if len(configs.Items) > 0 {
			c.ttydServiceBufferSize = configs.Items[0].Data["TTYD_SERVER_BUFFER_SIZE"]
			c.ttydPingInterval = configs.Items[0].Data["TTYD_PING_INTERVAL"]
		}
	}

	var wg sync.WaitGroup
	for i := 0; i < workers; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			c.worker(stopCh)
		}()
	}
	<-stopCh

	c.queue.ShutDown()
	wg.Wait()
}

func (c *Controller) syncHandler(ctx context.Context, key string) (*time.Duration, error) {
	klog.V(4).Infof("Reconciling cloudshell %s", key)