Function UpdateRuntimeCondition

pkg/utils/runtime_condition.go:42–71

UpdateRuntimeCondition updates the runtime to include the provided condition. If the condition that we are about to add already exists and has the same status and reason then we are not going to update.

(conditions []data.RuntimeCondition, condition data.RuntimeCondition)

// If the condition that we are about to add already exists
// and has the same status and reason then we are not going to update.
func UpdateRuntimeCondition(conditions []data.RuntimeCondition, condition data.RuntimeCondition) []data.RuntimeCondition {
	// conditions = trimRuntimeConditions(conditions)
	retConditions := slices.Clone(conditions)

	index, oldCondtion := GetRuntimeCondition(retConditions, condition.Type)

	if oldCondtion == nil {
		retConditions = append(retConditions, condition)
		return retConditions
	}

	// We define two types of runtime condition: ready type conditions (e.g. WorkerReady) and action type conditions (e.g. WorkerScaledOut).
	// For action type conditions that occur only once (e.g. WorkerInitialized), if condition exists, fluid will not update it.
	if isOnceActionTypeCondition(condition) {
		return retConditions
	}

	// For ready type conditions, recording the earliest transition and probe time is enough and
	// we avoiding update its probe time and transition time in every sync because it needs large amount of status updates.
	if isReadyTypeCondition(condition) {
		// keep old transition time and probe time if condition status is not changed
		if condition.Status == oldCondtion.Status {
			condition.LastTransitionTime = oldCondtion.LastTransitionTime
			condition.LastProbeTime = oldCondtion.LastProbeTime
		}
	}

	retConditions[index] = condition
	return retConditions
}

// GetRuntimeCondition gets a runtime condition given a runtime condition type.
// If found, return index of the founded condition in the condition array