- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for getPersistentVolumeClaims (0.22 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_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)