func()

in operator/controllers/operator/banyandb_controller.go [88:110]

• 20 lines of code
• 5 McCabe index (conditional complexity)

func (r *BanyanDBReconciler) checkState(ctx context.Context, log logr.Logger, banyanDB *operatorv1alpha1.BanyanDB) error {
	overlay := operatorv1alpha1.BanyanDBStatus{}
	deployment := apps.Deployment{}
	errCol := new(kubernetes.ErrorCollector)
	if err := r.Client.Get(ctx, client.ObjectKey{Namespace: banyanDB.Namespace, Name: banyanDB.Name + "-banyandb"}, &deployment); err != nil && !apierrors.IsNotFound(err) {
		errCol.Collect(fmt.Errorf("failed to get deployment: %w", err))
	} else {
		overlay.Conditions = deployment.Status.Conditions
		overlay.AvailableReplicas = deployment.Status.AvailableReplicas
	}
	if apiequal.Semantic.DeepDerivative(overlay, banyanDB.Status) {
		log.Info("Status keeps the same as before")
		return errCol.Error()
	}

	if err := r.updateStatus(ctx, banyanDB, overlay, errCol); err != nil {
		errCol.Collect(fmt.Errorf("failed to update status of banyanDB: %w", err))
	}

	log.Info("updated Status sub resource")

	return errCol.Error()
}