- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 886 for labelValue (0.29 sec)
-
cni/pkg/repair/repaircontroller.go
return nil } repairLog.Infof("Labeling pod %s/%s with label %s=%s", pod.Namespace, pod.Name, c.cfg.LabelKey, c.cfg.LabelValue) patchBytes := fmt.Sprintf(`{"metadata":{"labels":{%q:%q}}}`, c.cfg.LabelKey, c.cfg.LabelValue) // Both "pods" and "pods/status" can mutate the metadata. However, pods/status is lower privilege, so we use that instead.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/registry/apps/statefulset/storage/storage_test.go
t.Fatalf("Unexpected error: %v", err) } applyLabelPatch := func(labelName, labelValue string) rest.TransformFunc { return func(_ context.Context, _, currentObject runtime.Object) (objToUpdate runtime.Object, patchErr error) { currentObject.(metav1.Object).SetLabels(map[string]string{labelName: labelValue}) return currentObject, nil } } stopCh := make(chan struct{}) wg := &sync.WaitGroup{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 14K bytes - Viewed (0) -
pkg/registry/apps/replicaset/storage/storage_test.go
t.Fatalf("Unexpected error: %v", err) } applyLabelPatch := func(labelName, labelValue string) rest.TransformFunc { return func(_ context.Context, _, currentObject runtime.Object) (objToUpdate runtime.Object, patchErr error) { currentObject.(metav1.Object).SetLabels(map[string]string{labelName: labelValue}) return currentObject, nil } } stopCh := make(chan struct{}) wg := &sync.WaitGroup{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 17.7K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage_test.go
t.Fatalf("Unexpected error: %v", err) } applyLabelPatch := func(labelName, labelValue string) rest.TransformFunc { return func(_ context.Context, _, currentObject runtime.Object) (objToUpdate runtime.Object, patchErr error) { currentObject.(metav1.Object).SetLabels(map[string]string{labelName: labelValue}) return currentObject, nil } } stopCh := make(chan struct{}) wg := &sync.WaitGroup{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
} func namespaceHasLabelWithValue(kubeClient kube.CLIClient, ns string, label, labelValue string) (bool, error) { nsObj, err := getNamespace(kubeClient, ns) if err != nil { return false, err } if nsObj.Labels == nil { return false, nil } return nsObj.Labels[label] == labelValue, nil } func getNamespace(kubeClient kube.CLIClient, ns string) (*corev1.Namespace, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go
} return gotObj.(*unstructured.Unstructured), nil } applyPatch := func(labelName, labelValue string) rest.TransformFunc { return func(_ context.Context, _, currentObject runtime.Object) (objToUpdate runtime.Object, patchErr error) { o := currentObject.(metav1.Object) o.SetLabels(map[string]string{ labelName: labelValue, }) return currentObject, nil } } errs := make(chan error, 1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/registry/apps/deployment/storage/storage_test.go
t.Fatalf("Unexpected error: %v", err) } applyLabelPatch := func(labelName, labelValue string) rest.TransformFunc { return func(_ context.Context, _, currentObject runtime.Object) (objToUpdate runtime.Object, patchErr error) { currentObject.(metav1.Object).SetLabels(map[string]string{labelName: labelValue}) return currentObject, nil } } stopCh := make(chan struct{}) wg := &sync.WaitGroup{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:45 UTC 2023 - 19.7K bytes - Viewed (0) -
pkg/monitoring/monitoring_test.go
mt.Assert(hookSum.Name(), map[string]string{"name": "baz"}, monitortest.Exactly(45)) } type testRecordHook struct{} func (r *testRecordHook) OnRecord(n string, tags []monitoring.LabelValue, value float64) { // Check if this is `events_total` metric. if n != "events_total" { return } // Get name tag of recorded testSume metric, and record the corresponding hookSum metric. var nv string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 8.4K bytes - Viewed (0) -
cni/pkg/cmd/root.go
DeletePods: viper.GetBool(constants.RepairDeletePods), LabelPods: viper.GetBool(constants.RepairLabelPods), LabelKey: viper.GetString(constants.RepairLabelKey), LabelValue: viper.GetString(constants.RepairLabelValue), NodeName: viper.GetString(constants.RepairNodeName), SidecarAnnotation: viper.GetString(constants.RepairSidecarAnnotation),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/timing_ratio_histogram.go
func (v *TimingRatioHistogramVec) NewForLabelValuesSafe(initialNumerator, initialDenominator float64, labelValues []string) RatioedGauge { tro, err := v.NewForLabelValuesChecked(initialNumerator, initialDenominator, labelValues) if err == nil { klog.V(3).InfoS("TimingRatioHistogramVec.NewForLabelValuesSafe hit the efficient case", "fqName", v.FQName(), "labelValues", labelValues) return tro } if !compbasemetrics.ErrIsNotRegistered(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 03 06:51:04 UTC 2023 - 8.6K bytes - Viewed (0)