|
|
|
@ -33,6 +33,8 @@ import (
|
|
|
|
|
"github.com/fluxcd/flux2/internal/utils"
|
|
|
|
|
"github.com/fluxcd/flux2/pkg/manifestgen"
|
|
|
|
|
helmv2 "github.com/fluxcd/helm-controller/api/v2beta1"
|
|
|
|
|
autov1 "github.com/fluxcd/image-automation-controller/api/v1beta1"
|
|
|
|
|
imagev1 "github.com/fluxcd/image-reflector-controller/api/v1beta1"
|
|
|
|
|
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1beta2"
|
|
|
|
|
sourcev1 "github.com/fluxcd/source-controller/api/v1beta2"
|
|
|
|
|
)
|
|
|
|
@ -261,6 +263,45 @@ func uninstallFinalizers(ctx context.Context, kubeClient client.Client, dryRun b
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
{
|
|
|
|
|
var list imagev1.ImagePolicyList
|
|
|
|
|
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.ImageRepositoryList
|
|
|
|
|
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 autov1.ImageUpdateAutomationList
|
|
|
|
|
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)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func uninstallCustomResourceDefinitions(ctx context.Context, kubeClient client.Client, dryRun bool) {
|
|
|
|
|