mirror of
https://github.com/fluxcd/flux2.git
synced 2026-02-25 00:51:48 +00:00
Merge pull request #3087 from somtochiama/notify-finalize
Remove finalizers for notification controllers
This commit is contained in:
commit
c921cf0d54
1 changed files with 40 additions and 0 deletions
|
|
@ -36,6 +36,7 @@ import (
|
||||||
autov1 "github.com/fluxcd/image-automation-controller/api/v1beta1"
|
autov1 "github.com/fluxcd/image-automation-controller/api/v1beta1"
|
||||||
imagev1 "github.com/fluxcd/image-reflector-controller/api/v1beta1"
|
imagev1 "github.com/fluxcd/image-reflector-controller/api/v1beta1"
|
||||||
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1beta2"
|
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1beta2"
|
||||||
|
notificationv1 "github.com/fluxcd/notification-controller/api/v1beta1"
|
||||||
sourcev1 "github.com/fluxcd/source-controller/api/v1beta2"
|
sourcev1 "github.com/fluxcd/source-controller/api/v1beta2"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
@ -276,6 +277,45 @@ func uninstallFinalizers(ctx context.Context, kubeClient client.Client, dryRun b
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
{
|
||||||
|
var list notificationv1.AlertList
|
||||||
|
if err := kubeClient.List(ctx, &list, client.InNamespace("")); err == nil {
|
||||||
|
for _, r := range list.Items {
|
||||||
|
r.Finalizers = []string{}
|
||||||
|
if err := kubeClient.Update(ctx, &r, opts); err != nil {
|
||||||
|
logger.Failuref("%s/%s/%s removing finalizers failed: %s", r.Kind, r.Namespace, r.Name, err.Error())
|
||||||
|
} else {
|
||||||
|
logger.Successf("%s/%s/%s finalizers deleted %s", r.Kind, r.Namespace, r.Name, dryRunStr)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
{
|
||||||
|
var list notificationv1.ProviderList
|
||||||
|
if err := kubeClient.List(ctx, &list, client.InNamespace("")); err == nil {
|
||||||
|
for _, r := range list.Items {
|
||||||
|
r.Finalizers = []string{}
|
||||||
|
if err := kubeClient.Update(ctx, &r, opts); err != nil {
|
||||||
|
logger.Failuref("%s/%s/%s removing finalizers failed: %s", r.Kind, r.Namespace, r.Name, err.Error())
|
||||||
|
} else {
|
||||||
|
logger.Successf("%s/%s/%s finalizers deleted %s", r.Kind, r.Namespace, r.Name, dryRunStr)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
{
|
||||||
|
var list notificationv1.ReceiverList
|
||||||
|
if err := kubeClient.List(ctx, &list, client.InNamespace("")); err == nil {
|
||||||
|
for _, r := range list.Items {
|
||||||
|
r.Finalizers = []string{}
|
||||||
|
if err := kubeClient.Update(ctx, &r, opts); err != nil {
|
||||||
|
logger.Failuref("%s/%s/%s removing finalizers failed: %s", r.Kind, r.Namespace, r.Name, err.Error())
|
||||||
|
} else {
|
||||||
|
logger.Successf("%s/%s/%s finalizers deleted %s", r.Kind, r.Namespace, r.Name, dryRunStr)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
{
|
{
|
||||||
var list imagev1.ImagePolicyList
|
var list imagev1.ImagePolicyList
|
||||||
if err := kubeClient.List(ctx, &list, client.InNamespace("")); err == nil {
|
if err := kubeClient.List(ctx, &list, client.InNamespace("")); err == nil {
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue