- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for isMemberOf (0.78 sec)
-
pkg/controller/statefulset/stateful_set_utils_test.go
func TestIsMemberOf(t *testing.T) { set := newStatefulSet(3) set2 := newStatefulSet(3) set2.Name = "foo2" pod := newStatefulSetPod(set, 1) if !isMemberOf(set, pod) { t.Error("isMemberOf returned false negative") } if isMemberOf(set2, pod) { t.Error("isMemberOf returned false positive") } } func TestIdentityMatches(t *testing.T) { set := newStatefulSet(3) pod := newStatefulSetPod(set, 1)
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_utils.go
// NOTE: This name format is used by the heuristics for zone spreading in ChooseZoneForVolume return fmt.Sprintf("%s-%s-%d", claim.Name, set.Name, ordinal) } // isMemberOf tests if pod is a member of set. func isMemberOf(set *apps.StatefulSet, pod *v1.Pod) bool { return getParentName(pod) == set.Name } // identityMatches returns true if pod has a valid identity and network identity for a member of set.
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.go
if err != nil { return nil, err } filter := func(pod *v1.Pod) bool { // Only claim if it matches our StatefulSet name. Otherwise release/ignore. return isMemberOf(set, pod) } cm := controller.NewPodControllerRefManager(ssc.podControl, set, selector, controllerKind, ssc.canAdoptFunc(ctx, set)) return cm.ClaimPods(ctx, pods, filter) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0)