Function PatchWithOptimisticLock

pkg/resources/status/patch.go:38–90

PatchWithOptimisticLock updates the status of the cluster using the passed transaction functions (in the given order). Important: after successfully updating the status, this function refreshes it into the passed cluster

(
	ctx context.Context,
	c client.Client,
	cluster *apiv1.Cluster,
	txs ...Transaction,
)

// Important: after successfully updating the status, this
// function refreshes it into the passed cluster
func PatchWithOptimisticLock(
	ctx context.Context,
	c client.Client,
	cluster *apiv1.Cluster,
	txs ...Transaction,
) error {
	if cluster == nil {
		return nil
	}

	contextLogger := log.FromContext(ctx)

	origCluster := cluster.DeepCopy()

	if err := retry.RetryOnConflict(retry.DefaultBackoff, func() error {
		var currentCluster apiv1.Cluster
		if err := c.Get(ctx, client.ObjectKeyFromObject(cluster), &currentCluster); err != nil {
			return err
		}

		updatedCluster := currentCluster.DeepCopy()
		for _, tx := range txs {
			tx(updatedCluster)
		}

		if equality.Semantic.DeepEqual(currentCluster.Status, updatedCluster.Status) {
			return nil
		}

		if err := c.Status().Patch(
			ctx,
			updatedCluster,
			client.MergeFromWithOptions(&currentCluster, client.MergeFromWithOptimisticLock{}),
		); err != nil {
			return err
		}

		cluster.Status = updatedCluster.Status

		return nil
	}); err != nil {
		return fmt.Errorf("while patching status: %w", err)
	}

	if cluster.Status.Phase != apiv1.PhaseHealthy && origCluster.Status.Phase == apiv1.PhaseHealthy {
		contextLogger.Info("Cluster has become unhealthy")
	}
	if cluster.Status.Phase == apiv1.PhaseHealthy && origCluster.Status.Phase != apiv1.PhaseHealthy {
		contextLogger.Info("Cluster has become healthy")
	}

	return nil
}