Method createWorker

pkg/workerpool/worker_pool.go:481–522

(req *Request)

}

func (w *WorkerPool) createWorker(req *Request) error {
	nodeSelector, err := util.JSONStringToMap(req.NodeSelector)
	if err != nil {
		return fmt.Errorf("failed to unmarshal node selector for cloudshell, err: %v", err)
	}
	podBytes, err := util.ParseTemplate(manifests.PodTmplV1, struct {
		Name         string
		Namespace    string
		Image        string
		NodeSelector map[string]string
		Resources    *cloudshellv1alpha1.ResourceSetting
	}{
		Name:         fmt.Sprintf("cloudshell-worker-%s", rand.String(10)),
		Namespace:    req.Namespace,
		Image:        req.Image,
		NodeSelector: nodeSelector,
		Resources:    req.Resources,
	})
	if err != nil {
		return errors.Wrap(err, "failed create cloudshell job")
	}

	decoder := scheme.Codecs.UniversalDeserializer()
	obj, _, err := decoder.Decode(podBytes, nil, nil)
	if err != nil {
		klog.ErrorS(err, "failed to decode pod manifest")
		return err
	}
	pod := obj.(*corev1.Pod)

	pod.SetLabels(map[string]string{
		constants.WorkerOwnerLabelKey: "", constants.WorkerRequestLabelKey: req.Cloudshell, constants.WorkerNameLabelKey: pod.GetName(),
	})

	controllerutil.AddFinalizer(pod, ControllerFinalizer)

	if err := w.Create(context.TODO(), pod); err != nil {
		return err
	}
	klog.InfoS("worker created", "cloudshell", req.Cloudshell)
	return w.CreateServiceFor(context.TODO(), pod)
}

func (w *WorkerPool) CreateServiceFor(_ context.Context, worker *corev1.Pod) error {
	serviceBytes, err := util.ParseTemplate(manifests.ServiceTmplV1, struct {