func()

in pkg/controllers/member/serviceimport/controller.go [46:125]

• 62 lines of code
• 12 McCabe index (conditional complexity)

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
	// fetch serviceimport in member cluster
	serviceImport := &fleetnetv1alpha1.ServiceImport{}
	serviceImportRef := klog.KRef(req.Namespace, req.Name)
	startTime := time.Now()
	klog.V(2).InfoS("Reconciliation starts", "serviceImport", serviceImportRef)
	defer func() {
		latency := time.Since(startTime).Milliseconds()
		klog.V(2).InfoS("Reconciliation ends", "serviceImport", serviceImportRef, "latency", latency)
	}()

	if err := r.MemberClient.Get(ctx, req.NamespacedName, serviceImport); err != nil {
		if errors.IsNotFound(err) {
			klog.V(4).InfoS("Ignoring NotFound serviceImport", "serviceImport", serviceImportRef)
			return ctrl.Result{}, nil
		}
		klog.ErrorS(err, "Failed to get serviceImport", "serviceImport", serviceImportRef)
		return reconcile.Result{}, err
	}

	internalServiceImportName := formatInternalServiceImportName(serviceImport)
	internalServiceImport := &fleetnetv1alpha1.InternalServiceImport{
		ObjectMeta: metav1.ObjectMeta{
			Name:      internalServiceImportName,
			Namespace: r.HubNamespace,
		},
	}
	internalServiceImportRef := klog.KObj(internalServiceImport)

	// Examine DeletionTimestamp to determine if service import is under deletion.
	if serviceImport.ObjectMeta.DeletionTimestamp != nil {
		// When finalizer is not found, we can return early as the cleanup work should have been done.
		if !controllerutil.ContainsFinalizer(serviceImport, ServiceImportFinalizer) {
			return ctrl.Result{}, nil
		}

		// Delete service import dependency when the finalizer is expected then remove the finalizer from service import.
		if err := r.HubClient.Delete(ctx, internalServiceImport); err != nil {
			klog.ErrorS(err, "Failed to delete internalserviceimport as required by serviceimport finalizer", "InternalServiceImport", internalServiceImportRef, "ServiceImport", serviceImportRef, "finalizer", ServiceImportFinalizer)
			if !errors.IsNotFound(err) {
				return ctrl.Result{}, err
			}
		}
		controllerutil.RemoveFinalizer(serviceImport, ServiceImportFinalizer)
		if err := r.MemberClient.Update(ctx, serviceImport); err != nil {
			klog.ErrorS(err, "Failed to remove serviceimport finalizer", "ServiceImport", serviceImportRef, "finalizer", ServiceImportFinalizer)
			return ctrl.Result{}, err
		}
		// Stop reconciliation as the item is being deleted
		return ctrl.Result{}, nil
	}

	// Add finalizer when it's in service import when not being deleted
	if !controllerutil.ContainsFinalizer(serviceImport, ServiceImportFinalizer) {
		controllerutil.AddFinalizer(serviceImport, ServiceImportFinalizer)
		if err := r.MemberClient.Update(ctx, serviceImport); err != nil {
			klog.ErrorS(err, "Failed to add serviceimport finalizer", "ServiceImport", serviceImportRef, "finalizer", ServiceImportFinalizer)
			return ctrl.Result{}, err
		}
	}

	klog.V(2).InfoS("Create or update internal service import", "InternalServiceImport", internalServiceImportRef)
	if op, err := controllerutil.CreateOrUpdate(ctx, r.HubClient, internalServiceImport, func() error {
		if internalServiceImport.CreationTimestamp.IsZero() {
			// Set the ServiceReference only when the InternalServiceImport is created; most of the fields in
			// an ExportedObjectReference should be immutable.
			internalServiceImport.Spec.ServiceImportReference = fleetnetv1alpha1.FromMetaObjects(r.MemberClusterID, serviceImport.TypeMeta, serviceImport.ObjectMeta, serviceImport.CreationTimestamp)
		}

		// TO-DO: InternalServiceImport object is not an exported object and the ServiceImportReference (an
		// exportedObject field) will be removed; information updated here is not used.
		internalServiceImport.Spec.ServiceImportReference.UpdateFromMetaObject(serviceImport.ObjectMeta, serviceImport.CreationTimestamp)
		return nil
	}); err != nil {
		klog.ErrorS(err, "Failed to create or update InternalServiceImport from ServiceImport", "InternalServiceImport", internalServiceImportRef, "ServiceImport", serviceImportRef, "op", op)
		return ctrl.Result{}, err
	}

	return ctrl.Result{}, nil
}