Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 54 for LabelSelectorAsSelector (0.4 sec)

  1. pkg/controller/history/controller_history_test.go

    		}
    	}
    	ss1 := newStatefulSet(3, "ss1", types.UID("ss1"), map[string]string{"foo": "bar"})
    	ss2 := newStatefulSet(3, "ss2", types.UID("ss2"), map[string]string{"goo": "car"})
    	sel1, err := metav1.LabelSelectorAsSelector(ss1.Spec.Selector)
    	if err != nil {
    		t.Fatal(err)
    	}
    	ss1Rev1, err := NewControllerRevision(ss1, parentKind, ss1.Spec.Template.Labels, rawTemplate(&ss1.Spec.Template), 1, nil)
    	if err != nil {
    		t.Fatal(err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 21 13:31:28 UTC 2023
    - 49.1K bytes
    - Viewed (0)
  2. pkg/controller/podautoscaler/replica_calculator_test.go

    		}
    
    		assert.Equal(t, tc.metric.name, listAction.GetResource().Resource, "the metric requested should have matched the one specified")
    
    		selector, err := metav1.LabelSelectorAsSelector(tc.metric.selector)
    		if err != nil {
    			return true, nil, fmt.Errorf("failed to convert label selector specified in test client")
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Aug 19 03:31:34 UTC 2023
    - 68.4K bytes
    - Viewed (0)
  3. pkg/controller/podautoscaler/horizontal.go

    		a.monitor.ObserveMetricComputationResult(actionLabel, errorLabel, time.Since(start), spec.Type)
    	}()
    
    	switch spec.Type {
    	case autoscalingv2.ObjectMetricSourceType:
    		metricSelector, err := metav1.LabelSelectorAsSelector(spec.Object.Metric.Selector)
    		if err != nil {
    			condition := a.getUnableComputeReplicaCountCondition(hpa, "FailedGetObjectMetric", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  4. pkg/controller/daemon/update.go

    // If you want to modify one, you need to deep-copy it first.
    func (dsc *DaemonSetsController) controlledHistories(ctx context.Context, ds *apps.DaemonSet) ([]*apps.ControllerRevision, error) {
    	selector, err := metav1.LabelSelectorAsSelector(ds.Spec.Selector)
    	if err != nil {
    		return nil, err
    	}
    
    	// List all histories to include those that don't match the selector anymore
    	// but have a ControllerRef pointing to the controller.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 16:53:53 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_set_control.go

    	return currentRevision, updateRevision, currentStatus, nil
    }
    
    func (ssc *defaultStatefulSetControl) ListRevisions(set *apps.StatefulSet) ([]*apps.ControllerRevision, error) {
    	selector, err := metav1.LabelSelectorAsSelector(set.Spec.Selector)
    	if err != nil {
    		return nil, err
    	}
    	return ssc.controllerHistory.ListControllerRevisions(set, selector)
    }
    
    func (ssc *defaultStatefulSetControl) AdoptOrphanRevisions(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  6. pkg/controller/job/job_controller.go

    // finalizers.
    // Note that the returned Pods are pointers into the cache.
    func (jm *Controller) getPodsForJob(ctx context.Context, j *batch.Job) ([]*v1.Pod, error) {
    	selector, err := metav1.LabelSelectorAsSelector(j.Spec.Selector)
    	if err != nil {
    		return nil, fmt.Errorf("couldn't convert Job selector: %v", err)
    	}
    	// List all pods to include those that don't match the selector anymore
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  7. pkg/controller/disruption/disruption.go

    // IMPORTANT NOTE : the returned pods should NOT be modified.
    func (dc *DisruptionController) getPodsForPdb(pdb *policy.PodDisruptionBudget) ([]*v1.Pod, error) {
    	sel, err := metav1.LabelSelectorAsSelector(pdb.Spec.Selector)
    	if err != nil {
    		return []*v1.Pod{}, err
    	}
    	pods, err := dc.podLister.Pods(pdb.Namespace).List(sel)
    	if err != nil {
    		return []*v1.Pod{}, err
    	}
    	return pods, nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  8. operator/cmd/mesh/manifest-generate_test.go

    	t.Helper()
    	// From webhook spec: "Default to the empty LabelSelector, which matches everything."
    	if selector == nil {
    		return true
    	}
    	s, err := metav1.LabelSelectorAsSelector(selector)
    	if err != nil {
    		t.Fatal(err)
    	}
    	return s.Matches(labels)
    }
    
    func TestSidecarTemplate(t *testing.T) {
    	runTestGroup(t, testGroup{
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 04 18:05:06 UTC 2024
    - 43.5K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/volumebinding/binder.go

    	if capacity.NodeTopology == nil {
    		// Unavailable
    		return false
    	}
    	// Only matching by label is supported.
    	selector, err := metav1.LabelSelectorAsSelector(capacity.NodeTopology)
    	if err != nil {
    		logger.Error(err, "Unexpected error converting to a label selector", "nodeTopology", capacity.NodeTopology)
    		return false
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  10. pkg/controller/daemon/daemon_controller.go

    // If you want to modify one, you need to deep-copy it first.
    func (dsc *DaemonSetsController) getDaemonPods(ctx context.Context, ds *apps.DaemonSet) ([]*v1.Pod, error) {
    	selector, err := metav1.LabelSelectorAsSelector(ds.Spec.Selector)
    	if err != nil {
    		return nil, err
    	}
    
    	// List all pods to include those that don't match the selector anymore but
    	// have a ControllerRef pointing to this controller.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
Back to top