Skip to content

Commit

Permalink
remove unneeded if statements
Browse files Browse the repository at this point in the history
  • Loading branch information
moh-osman3 committed Aug 31, 2022
1 parent 34f80d2 commit e54ef2a
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 16 deletions.
8 changes: 3 additions & 5 deletions apis/v1alpha1/opentelemetrycollector_webhook.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,11 +63,9 @@ func (r *OpenTelemetryCollector) Default() {
r.Spec.Replicas = &one
}

// if autoscaling is enabled then set default targetCPUUtilization
if r.Spec.MaxReplicas != nil && r.Spec.TargetCPUUtilization == nil {
defaultCPUTarget := int32(90)
r.Spec.TargetCPUUtilization = &defaultCPUTarget
}
// Set default targetCPUUtilization for autoscaler
defaultCPUTarget := int32(90)
r.Spec.TargetCPUUtilization = &defaultCPUTarget
}

// +kubebuilder:webhook:verbs=create;update,path=/validate-opentelemetry-io-v1alpha1-opentelemetrycollector,mutating=false,failurePolicy=fail,groups=opentelemetry.io,resources=opentelemetrycollectors,versions=v1alpha1,name=vopentelemetrycollectorcreateupdate.kb.io,sideEffects=none,admissionReviewVersions=v1
Expand Down
13 changes: 2 additions & 11 deletions pkg/collector/reconcile/horizontalpodautoscaler.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,6 @@ func expectedHorizontalPodAutoscalers(ctx context.Context, params Params, expect

func setAutoscalerSpec(params Params, autoscalingVersion autodetect.AutoscalingVersion, updated client.Object) {
one := int32(1)
ninety := int32(90)
if params.Instance.Spec.MaxReplicas != nil {
if autoscalingVersion == autodetect.AutoscalingVersionV2Beta2 {
updated.(*autoscalingv2beta2.HorizontalPodAutoscaler).Spec.MaxReplicas = *params.Instance.Spec.MaxReplicas
Expand All @@ -120,23 +119,15 @@ func setAutoscalerSpec(params Params, autoscalingVersion autodetect.AutoscalingV
} else {
updated.(*autoscalingv2beta2.HorizontalPodAutoscaler).Spec.MinReplicas = &one
}
if params.Instance.Spec.TargetCPUUtilization != nil {
updated.(*autoscalingv2beta2.HorizontalPodAutoscaler).Spec.Metrics[0].Resource.Target.AverageUtilization = params.Instance.Spec.TargetCPUUtilization
} else {
updated.(*autoscalingv2beta2.HorizontalPodAutoscaler).Spec.Metrics[0].Resource.Target.AverageUtilization = &ninety
}
updated.(*autoscalingv2beta2.HorizontalPodAutoscaler).Spec.Metrics[0].Resource.Target.AverageUtilization = params.Instance.Spec.TargetCPUUtilization
} else {
updated.(*autoscalingv2.HorizontalPodAutoscaler).Spec.MaxReplicas = *params.Instance.Spec.MaxReplicas
if params.Instance.Spec.MinReplicas != nil {
updated.(*autoscalingv2.HorizontalPodAutoscaler).Spec.MinReplicas = params.Instance.Spec.MinReplicas
} else {
updated.(*autoscalingv2.HorizontalPodAutoscaler).Spec.MinReplicas = &one
}
if params.Instance.Spec.TargetCPUUtilization != nil {
updated.(*autoscalingv2.HorizontalPodAutoscaler).Spec.Metrics[0].Resource.Target.AverageUtilization = params.Instance.Spec.TargetCPUUtilization
} else {
updated.(*autoscalingv2.HorizontalPodAutoscaler).Spec.Metrics[0].Resource.Target.AverageUtilization = &ninety
}
updated.(*autoscalingv2.HorizontalPodAutoscaler).Spec.Metrics[0].Resource.Target.AverageUtilization = params.Instance.Spec.TargetCPUUtilization
}
}
}
Expand Down

0 comments on commit e54ef2a

Please sign in to comment.