Method deleteObjects

internal/olm/operator/uninstall.go:207–237

(ctx context.Context, waitForDelete bool, objs ...client.Object)

}

func (u *Uninstall) deleteObjects(ctx context.Context, waitForDelete bool, objs ...client.Object) error {
	for _, obj := range objs {
		if obj == nil {
			continue
		}
		gvks, _, err := u.config.Scheme.ObjectKinds(obj)
		if err != nil {
			return err
		}
		lowerKind := strings.ToLower(gvks[0].Kind)
		if err := u.config.Client.Delete(ctx, obj); err != nil && !apierrors.IsNotFound(err) {
			return fmt.Errorf("delete %s %q: %v", lowerKind, obj.GetName(), err)
		} else if err == nil {
			u.Logf("%s %q deleted", lowerKind, obj.GetName())
		}
		if waitForDelete {
			key := client.ObjectKeyFromObject(obj)
			if err := wait.PollUntilContextCancel(ctx, 250*time.Millisecond, false, func(pctx context.Context) (bool, error) {
				if err := u.config.Client.Get(pctx, key, obj); apierrors.IsNotFound(err) {
					return true, nil
				} else if err != nil {
					return false, err
				}
				return false, nil
			}); err != nil {
				return fmt.Errorf("wait for %s deleted: %v", lowerKind, err)
			}
		}
	}
	return nil
}

// getCRDs returns the list of CRDs required by a CSV.
func getCRDs(csv *v1alpha1.ClusterServiceVersion) (crds []client.Object) {