...
1
2
3
4
19
20
21
22 package v1beta1
23
24 import (
25 v1beta1 "k8s.io/api/batch/v1beta1"
26 runtime "k8s.io/apimachinery/pkg/runtime"
27 v1 "k8s.io/kubernetes/pkg/apis/core/v1"
28 )
29
30
31
32
33 func RegisterDefaults(scheme *runtime.Scheme) error {
34 scheme.AddTypeDefaultingFunc(&v1beta1.CronJob{}, func(obj interface{}) { SetObjectDefaults_CronJob(obj.(*v1beta1.CronJob)) })
35 scheme.AddTypeDefaultingFunc(&v1beta1.CronJobList{}, func(obj interface{}) { SetObjectDefaults_CronJobList(obj.(*v1beta1.CronJobList)) })
36 return nil
37 }
38
39 func SetObjectDefaults_CronJob(in *v1beta1.CronJob) {
40 SetDefaults_CronJob(in)
41 v1.SetDefaults_PodSpec(&in.Spec.JobTemplate.Spec.Template.Spec)
42 for i := range in.Spec.JobTemplate.Spec.Template.Spec.Volumes {
43 a := &in.Spec.JobTemplate.Spec.Template.Spec.Volumes[i]
44 v1.SetDefaults_Volume(a)
45 if a.VolumeSource.HostPath != nil {
46 v1.SetDefaults_HostPathVolumeSource(a.VolumeSource.HostPath)
47 }
48 if a.VolumeSource.Secret != nil {
49 v1.SetDefaults_SecretVolumeSource(a.VolumeSource.Secret)
50 }
51 if a.VolumeSource.ISCSI != nil {
52 v1.SetDefaults_ISCSIVolumeSource(a.VolumeSource.ISCSI)
53 }
54 if a.VolumeSource.RBD != nil {
55 v1.SetDefaults_RBDVolumeSource(a.VolumeSource.RBD)
56 }
57 if a.VolumeSource.DownwardAPI != nil {
58 v1.SetDefaults_DownwardAPIVolumeSource(a.VolumeSource.DownwardAPI)
59 for j := range a.VolumeSource.DownwardAPI.Items {
60 b := &a.VolumeSource.DownwardAPI.Items[j]
61 if b.FieldRef != nil {
62 v1.SetDefaults_ObjectFieldSelector(b.FieldRef)
63 }
64 }
65 }
66 if a.VolumeSource.ConfigMap != nil {
67 v1.SetDefaults_ConfigMapVolumeSource(a.VolumeSource.ConfigMap)
68 }
69 if a.VolumeSource.AzureDisk != nil {
70 v1.SetDefaults_AzureDiskVolumeSource(a.VolumeSource.AzureDisk)
71 }
72 if a.VolumeSource.Projected != nil {
73 v1.SetDefaults_ProjectedVolumeSource(a.VolumeSource.Projected)
74 for j := range a.VolumeSource.Projected.Sources {
75 b := &a.VolumeSource.Projected.Sources[j]
76 if b.DownwardAPI != nil {
77 for k := range b.DownwardAPI.Items {
78 c := &b.DownwardAPI.Items[k]
79 if c.FieldRef != nil {
80 v1.SetDefaults_ObjectFieldSelector(c.FieldRef)
81 }
82 }
83 }
84 if b.ServiceAccountToken != nil {
85 v1.SetDefaults_ServiceAccountTokenProjection(b.ServiceAccountToken)
86 }
87 }
88 }
89 if a.VolumeSource.ScaleIO != nil {
90 v1.SetDefaults_ScaleIOVolumeSource(a.VolumeSource.ScaleIO)
91 }
92 if a.VolumeSource.Ephemeral != nil {
93 if a.VolumeSource.Ephemeral.VolumeClaimTemplate != nil {
94 v1.SetDefaults_PersistentVolumeClaimSpec(&a.VolumeSource.Ephemeral.VolumeClaimTemplate.Spec)
95 v1.SetDefaults_ResourceList(&a.VolumeSource.Ephemeral.VolumeClaimTemplate.Spec.Resources.Limits)
96 v1.SetDefaults_ResourceList(&a.VolumeSource.Ephemeral.VolumeClaimTemplate.Spec.Resources.Requests)
97 }
98 }
99 }
100 for i := range in.Spec.JobTemplate.Spec.Template.Spec.InitContainers {
101 a := &in.Spec.JobTemplate.Spec.Template.Spec.InitContainers[i]
102 v1.SetDefaults_Container(a)
103 for j := range a.Ports {
104 b := &a.Ports[j]
105 if b.Protocol == "" {
106 b.Protocol = "TCP"
107 }
108 }
109 for j := range a.Env {
110 b := &a.Env[j]
111 if b.ValueFrom != nil {
112 if b.ValueFrom.FieldRef != nil {
113 v1.SetDefaults_ObjectFieldSelector(b.ValueFrom.FieldRef)
114 }
115 }
116 }
117 v1.SetDefaults_ResourceList(&a.Resources.Limits)
118 v1.SetDefaults_ResourceList(&a.Resources.Requests)
119 if a.LivenessProbe != nil {
120 v1.SetDefaults_Probe(a.LivenessProbe)
121 if a.LivenessProbe.ProbeHandler.HTTPGet != nil {
122 v1.SetDefaults_HTTPGetAction(a.LivenessProbe.ProbeHandler.HTTPGet)
123 }
124 if a.LivenessProbe.ProbeHandler.GRPC != nil {
125 if a.LivenessProbe.ProbeHandler.GRPC.Service == nil {
126 var ptrVar1 string = ""
127 a.LivenessProbe.ProbeHandler.GRPC.Service = &ptrVar1
128 }
129 }
130 }
131 if a.ReadinessProbe != nil {
132 v1.SetDefaults_Probe(a.ReadinessProbe)
133 if a.ReadinessProbe.ProbeHandler.HTTPGet != nil {
134 v1.SetDefaults_HTTPGetAction(a.ReadinessProbe.ProbeHandler.HTTPGet)
135 }
136 if a.ReadinessProbe.ProbeHandler.GRPC != nil {
137 if a.ReadinessProbe.ProbeHandler.GRPC.Service == nil {
138 var ptrVar1 string = ""
139 a.ReadinessProbe.ProbeHandler.GRPC.Service = &ptrVar1
140 }
141 }
142 }
143 if a.StartupProbe != nil {
144 v1.SetDefaults_Probe(a.StartupProbe)
145 if a.StartupProbe.ProbeHandler.HTTPGet != nil {
146 v1.SetDefaults_HTTPGetAction(a.StartupProbe.ProbeHandler.HTTPGet)
147 }
148 if a.StartupProbe.ProbeHandler.GRPC != nil {
149 if a.StartupProbe.ProbeHandler.GRPC.Service == nil {
150 var ptrVar1 string = ""
151 a.StartupProbe.ProbeHandler.GRPC.Service = &ptrVar1
152 }
153 }
154 }
155 if a.Lifecycle != nil {
156 if a.Lifecycle.PostStart != nil {
157 if a.Lifecycle.PostStart.HTTPGet != nil {
158 v1.SetDefaults_HTTPGetAction(a.Lifecycle.PostStart.HTTPGet)
159 }
160 }
161 if a.Lifecycle.PreStop != nil {
162 if a.Lifecycle.PreStop.HTTPGet != nil {
163 v1.SetDefaults_HTTPGetAction(a.Lifecycle.PreStop.HTTPGet)
164 }
165 }
166 }
167 }
168 for i := range in.Spec.JobTemplate.Spec.Template.Spec.Containers {
169 a := &in.Spec.JobTemplate.Spec.Template.Spec.Containers[i]
170 v1.SetDefaults_Container(a)
171 for j := range a.Ports {
172 b := &a.Ports[j]
173 if b.Protocol == "" {
174 b.Protocol = "TCP"
175 }
176 }
177 for j := range a.Env {
178 b := &a.Env[j]
179 if b.ValueFrom != nil {
180 if b.ValueFrom.FieldRef != nil {
181 v1.SetDefaults_ObjectFieldSelector(b.ValueFrom.FieldRef)
182 }
183 }
184 }
185 v1.SetDefaults_ResourceList(&a.Resources.Limits)
186 v1.SetDefaults_ResourceList(&a.Resources.Requests)
187 if a.LivenessProbe != nil {
188 v1.SetDefaults_Probe(a.LivenessProbe)
189 if a.LivenessProbe.ProbeHandler.HTTPGet != nil {
190 v1.SetDefaults_HTTPGetAction(a.LivenessProbe.ProbeHandler.HTTPGet)
191 }
192 if a.LivenessProbe.ProbeHandler.GRPC != nil {
193 if a.LivenessProbe.ProbeHandler.GRPC.Service == nil {
194 var ptrVar1 string = ""
195 a.LivenessProbe.ProbeHandler.GRPC.Service = &ptrVar1
196 }
197 }
198 }
199 if a.ReadinessProbe != nil {
200 v1.SetDefaults_Probe(a.ReadinessProbe)
201 if a.ReadinessProbe.ProbeHandler.HTTPGet != nil {
202 v1.SetDefaults_HTTPGetAction(a.ReadinessProbe.ProbeHandler.HTTPGet)
203 }
204 if a.ReadinessProbe.ProbeHandler.GRPC != nil {
205 if a.ReadinessProbe.ProbeHandler.GRPC.Service == nil {
206 var ptrVar1 string = ""
207 a.ReadinessProbe.ProbeHandler.GRPC.Service = &ptrVar1
208 }
209 }
210 }
211 if a.StartupProbe != nil {
212 v1.SetDefaults_Probe(a.StartupProbe)
213 if a.StartupProbe.ProbeHandler.HTTPGet != nil {
214 v1.SetDefaults_HTTPGetAction(a.StartupProbe.ProbeHandler.HTTPGet)
215 }
216 if a.StartupProbe.ProbeHandler.GRPC != nil {
217 if a.StartupProbe.ProbeHandler.GRPC.Service == nil {
218 var ptrVar1 string = ""
219 a.StartupProbe.ProbeHandler.GRPC.Service = &ptrVar1
220 }
221 }
222 }
223 if a.Lifecycle != nil {
224 if a.Lifecycle.PostStart != nil {
225 if a.Lifecycle.PostStart.HTTPGet != nil {
226 v1.SetDefaults_HTTPGetAction(a.Lifecycle.PostStart.HTTPGet)
227 }
228 }
229 if a.Lifecycle.PreStop != nil {
230 if a.Lifecycle.PreStop.HTTPGet != nil {
231 v1.SetDefaults_HTTPGetAction(a.Lifecycle.PreStop.HTTPGet)
232 }
233 }
234 }
235 }
236 for i := range in.Spec.JobTemplate.Spec.Template.Spec.EphemeralContainers {
237 a := &in.Spec.JobTemplate.Spec.Template.Spec.EphemeralContainers[i]
238 v1.SetDefaults_EphemeralContainer(a)
239 for j := range a.EphemeralContainerCommon.Ports {
240 b := &a.EphemeralContainerCommon.Ports[j]
241 if b.Protocol == "" {
242 b.Protocol = "TCP"
243 }
244 }
245 for j := range a.EphemeralContainerCommon.Env {
246 b := &a.EphemeralContainerCommon.Env[j]
247 if b.ValueFrom != nil {
248 if b.ValueFrom.FieldRef != nil {
249 v1.SetDefaults_ObjectFieldSelector(b.ValueFrom.FieldRef)
250 }
251 }
252 }
253 v1.SetDefaults_ResourceList(&a.EphemeralContainerCommon.Resources.Limits)
254 v1.SetDefaults_ResourceList(&a.EphemeralContainerCommon.Resources.Requests)
255 if a.EphemeralContainerCommon.LivenessProbe != nil {
256 v1.SetDefaults_Probe(a.EphemeralContainerCommon.LivenessProbe)
257 if a.EphemeralContainerCommon.LivenessProbe.ProbeHandler.HTTPGet != nil {
258 v1.SetDefaults_HTTPGetAction(a.EphemeralContainerCommon.LivenessProbe.ProbeHandler.HTTPGet)
259 }
260 if a.EphemeralContainerCommon.LivenessProbe.ProbeHandler.GRPC != nil {
261 if a.EphemeralContainerCommon.LivenessProbe.ProbeHandler.GRPC.Service == nil {
262 var ptrVar1 string = ""
263 a.EphemeralContainerCommon.LivenessProbe.ProbeHandler.GRPC.Service = &ptrVar1
264 }
265 }
266 }
267 if a.EphemeralContainerCommon.ReadinessProbe != nil {
268 v1.SetDefaults_Probe(a.EphemeralContainerCommon.ReadinessProbe)
269 if a.EphemeralContainerCommon.ReadinessProbe.ProbeHandler.HTTPGet != nil {
270 v1.SetDefaults_HTTPGetAction(a.EphemeralContainerCommon.ReadinessProbe.ProbeHandler.HTTPGet)
271 }
272 if a.EphemeralContainerCommon.ReadinessProbe.ProbeHandler.GRPC != nil {
273 if a.EphemeralContainerCommon.ReadinessProbe.ProbeHandler.GRPC.Service == nil {
274 var ptrVar1 string = ""
275 a.EphemeralContainerCommon.ReadinessProbe.ProbeHandler.GRPC.Service = &ptrVar1
276 }
277 }
278 }
279 if a.EphemeralContainerCommon.StartupProbe != nil {
280 v1.SetDefaults_Probe(a.EphemeralContainerCommon.StartupProbe)
281 if a.EphemeralContainerCommon.StartupProbe.ProbeHandler.HTTPGet != nil {
282 v1.SetDefaults_HTTPGetAction(a.EphemeralContainerCommon.StartupProbe.ProbeHandler.HTTPGet)
283 }
284 if a.EphemeralContainerCommon.StartupProbe.ProbeHandler.GRPC != nil {
285 if a.EphemeralContainerCommon.StartupProbe.ProbeHandler.GRPC.Service == nil {
286 var ptrVar1 string = ""
287 a.EphemeralContainerCommon.StartupProbe.ProbeHandler.GRPC.Service = &ptrVar1
288 }
289 }
290 }
291 if a.EphemeralContainerCommon.Lifecycle != nil {
292 if a.EphemeralContainerCommon.Lifecycle.PostStart != nil {
293 if a.EphemeralContainerCommon.Lifecycle.PostStart.HTTPGet != nil {
294 v1.SetDefaults_HTTPGetAction(a.EphemeralContainerCommon.Lifecycle.PostStart.HTTPGet)
295 }
296 }
297 if a.EphemeralContainerCommon.Lifecycle.PreStop != nil {
298 if a.EphemeralContainerCommon.Lifecycle.PreStop.HTTPGet != nil {
299 v1.SetDefaults_HTTPGetAction(a.EphemeralContainerCommon.Lifecycle.PreStop.HTTPGet)
300 }
301 }
302 }
303 }
304 v1.SetDefaults_ResourceList(&in.Spec.JobTemplate.Spec.Template.Spec.Overhead)
305 }
306
307 func SetObjectDefaults_CronJobList(in *v1beta1.CronJobList) {
308 for i := range in.Items {
309 a := &in.Items[i]
310 SetObjectDefaults_CronJob(a)
311 }
312 }
313
View as plain text