-
Notifications
You must be signed in to change notification settings - Fork 103
/
utils_kubelet.go
101 lines (83 loc) · 2.72 KB
/
utils_kubelet.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
// Unless explicitly stated otherwise all files in this repository are licensed
// under the Apache License Version 2.0.
// This product includes software developed at Datadog (https://www.datadoghq.com/).
// Copyright 2016-present Datadog, Inc.
package datadogagent
import (
datadoghqv1alpha1 "github.com/DataDog/datadog-operator/api/v1alpha1"
corev1 "k8s.io/api/core/v1"
)
func getKubeletEnvVars(dda *datadoghqv1alpha1.DatadogAgent) []corev1.EnvVar {
kubeletVars := make([]corev1.EnvVar, 0)
// Host valueFrom
var kubeletHostValueFrom *corev1.EnvVarSource
if dda.Spec.Agent.Config.Kubelet != nil && dda.Spec.Agent.Config.Kubelet.Host != nil {
kubeletHostValueFrom = dda.Spec.Agent.Config.Kubelet.Host
} else {
kubeletHostValueFrom = &corev1.EnvVarSource{
FieldRef: &corev1.ObjectFieldSelector{
FieldPath: FieldPathStatusHostIP,
},
}
}
kubeletVars = append(kubeletVars, corev1.EnvVar{
Name: datadoghqv1alpha1.DDKubeletHost,
ValueFrom: kubeletHostValueFrom,
})
// TLS Verify
if dda.Spec.Agent.Config.Kubelet != nil && dda.Spec.Agent.Config.Kubelet.TLSVerify != nil {
kubeletVars = append(kubeletVars, corev1.EnvVar{
Name: datadoghqv1alpha1.DDKubeletTLSVerify,
Value: datadoghqv1alpha1.BoolToString(dda.Spec.Agent.Config.Kubelet.TLSVerify),
})
}
// CA Path
if dda.Spec.Agent.Config.Kubelet != nil && (dda.Spec.Agent.Config.Kubelet.AgentCAPath != "" || dda.Spec.Agent.Config.Kubelet.HostCAPath != "") {
kubeletVars = append(kubeletVars, corev1.EnvVar{
Name: datadoghqv1alpha1.DDKubeletCAPath,
Value: getAgentCAPath(dda),
})
}
return kubeletVars
}
func getKubeletVolumes(dda *datadoghqv1alpha1.DatadogAgent) []corev1.Volume {
if dda.Spec.Agent.Config.Kubelet == nil {
return nil
}
if dda.Spec.Agent.Config.Kubelet.HostCAPath != "" {
fileVolumeType := corev1.HostPathFile
return []corev1.Volume{
{
Name: datadoghqv1alpha1.KubeletCAVolumeName,
VolumeSource: corev1.VolumeSource{
HostPath: &corev1.HostPathVolumeSource{
Path: dda.Spec.Agent.Config.Kubelet.HostCAPath,
Type: &fileVolumeType,
},
},
},
}
}
return nil
}
func getKubeletVolumeMounts(dda *datadoghqv1alpha1.DatadogAgent) []corev1.VolumeMount {
if dda.Spec.Agent.Config.Kubelet == nil {
return nil
}
if dda.Spec.Agent.Config.Kubelet.HostCAPath != "" {
return []corev1.VolumeMount{
{
Name: datadoghqv1alpha1.KubeletCAVolumeName,
MountPath: getAgentCAPath(dda),
ReadOnly: true,
},
}
}
return nil
}
func getAgentCAPath(dda *datadoghqv1alpha1.DatadogAgent) string {
if dda.Spec.Agent.Config.Kubelet != nil && dda.Spec.Agent.Config.Kubelet.AgentCAPath != "" {
return dda.Spec.Agent.Config.Kubelet.AgentCAPath
}
return datadoghqv1alpha1.DefaultKubeletAgentCAPath
}