-
Notifications
You must be signed in to change notification settings - Fork 20
/
job_operations.js
91 lines (78 loc) · 2.6 KB
/
job_operations.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
import { Kubernetes } from 'k6/x/kubernetes';
import { describe, expect } from 'https://jslib.k6.io/k6chaijs/4.3.4.3/index.js';
import { load } from 'https://cdn.jsdelivr.net/npm/[email protected]/dist/js-yaml.mjs';
let json = {
apiVersion: "batch/v1",
kind: "Job",
metadata: {
name: "json-job",
namespace: "default",
},
spec: {
ttlSecondsAfterFinished: 30,
template: {
spec: {
containers: [
{
name: "myjob",
image: "perl:5.34.0",
command: ["perl", "-Mbignum=bpi", "-wle", "print bpi(2000)"],
},
],
restartPolicy: "Never",
}
},
backoffLimit: 4,
}
}
let yaml = `
apiVersion: batch/v1
kind: Job
metadata:
name: yaml-job
namespace: default
spec:
ttlSecondsAfterFinished: 30
suspend: false
template:
spec:
containers:
- name: myjob
image: perl:5.34.0
command: ["perl", "-Mbignum=bpi", "-wle", "print bpi(2000)"]
restartPolicy: Never
backoffLimit: 4
`
export default function () {
const kubernetes = new Kubernetes();
describe('JSON-based resources', () => {
const name = json.metadata.name
const ns = json.metadata.namespace
const helpers = kubernetes.helpers(ns)
let job
describe('Create our job using the JSON definition and wait until completed', () => {
job = kubernetes.create(json)
expect(job.metadata, 'new job').to.have.property('uid')
let timeout = 10
expect(helpers.waitJobCompleted(name, timeout), `job completion within ${timeout}s`).to.be.true
let fetched = kubernetes.get("Job.batch", name, ns)
expect(job.metadata.uid, 'created and fetched uids').to.equal(fetched.metadata.uid)
})
describe('Retrieve all available jobs', () => {
expect(kubernetes.list("Job.batch", ns).length, 'total jobs').to.be.at.least(1)
})
describe('Remove our jobs to cleanup', () => {
kubernetes.delete("Job.batch", name, ns)
})
})
describe('YAML-based resources', () => {
let yamlObject = load(yaml)
const name = yamlObject.metadata.name
const ns = yamlObject.metadata.namespace
describe('Create our job using the YAML definition', () => {
kubernetes.apply(yaml)
let created = kubernetes.get("Job.batch", name, ns)
expect(created.metadata, 'new job').to.have.property('uid')
})
})
}