Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for new_labels (0.28 sec)

  1. pkg/test/framework/components/ambient/waypoint.go

    		}
    		oldLabels := oldSvc.ObjectMeta.GetLabels()
    		if oldLabels == nil {
    			oldLabels = make(map[string]string, 1)
    		}
    		newLabels := maps.Clone(oldLabels)
    		if waypoint != "" {
    			newLabels[constants.AmbientUseWaypointLabel] = waypoint
    		} else {
    			delete(newLabels, constants.AmbientUseWaypointLabel)
    		}
    
    		doLabel := func(labels map[string]string) error {
    			// update needs the latest version
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/cache/desired_state_of_world.go

    					}
    				}
    				if seLinuxFileLabel == "" {
    					seLinuxFileLabel = newLabel
    					continue
    				}
    				if seLinuxFileLabel != newLabel {
    					accessMode := getVolumeAccessMode(volumeSpec)
    
    					fullErr := fmt.Errorf("volume %s is used with two different SELinux contexts in the same pod: %q, %q", volumeSpec.Name(), seLinuxFileLabel, newLabel)
    					err := handleSELinuxMetricError(
    						fullErr,
    						seLinuxSupported,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  3. cmd/metrics-v3-types.go

    				continue
    			}
    		}
    
    		labels := make([]string, 0, len(metric.VariableLabels)*2)
    		for k, v := range metric.VariableLabels {
    			if newLabel, ok := renameLabels[k]; ok {
    				labels = append(labels, newLabel, v)
    			} else {
    				labels = append(labels, k, v)
    			}
    		}
    		labels = append(labels, extraLabels...)
    		// If valid non zero value set the metrics
    		if metric.Value > 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 07:41:18 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/types2/labels.go

    				if d, _ := d.(*syntax.VarDecl); d != nil {
    					recordVarDecl(d.Pos())
    				}
    			}
    
    		case *syntax.LabeledStmt:
    			// declare non-blank label
    			if name := s.Label.Value; name != "_" {
    				lbl := NewLabel(s.Label.Pos(), check.pkg, name)
    				if alt := all.Insert(lbl); alt != nil {
    					err := check.newError(DuplicateLabel)
    					err.soft = true
    					err.addf(lbl.pos, "label %s already declared", name)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  5. src/go/types/labels.go

    			if d, _ := s.Decl.(*ast.GenDecl); d != nil && d.Tok == token.VAR {
    				recordVarDecl(d.Pos())
    			}
    
    		case *ast.LabeledStmt:
    			// declare non-blank label
    			if name := s.Label.Name; name != "_" {
    				lbl := NewLabel(s.Label.Pos(), check.pkg, name)
    				if alt := all.Insert(lbl); alt != nil {
    					err := check.newError(DuplicateLabel)
    					err.soft = true
    					err.addf(lbl, "label %s already declared", name)
    					err.addAltDecl(alt)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  6. src/cmd/cover/cover.go

    				if label, isLabel := stmt.(*ast.LabeledStmt); isLabel && !f.isControl(label.Stmt) {
    					newLabel := *label
    					newLabel.Stmt = &ast.EmptyStmt{
    						Semicolon: label.Stmt.Pos(),
    						Implicit:  true,
    					}
    					end = label.Pos() // Previous block ends before the label.
    					list[last] = &newLabel
    					// Open a gap and drop in the old statement, now without a label.
    					list = append(list, nil)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/serviceregistry_test.go

    		_, kube, xdsUpdater := setupTest(t)
    		makeService(t, kube, service)
    		xdsUpdater.WaitOrFail(t, "service")
    		makePod(t, kube, pod)
    		xdsUpdater.WaitOrFail(t, "proxy")
    		newPod := pod.DeepCopy()
    		newPod.Labels["newlabel"] = "new"
    		makePod(t, kube, newPod)
    		xdsUpdater.WaitOrFail(t, "proxy")
    	})
    
    	t.Run("Kubernetes only: headless pure HTTP service", func(t *testing.T) {
    		_, kube, fx := setupTest(t)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
Back to top