Skip to content

Commit 3e86101

Browse files
upgrade deamonset from v1alpha1 to v1beta1 (#2211)
* upgrade deamonset from v1alpha1 to v1beta1 Signed-off-by: PersistentJZH <zhihao.kan17@gmail.com> update webhook logic add omitempty to DaemonSetHash add currentRevision cal logic update CurrentRevision cal logic optimize fix e2e test * change Partition to IntOrString Signed-off-by: PersistentJZH <zhihao.kan17@gmail.com> remove debug log * remove CurrentRevision status Signed-off-by: PersistentJZH <zhihao.kan17@gmail.com> * do not remove ProgressiveCreatePod Annotation in convert to v1beta1 Signed-off-by: PersistentJZH <zhihao.kan17@gmail.com> * change DaemonSetScaleStrategy cfg from Progressive to PartitionedScaling Signed-off-by: PersistentJZH <zhihao.kan17@gmail.com> * add more ut in daemonset validate webhook Signed-off-by: PersistentJZH <zhihao.kan17@gmail.com> --------- Signed-off-by: PersistentJZH <zhihao.kan17@gmail.com>
1 parent 0ca7821 commit 3e86101

41 files changed

Lines changed: 5395 additions & 293 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

apis/apps/defaults/v1beta1.go

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -224,3 +224,36 @@ func SetDefaultsImageTagPullPolicyV1beta1(obj *v1beta1.ImageTagPullPolicy) {
224224
obj.BackoffLimit = ptr.To(int32(3))
225225
}
226226
}
227+
228+
// SetDefaultsDaemonSetV1beta1 sets default values for v1beta1 DaemonSet.
229+
func SetDefaultsDaemonSetV1beta1(obj *v1beta1.DaemonSet) {
230+
if obj.Spec.BurstReplicas == nil {
231+
BurstReplicas := intstr.FromInt(250)
232+
obj.Spec.BurstReplicas = &BurstReplicas
233+
}
234+
235+
if obj.Spec.UpdateStrategy.Type == "" {
236+
obj.Spec.UpdateStrategy.Type = v1beta1.RollingUpdateDaemonSetStrategyType
237+
}
238+
if obj.Spec.UpdateStrategy.Type == v1beta1.RollingUpdateDaemonSetStrategyType {
239+
if obj.Spec.UpdateStrategy.RollingUpdate == nil {
240+
obj.Spec.UpdateStrategy.RollingUpdate = &v1beta1.RollingUpdateDaemonSet{}
241+
}
242+
243+
// Default to Standard
244+
if obj.Spec.UpdateStrategy.RollingUpdate.Type == "" {
245+
obj.Spec.UpdateStrategy.RollingUpdate.Type = v1beta1.StandardRollingUpdateType
246+
}
247+
248+
if obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable == nil && obj.Spec.UpdateStrategy.RollingUpdate.MaxSurge == nil {
249+
maxUnavailable := intstr.FromInt(1)
250+
obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable = &maxUnavailable
251+
MaxSurge := intstr.FromInt(0)
252+
obj.Spec.UpdateStrategy.RollingUpdate.MaxSurge = &MaxSurge
253+
}
254+
}
255+
256+
if obj.Spec.RevisionHistoryLimit == nil {
257+
obj.Spec.RevisionHistoryLimit = ptr.To(int32(10))
258+
}
259+
}

0 commit comments

Comments
 (0)