openkruise
/
rollouts
mirror of https://github.com/openkruise/rollouts.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix workload webhook filtering: patch label bug and add Kruise StatefulSet support (#299) 

* Fix workload type label patching bug and add Kruise StatefulSet support

Signed-off-by: Parship Chowdhury <i.am.parship@gmail.com>

* added objectSelector to filter workloads by rollout label

Signed-off-by: Parship Chowdhury <i.am.parship@gmail.com>

* reverted the changes in manifest

Signed-off-by: Parship Chowdhury <i.am.parship@gmail.com>

---------

Signed-off-by: Parship Chowdhury <i.am.parship@gmail.com>
This commit is contained in:
Parship Chowdhury 2025-07-28 08:17:58 +05:30 committed by GitHub
parent b2806f5dec
commit 87f7e652ab
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/controller/rollout/rollout_status.go
View File

@ -298,10 +298,12 @@ func (r *RolloutReconciler) patchWorkloadRolloutWebhookLabel(rollout *v1beta1.Ro
workloadType = util.DeploymentType workloadType = util.DeploymentType
case util.ControllerKindSts.Kind: case util.ControllerKindSts.Kind:
workloadType = util.StatefulSetType workloadType = util.StatefulSetType
case util.ControllerKruiseKindSts.Kind, util.ControllerKruiseOldKindSts.Kind:
workloadType = util.StatefulSetType
case util.ControllerKruiseKindDS.Kind: case util.ControllerKruiseKindDS.Kind:
workloadType = util.DaemonSetType workloadType = util.DaemonSetType
} }
if workload.Annotations[util.WorkloadTypeLabel] == "" && workloadType != "" { if workload.Labels[util.WorkloadTypeLabel] == "" && workloadType != "" {
workloadGVK := schema.FromAPIVersionAndKind(workload.APIVersion, workload.Kind) workloadGVK := schema.FromAPIVersionAndKind(workload.APIVersion, workload.Kind)
obj := util.GetEmptyWorkloadObject(workloadGVK) obj := util.GetEmptyWorkloadObject(workloadGVK)
obj.SetNamespace(workload.Namespace) obj.SetNamespace(workload.Namespace)