mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-03-31 03:45:17 +00:00
Code Activity

fix delete logic

Browse source
This commit is contained in:
evalsocket 2020-07-10 17:21:30 -07:00
parent 04ecfd3998
commit 98fa10ea59
1 changed files with 11 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
pkg/generate/generate.go
View file

@ -47,18 +47,22 @@ func (c *Controller) applyGenerate(resource unstructured.Unstructured, gr kyvern
policy, err := c.pLister.Get(gr.Spec.Policy)
if err != nil {
if apierrors.IsNotFound(err) {
for _, e := range policy.Spec.Rules {
if e.Generation.Synchronize {
if err := c.client.DeleteResource(e.Generation.Kind, e.Generation.Namespace, e.Generation.Name, false); err != nil {
logger.V(4).Info("Generated resource is deleted")
return nil, err
}
resource, err := c.client.GetResource(gr.Spec.Resource.Kind, gr.Spec.Resource.Namespace, gr.Spec.Resource.Name)
if err != nil {
logger.V(4).Info("Generated resource is deleted")
return nil, err
}
labels := resource.GetLabels()
if labels["app.kubernetes.io/synchronize"] == "enable" {
if err := c.client.DeleteResource(gr.Spec.Resource.Kind, gr.Spec.Resource.Namespace, gr.Spec.Resource.Name, false); err != nil {
logger.V(4).Info("Generated resource is deleted")
return nil, err
}
}
return nil, nil
}
logger.Error(err, "error in getting policy")
return nil, err
}
resourceRaw, err := resource.MarshalJSON()