Skip to content

Commit 458fbd9

Browse files
Merge pull request #205 from lpiwowar/bugfix/limit-resources
Limit resources
2 parents 57775dc + fe5dfdf commit 458fbd9

File tree

5 files changed

+20
-0
lines changed

5 files changed

+20
-0
lines changed

pkg/ansibletest/job.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,9 @@ func Job(
6262
Env: env.MergeEnvs([]corev1.EnvVar{}, envVars),
6363
VolumeMounts: GetVolumeMounts(mountCerts, instance, externalWorkflowCounter),
6464
SecurityContext: &securityContext,
65+
Resources: corev1.ResourceRequirements{
66+
Limits: util.GetResourceLimits(),
67+
},
6568
},
6669
},
6770
Volumes: GetVolumes(

pkg/horizontest/job.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,9 @@ func Job(
6161
Env: env.MergeEnvs([]corev1.EnvVar{}, envVars),
6262
VolumeMounts: GetVolumeMounts(mountCerts, mountKeys, mountKubeconfig),
6363
SecurityContext: &securityContext,
64+
Resources: corev1.ResourceRequirements{
65+
Limits: util.GetResourceLimits(),
66+
},
6467
},
6568
},
6669
Volumes: GetVolumes(

pkg/tempest/job.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,9 @@ func Job(
7979
},
8080
},
8181
},
82+
Resources: corev1.ResourceRequirements{
83+
Limits: util.GetResourceLimits(),
84+
},
8285
},
8386
},
8487
Volumes: GetVolumes(

pkg/tobiko/job.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,9 @@ func Job(
6868
Env: env.MergeEnvs([]corev1.EnvVar{}, envVars),
6969
VolumeMounts: GetVolumeMounts(mountCerts, mountKeys, mountKubeconfig),
7070
SecurityContext: &securityContext,
71+
Resources: corev1.ResourceRequirements{
72+
Limits: util.GetResourceLimits(),
73+
},
7174
},
7275
},
7376
Volumes: GetVolumes(

pkg/util/common.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package util
22

33
import (
44
corev1 "k8s.io/api/core/v1"
5+
"k8s.io/apimachinery/pkg/api/resource"
56
)
67

78
func GetSecurityContext(
@@ -37,3 +38,10 @@ func GetSecurityContext(
3738

3839
return securityContext
3940
}
41+
42+
func GetResourceLimits() corev1.ResourceList {
43+
return corev1.ResourceList{
44+
corev1.ResourceCPU: resource.MustParse("2000m"),
45+
corev1.ResourceMemory: resource.MustParse("4Gi"),
46+
}
47+
}

0 commit comments

Comments
 (0)