func()

in controllers/flinkcluster/flinkcluster_reconciler.go [360:376]

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

func (reconciler *ClusterReconciler) reconcilePersistentVolumeClaims(ctx context.Context) error {
	observed := reconciler.observed
	pvcs := observed.persistentVolumeClaims
	jm := observed.jmStatefulSet
	tm := observed.tmStatefulSet

	for _, pvc := range pvcs.Items {
		if c, ok := pvc.Labels["component"]; ok && c == "jobmanager" && jm != nil {
			reconciler.reconcilePersistentVolumeClaim(ctx, &pvc, jm)
		}
		if c, ok := pvc.Labels["component"]; ok && c == "taskmanager" && tm != nil {
			reconciler.reconcilePersistentVolumeClaim(ctx, &pvc, tm)
		}
	}

	return nil
}