- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for getPersistentVolumeClaims (0.28 sec)
-
pkg/controller/statefulset/stateful_pod_control_test.go
} func TestStatefulPodControlCreatePodExists(t *testing.T) { recorder := record.NewFakeRecorder(10) set := newStatefulSet(3) pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{} pvcs := getPersistentVolumeClaims(set, pod) pvcIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) for k := range pvcs { pvc := pvcs[k] pvcIndexer.Add(&pvc) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
if policy.WhenScaled == apps.RetainPersistentVolumeClaimRetentionPolicyType { // PVCs are meant to be reused and so can't be stale. return false, nil } for _, claim := range getPersistentVolumeClaims(set, pod) { pvc, err := spc.objectMgr.GetClaim(claim.Namespace, claim.Name) switch { case apierrors.IsNotFound(err): // If the claim doesn't exist yet, it can't be stale. continue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
} return append(refs, *metav1.NewControllerRef(owner, gvk)) } // getPersistentVolumeClaims gets a map of PersistentVolumeClaims to their template names, as defined in set. The // returned PersistentVolumeClaims are each constructed with a the name specific to the Pod. This name is determined // by getPersistentVolumeClaimName. func getPersistentVolumeClaims(set *apps.StatefulSet, pod *v1.Pod) map[string]v1.PersistentVolumeClaim {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
func TestGetPersistentVolumeClaims(t *testing.T) { // nil inherits statefulset labels pod := newPod() statefulSet := newStatefulSet(1) statefulSet.Spec.Selector.MatchLabels = nil claims := getPersistentVolumeClaims(statefulSet, pod) pvc := newPVC("datadir-foo-0") resultClaims := map[string]v1.PersistentVolumeClaim{"datadir": pvc} if !reflect.DeepEqual(claims, resultClaims) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
if err != nil { t.Error(err) } pods, err := om.podsLister.Pods(set.Namespace).List(selector) if err != nil { t.Error(err) } for _, pod := range pods { podClaims := getPersistentVolumeClaims(set, pod) for _, claim := range claims { if _, found := podClaims[claim.Name]; found { if hasOwnerRef(claim, pod) { t.Errorf("Unexpected ownerRef on %s", claim.Name) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
t.Fatalf("failed to unmarshal updated pod %s: %v", pod.Name, err) } return true, pod, nil }) for _, pod := range pods { om.podsIndexer.Add(pod) claims := getPersistentVolumeClaims(set, pod) for _, claim := range claims { om.CreateClaim(&claim) } } for i := range pods { if _, err := om.setPodReady(set, i); err != nil { t.Errorf("%d: %v", i, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0)