GKE中のプログラムからKubernetesジョブを生成して非同期処理を行う

// Run a job
func (jh SampleHandler) RunAJob(c echo.Context) error {
	jobInfo := new(JobInfo)
	if err := c.Bind(jobInfo); err != nil {
		c.JSON(http.StatusBadRequest, "input parameters error")
	}

	// creates the in-cluster config
	config, err := rest.InClusterConfig()
	if err != nil {
		panic(err.Error())
	}
	// creates the clientset
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(err.Error())
	}

	jobClient := clientset.BatchV1().Jobs("default")

	job := &batchv1.Job{
		ObjectMeta: metav1.ObjectMeta{
			GenerateName: "dummy-job-",
		},
		Spec: batchv1.JobSpec{
			// the retries number when job failed. No retry for this dummy job
			BackoffLimit: int32Ptr(0),

			// auto delete job after finished
			TTLSecondsAfterFinished: int32Ptr(300),
			Template: apiv1.PodTemplateSpec{
				ObjectMeta: metav1.ObjectMeta{
					GenerateName: "dummy-job-",
				},
				Spec: apiv1.PodSpec{
					Containers: []apiv1.Container{
						{
							Name:    "dummy-job-container",
							Image:   fmt.Sprintf("%s/%s/dummyjob", containerRegistryRepo, projectID),
							Command: []string{"/app/dummyjob"},
							Args:    []string{"--api-end-point", statusUpdateEndpoint, "--job-id", jobInfo.JobId},
						},
					},
					RestartPolicy: apiv1.RestartPolicyNever,
				},
			},
		},
	}

	fmt.Println("Creating job... ")

	result1, err1 := jobClient.Create(job)
	if err != nil {
		fmt.Println(err1)
		panic(err1)
	}

	jobName := result1.GetName()
	fmt.Printf("Created job %s\n", jobName)

	jobs = append(jobs, &JobInfo{
		JobId:      jobInfo.JobId,
		JobName: jobName,
		Status:  "-",
	})

	return c.Redirect(http.StatusMovedPermanently, "/index")
}