Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for isMemberOf (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top