Function WorkerKeyFunc

pkg/workerpool/worker_pool.go:593–620

(obj interface{})

}

func WorkerKeyFunc(obj interface{}) (string, error) {
	worker, ok := obj.(*corev1.Pod)
	if !ok {
		return "", fmt.Errorf("no support the type struct")
	}

	objName, err := cache.ObjectToName(worker)
	if err != nil {
		return "", err
	}

	ttyd := corev1.Container{}
	for _, container := range worker.Spec.Containers {
		if container.Name == "web-tty" {
			ttyd = container
			break
		}
	}
	if len(ttyd.Image) == 0 {
		return "", fmt.Errorf("web-tty container image not found")
	}

	if len(objName.Namespace) > 0 {
		return fmt.Sprintf("%s//%s//%s", objName.Namespace, ttyd.Image, objName.Name), nil
	}

	return fmt.Sprintf("%s//%s", ttyd.Image, objName.Name), nil
}