- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for LabelSelectorAsSelector (0.4 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)