-
Notifications
You must be signed in to change notification settings - Fork 473
/
pod.go
189 lines (154 loc) · 5.87 KB
/
pod.go
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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
// SPDX-FileCopyrightText: 2024 SAP SE or an SAP affiliate company and Gardener contributors
//
// SPDX-License-Identifier: Apache-2.0
package kubernetes
import (
"context"
"fmt"
"slices"
appsv1 "k8s.io/api/apps/v1"
appsv1beta1 "k8s.io/api/apps/v1beta1"
appsv1beta2 "k8s.io/api/apps/v1beta2"
batchv1 "k8s.io/api/batch/v1"
batchv1beta1 "k8s.io/api/batch/v1beta1"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/util/sets"
"sigs.k8s.io/controller-runtime/pkg/client"
)
// VisitPodSpec calls the given visitor for the PodSpec contained in the given object. The visitor may mutate the
// PodSpec.
func VisitPodSpec(obj runtime.Object, visit func(*corev1.PodSpec)) error {
switch o := obj.(type) {
case *corev1.Pod:
visit(&o.Spec)
case *appsv1.Deployment:
visit(&o.Spec.Template.Spec)
case *appsv1beta2.Deployment:
visit(&o.Spec.Template.Spec)
case *appsv1beta1.Deployment:
visit(&o.Spec.Template.Spec)
case *appsv1.StatefulSet:
visit(&o.Spec.Template.Spec)
case *appsv1beta2.StatefulSet:
visit(&o.Spec.Template.Spec)
case *appsv1beta1.StatefulSet:
visit(&o.Spec.Template.Spec)
case *appsv1.DaemonSet:
visit(&o.Spec.Template.Spec)
case *appsv1beta2.DaemonSet:
visit(&o.Spec.Template.Spec)
case *batchv1.Job:
visit(&o.Spec.Template.Spec)
case *batchv1.CronJob:
visit(&o.Spec.JobTemplate.Spec.Template.Spec)
case *batchv1beta1.CronJob:
visit(&o.Spec.JobTemplate.Spec.Template.Spec)
default:
return fmt.Errorf("unhandled object type %T", obj)
}
return nil
}
// VisitContainers calls the given visitor for all (init) containers in the given PodSpec. If containerNames are given
// it only visits (init) containers with matching names. The visitor may mutate the Container.
func VisitContainers(podSpec *corev1.PodSpec, visit func(*corev1.Container), containerNames ...string) {
for i, c := range podSpec.InitContainers {
container := c
if len(containerNames) == 0 || slices.Contains(containerNames, container.Name) {
visit(&container)
podSpec.InitContainers[i] = container
}
}
for i, c := range podSpec.Containers {
container := c
if len(containerNames) == 0 || slices.Contains(containerNames, container.Name) {
visit(&container)
podSpec.Containers[i] = container
}
}
}
// AddVolume adds the given Volume to the given PodSpec if not present. If a Volume with the given name is already
// present it optionally overwrites the Volume according to the overwrite parameter.
func AddVolume(podSpec *corev1.PodSpec, volume corev1.Volume, overwrite bool) {
for i, v := range podSpec.Volumes {
if v.Name == volume.Name {
// volume with given name is already present
if overwrite {
podSpec.Volumes[i] = volume
}
return
}
}
// volume with given name is not present, add it
podSpec.Volumes = append(podSpec.Volumes, volume)
}
// AddVolumeMount adds the given VolumeMount to the given Container if not present. If a VolumeMount with the given name
// is already present it optionally overwrites the VolumeMount according to the overwrite parameter.
func AddVolumeMount(container *corev1.Container, volumeMount corev1.VolumeMount, overwrite bool) {
for i, v := range container.VolumeMounts {
if v.Name == volumeMount.Name {
// volumeMount with given name is already present
if overwrite {
container.VolumeMounts[i] = volumeMount
}
return
}
}
// volumeMount with given name is not present, add it
container.VolumeMounts = append(container.VolumeMounts, volumeMount)
}
// AddEnvVar adds the given EnvVar to the given Container if not present. If a EnvVar with the given name
// is already present it optionally overwrites the EnvVar according to the overwrite parameter.
func AddEnvVar(container *corev1.Container, envVar corev1.EnvVar, overwrite bool) {
for i, e := range container.Env {
if e.Name == envVar.Name {
// envVar with given name is already present
if overwrite {
container.Env[i] = envVar
}
return
}
}
// envVar with given name is not present, add it
container.Env = append(container.Env, envVar)
}
// HasEnvVar checks if the given container has an EnvVar with the given name.
func HasEnvVar(container corev1.Container, name string) bool {
envVars := sets.New[string]()
for _, e := range container.Env {
envVars.Insert(e.Name)
}
return envVars.Has(name)
}
// GetDeploymentForPod returns the deployment the pod belongs to by traversing its metadata.
func GetDeploymentForPod(ctx context.Context, reader client.Reader, namespace string, podOwnerReferences []metav1.OwnerReference) (*appsv1.Deployment, error) {
var replicaSetName string
for _, ownerReference := range podOwnerReferences {
if ownerReference.APIVersion == appsv1.SchemeGroupVersion.String() && ownerReference.Kind == "ReplicaSet" {
replicaSetName = ownerReference.Name
}
}
if replicaSetName == "" {
return nil, nil
}
replicaSet := &metav1.PartialObjectMetadata{ObjectMeta: metav1.ObjectMeta{Name: replicaSetName, Namespace: namespace}}
replicaSet.SetGroupVersionKind(appsv1.SchemeGroupVersion.WithKind("ReplicaSet"))
if err := reader.Get(ctx, client.ObjectKeyFromObject(replicaSet), replicaSet); err != nil {
return nil, fmt.Errorf("failed reading ReplicaSet %s: %w", client.ObjectKeyFromObject(replicaSet), err)
}
var deploymentName string
for _, ownerReference := range replicaSet.OwnerReferences {
if ownerReference.APIVersion == appsv1.SchemeGroupVersion.String() && ownerReference.Kind == "Deployment" {
deploymentName = ownerReference.Name
}
}
if deploymentName == "" {
return nil, nil
}
deployment := &appsv1.Deployment{ObjectMeta: metav1.ObjectMeta{Name: deploymentName, Namespace: replicaSet.Namespace}}
if err := reader.Get(ctx, client.ObjectKeyFromObject(deployment), deployment); err != nil {
return nil, fmt.Errorf("failed reading Deployment %s: %w", client.ObjectKeyFromObject(deployment), err)
}
return deployment, nil
}