mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-29 06:27:05 +00:00
Merge pull request #109139 from krmayankk/fixnits
fix some nits from API changes
This commit is contained in:
commit
de68e86a95
@ -22,6 +22,7 @@ import (
|
|||||||
"k8s.io/apimachinery/pkg/util/intstr"
|
"k8s.io/apimachinery/pkg/util/intstr"
|
||||||
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
||||||
"k8s.io/kubernetes/pkg/features"
|
"k8s.io/kubernetes/pkg/features"
|
||||||
|
"k8s.io/utils/pointer"
|
||||||
)
|
)
|
||||||
|
|
||||||
func addDefaultingFuncs(scheme *runtime.Scheme) error {
|
func addDefaultingFuncs(scheme *runtime.Scheme) error {
|
||||||
@ -116,8 +117,7 @@ func SetDefaults_StatefulSet(obj *appsv1.StatefulSet) {
|
|||||||
obj.Spec.UpdateStrategy.RollingUpdate != nil {
|
obj.Spec.UpdateStrategy.RollingUpdate != nil {
|
||||||
|
|
||||||
if obj.Spec.UpdateStrategy.RollingUpdate.Partition == nil {
|
if obj.Spec.UpdateStrategy.RollingUpdate.Partition == nil {
|
||||||
obj.Spec.UpdateStrategy.RollingUpdate.Partition = new(int32)
|
obj.Spec.UpdateStrategy.RollingUpdate.Partition = pointer.Int32(0)
|
||||||
*obj.Spec.UpdateStrategy.RollingUpdate.Partition = 0
|
|
||||||
}
|
}
|
||||||
if utilfeature.DefaultFeatureGate.Enabled(features.MaxUnavailableStatefulSet) {
|
if utilfeature.DefaultFeatureGate.Enabled(features.MaxUnavailableStatefulSet) {
|
||||||
if obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable == nil {
|
if obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable == nil {
|
||||||
|
@ -23,6 +23,7 @@ import (
|
|||||||
"k8s.io/apimachinery/pkg/util/intstr"
|
"k8s.io/apimachinery/pkg/util/intstr"
|
||||||
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
||||||
"k8s.io/kubernetes/pkg/features"
|
"k8s.io/kubernetes/pkg/features"
|
||||||
|
"k8s.io/utils/pointer"
|
||||||
)
|
)
|
||||||
|
|
||||||
func addDefaultingFuncs(scheme *runtime.Scheme) error {
|
func addDefaultingFuncs(scheme *runtime.Scheme) error {
|
||||||
@ -73,8 +74,7 @@ func SetDefaults_StatefulSet(obj *appsv1beta1.StatefulSet) {
|
|||||||
obj.Spec.UpdateStrategy.RollingUpdate != nil {
|
obj.Spec.UpdateStrategy.RollingUpdate != nil {
|
||||||
|
|
||||||
if obj.Spec.UpdateStrategy.RollingUpdate.Partition == nil {
|
if obj.Spec.UpdateStrategy.RollingUpdate.Partition == nil {
|
||||||
obj.Spec.UpdateStrategy.RollingUpdate.Partition = new(int32)
|
obj.Spec.UpdateStrategy.RollingUpdate.Partition = pointer.Int32(0)
|
||||||
*obj.Spec.UpdateStrategy.RollingUpdate.Partition = 0
|
|
||||||
}
|
}
|
||||||
if utilfeature.DefaultFeatureGate.Enabled(features.MaxUnavailableStatefulSet) {
|
if utilfeature.DefaultFeatureGate.Enabled(features.MaxUnavailableStatefulSet) {
|
||||||
if obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable == nil {
|
if obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable == nil {
|
||||||
|
@ -22,6 +22,7 @@ import (
|
|||||||
"k8s.io/apimachinery/pkg/util/intstr"
|
"k8s.io/apimachinery/pkg/util/intstr"
|
||||||
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
||||||
"k8s.io/kubernetes/pkg/features"
|
"k8s.io/kubernetes/pkg/features"
|
||||||
|
"k8s.io/utils/pointer"
|
||||||
)
|
)
|
||||||
|
|
||||||
func addDefaultingFuncs(scheme *runtime.Scheme) error {
|
func addDefaultingFuncs(scheme *runtime.Scheme) error {
|
||||||
@ -73,8 +74,7 @@ func SetDefaults_StatefulSet(obj *appsv1beta2.StatefulSet) {
|
|||||||
obj.Spec.UpdateStrategy.RollingUpdate != nil {
|
obj.Spec.UpdateStrategy.RollingUpdate != nil {
|
||||||
|
|
||||||
if obj.Spec.UpdateStrategy.RollingUpdate.Partition == nil {
|
if obj.Spec.UpdateStrategy.RollingUpdate.Partition == nil {
|
||||||
obj.Spec.UpdateStrategy.RollingUpdate.Partition = new(int32)
|
obj.Spec.UpdateStrategy.RollingUpdate.Partition = pointer.Int32(0)
|
||||||
*obj.Spec.UpdateStrategy.RollingUpdate.Partition = 0
|
|
||||||
}
|
}
|
||||||
if utilfeature.DefaultFeatureGate.Enabled(features.MaxUnavailableStatefulSet) {
|
if utilfeature.DefaultFeatureGate.Enabled(features.MaxUnavailableStatefulSet) {
|
||||||
if obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable == nil {
|
if obj.Spec.UpdateStrategy.RollingUpdate.MaxUnavailable == nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user