go - Creating a Job with Kubernetes client-go
问题描述
Currently I have a piece of go code that is based on other examples. I can list all the pods, jobs... etc but I am encountering a rather tricky problem with the creation of a Job on Openshift.
The following parts of my code are supposed to create a Job, I even get a response, but no job is being created on the mentioned namespace:
func main() {
var kubeconfig *string
if home := homedir.HomeDir(); home != "" {
kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
} else {
kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
}
flag.Parse()
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
panic(err)
}
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err)
}
jobsClient := clientset.BatchV1().Jobs("gitlab")
job := &batchv1.Job{
ObjectMeta: metav1.ObjectMeta{
Name: "demo-job",
},
Spec: batchv1.JobSpec{
Template: apiv1.PodTemplateSpec{
Spec: apiv1.PodSpec{
Containers: []apiv1.Container{
{
Name: "demo",
Image: "myimage",
},
},
},
},
},
}
fmt.Println("Creating job... ")
result1, err1 := jobsClient.Create(job)
if err != nil {
fmt.Println(err1)
panic(err1)
}
fmt.Printf("Created job %q.\n", result1)
}
As a result, all I get is this:
Created job "&Job{ObjectMeta:k8s_io_apimachinery_pkg_apis_meta_v1.ObjectMeta{Name:,GenerateName:,Namespace:,SelfLink:,UID:,ResourceVersion:,Generation:0,CreationTimestamp:0001-01-01 00:00:00 +0000 UTC,DeletionTimestamp:<nil>,DeletionGracePeriodSeconds:nil,Labels:map[string]string{},Annotations:map[string]string{},OwnerReferences:[],Finalizers:[],ClusterName:,Initializers:nil,},Spec:JobSpec{Parallelism:nil,Completions:nil,ActiveDeadlineSeconds:nil,Selector:nil,ManualSelector:nil,Template:k8s_io_api_core_v1.PodTemplateSpec{ObjectMeta:k8s_io_apimachinery_pkg_apis_meta_v1.ObjectMeta{Name:,GenerateName:,Namespace:,SelfLink:,UID:,ResourceVersion:,Generation:0,CreationTimestamp:0001-01-01 00:00:00 +0000 UTC,DeletionTimestamp:<nil>,DeletionGracePeriodSeconds:nil,Labels:map[string]string{},Annotations:map[string]string{},OwnerReferences:[],Finalizers:[],ClusterName:,Initializers:nil,},Spec:PodSpec{Volumes:[],Containers:[],RestartPolicy:,TerminationGracePeriodSeconds:nil,ActiveDeadlineSeconds:nil,DNSPolicy:,NodeSelector:map[string]string{},ServiceAccountName:,DeprecatedServiceAccount:,NodeName:,HostNetwork:false,HostPID:false,HostIPC:false,SecurityContext:nil,ImagePullSecrets:[],Hostname:,Subdomain:,Affinity:nil,SchedulerName:,InitContainers:[],AutomountServiceAccountToken:nil,Tolerations:[],HostAliases:[],PriorityClassName:,Priority:nil,DNSConfig:nil,},},BackoffLimit:nil,},Status:JobStatus{Conditions:[],StartTime:<nil>,CompletionTime:<nil>,Active:0,Succeeded:0,Failed:0,},}".
Checking on the "gitlab" namespace and there is no new job.
解决方案
基于我过去所做的工作(你可以在这里看到),我认为你可以在 Job 资源的 ObjectMeta 中指定 Namespace。你可以把它放在jobsClient中。
jobsClient := clientset.BatchV1().Jobs()
job := &batchv1.Job{
ObjectMeta: metav1.ObjectMeta{
Name: "demo-job",
Namespace: "gitlab",
},
Spec: batchv1.JobSpec{
Template: apiv1.PodTemplateSpec{
Spec: apiv1.PodSpec{
Containers: []apiv1.Container{
{
Name: "demo",
Image: "myimage",
},
},
},
},
},
}
推荐阅读
- json - 无法在本机反应中获取数据数组
- jenkins - 在 Jenkins 上具有并行作业执行的单一报告
- python - Google Adwords API TargettingIdeaService 设备类型
- java - Java - 如何将提取的 pdf 文件中的单词集成到 MYSQL 以进行索引?
- wordpress - wordpress 将子页面作为参数传递
- java - for循环内的条件问题(JAVA)
- html - 如何使用css显示水平时间线
- javascript - 在 JavaScript 上将 Get 转换为 Post
- python - Python 在 MacOS Mojave 中与 OpenCV 一起崩溃
- angular - TypeScript 已安装,但未执行我的代码