Skip to content

Commit 21e8c9e

Browse files
ju187AlexsJones
andauthored
configure resources with values from spec (#634)
* configure resources with values from spec Signed-off-by: Tony Chen <[email protected]> * add more checking Signed-off-by: Tony Chen <[email protected]> --------- Signed-off-by: Tony Chen <[email protected]> Co-authored-by: Alex Jones <[email protected]>
1 parent 94dcdcb commit 21e8c9e

File tree

1 file changed

+40
-10
lines changed

1 file changed

+40
-10
lines changed

pkg/resources/k8sgpt.go

+40-10
Original file line numberDiff line numberDiff line change
@@ -313,18 +313,48 @@ func GetDeployment(config v1alpha1.K8sGPT, outOfClusterMode bool, c client.Clien
313313
},
314314
Resources: corev1.ResourceRequirements{
315315
Limits: corev1.ResourceList{
316-
corev1.ResourceCPU: resource.MustParse("1"),
317-
corev1.ResourceMemory: resource.MustParse("512Mi"),
316+
corev1.ResourceCPU: func() resource.Quantity {
317+
if config.Spec.Resources != nil {
318+
if config.Spec.Resources.Limits != nil {
319+
if cpuLimit, exists := config.Spec.Resources.Limits["cpu"]; exists {
320+
return cpuLimit
321+
}
322+
}
323+
}
324+
return resource.MustParse("1")
325+
}(),
326+
corev1.ResourceMemory: func() resource.Quantity {
327+
if config.Spec.Resources != nil {
328+
if config.Spec.Resources.Limits != nil {
329+
if memLimit, exists := config.Spec.Resources.Limits["memory"]; exists {
330+
return memLimit
331+
}
332+
}
333+
}
334+
return resource.MustParse("512Mi")
335+
}(),
318336
},
319337
Requests: corev1.ResourceList{
320-
corev1.ResourceCPU: resource.MustParse("0.2"),
321-
corev1.ResourceMemory: resource.MustParse("156Mi"),
322-
},
323-
},
324-
VolumeMounts: []corev1.VolumeMount{
325-
{
326-
MountPath: "/k8sgpt-data",
327-
Name: "k8sgpt-vol",
338+
corev1.ResourceCPU: func() resource.Quantity {
339+
if config.Spec.Resources != nil {
340+
if config.Spec.Resources.Requests != nil {
341+
if cpuRequest, exists := config.Spec.Resources.Requests["cpu"]; exists {
342+
return cpuRequest
343+
}
344+
}
345+
}
346+
return resource.MustParse("0.2")
347+
}(),
348+
corev1.ResourceMemory: func() resource.Quantity {
349+
if config.Spec.Resources != nil {
350+
if config.Spec.Resources.Requests != nil {
351+
if memRequest, exists := config.Spec.Resources.Requests["memory"]; exists {
352+
return memRequest
353+
}
354+
}
355+
}
356+
return resource.MustParse("256Mi")
357+
}(),
328358
},
329359
},
330360
},

0 commit comments

Comments
 (0)