Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for updateStorage (0.4 sec)

  1. pkg/controller/statefulset/stateful_set_utils_test.go

    	}
    	updateStorage(set, pod)
    	if !storageMatches(set, pod) {
    		t.Error("updateStorage failed to recreate volumes")
    	}
    	pod = newStatefulSetPod(set, 1)
    	for i := range pod.Spec.Volumes {
    		pod.Spec.Volumes[i].PersistentVolumeClaim = nil
    	}
    	if storageMatches(set, pod) {
    		t.Error("Pod with invalid Volumes claim valid storage")
    	}
    	updateStorage(set, pod)
    	if !storageMatches(set, pod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_utils.go

    		}
    		claims[templates[i].Name] = *claim
    	}
    	return claims
    }
    
    // updateStorage updates pod's Volumes to conform with the PersistentVolumeClaim of set's templates. If pod has
    // conflicting local Volumes these are replaced with Volumes that conform to the set's templates.
    func updateStorage(set *apps.StatefulSet, pod *v1.Pod) {
    	currentVolumes := pod.Spec.Volumes
    	claims := getPersistentVolumeClaims(set, pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_pod_control.go

    			consistent = false
    		}
    		// if the Pod does not conform to the StatefulSet's storage requirements, update the Pod's PVC's,
    		// dirty the Pod, and create any missing PVCs
    		if !storageMatches(set, pod) {
    			updateStorage(set, pod)
    			consistent = false
    			if err := spc.createPersistentVolumeClaims(set, pod); err != nil {
    				spc.recordPodEvent("update", set, pod, err)
    				return err
    			}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 14.9K bytes
    - Viewed (0)
Back to top