func()

in pkg/controllers/member/internalmembercluster/v1alpha1/controller.go [214:247]

• 32 lines of code
• 8 McCabe index (conditional complexity)

func (r *Reconciler) cleanupServiceExportRelatedResources(ctx context.Context) error {
	list := &fleetnetv1alpha1.ServiceExportList{}
	if err := r.MemberClient.List(ctx, list); err != nil {
		klog.ErrorS(err, "Failed to list serviceExport")
		return err
	}
	for i := range list.Items {
		if list.Items[i].ObjectMeta.DeletionTimestamp != nil {
			continue
		}
		deleteFunc := func() error {
			return r.MemberClient.Delete(ctx, &list.Items[i])
		}
		if err := apiretry.Do(deleteFunc); err != nil && !apierrors.IsNotFound(err) {
			klog.ErrorS(err, "Failed to delete serviceExport", "serviceExport", klog.KObj(&list.Items[i]))
			return err
		}
	}

	for i := range list.Items {
		name := types.NamespacedName{Namespace: list.Items[i].GetNamespace(), Name: list.Items[i].GetName()}
		svcExport := fleetnetv1alpha1.ServiceExport{}
		getFunc := func() error {
			return r.MemberClient.Get(ctx, name, &svcExport)
		}
		if err := apiretry.WaitUntilObjectDeleted(ctx, getFunc); err != nil {
			klog.ErrorS(err, "Failed to get the serviceExport", "serviceExport", name)
			return err
		}
	}

	klog.V(2).InfoS("Completed cleanup serviceExport related resources", "serviceExportCounter", len(list.Items))
	return nil
}