Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for rp (0.4 sec)

  1. pilot/pkg/networking/core/envoyfilter/rc_patch.go

    	for _, rp := range efw.Patches[networking.EnvoyFilter_ROUTE_CONFIGURATION] {
    		if rp.Operation != networking.EnvoyFilter_Patch_MERGE {
    			continue
    		}
    		if commonConditionMatch(patchContext, rp) &&
    			routeConfigurationMatch(patchContext, routeConfiguration, rp, portMap) {
    			merge.Merge(routeConfiguration, rp.Value)
    			IncrementEnvoyFilterMetric(rp.Key(), Route, true)
    		} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. pkg/config/schema/kubetypes/common.go

    		}
    		return gr
    	}
    	if rp := typemap.Get[RegisterType[T]](registeredTypes); rp != nil {
    		return (*rp).GetGVR()
    	}
    	panic("unknown kind: " + ptr.TypeName[T]())
    }
    
    func MustGVKFromType[T runtime.Object]() (cfg config.GroupVersionKind) {
    	if gvk, ok := getGvk(ptr.Empty[T]()); ok {
    		return gvk
    	}
    	if rp := typemap.Get[RegisterType[T]](registeredTypes); rp != nil {
    		return (*rp).GetGVK()
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 16:38:40 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  3. pkg/config/analysis/analyzers/telemetry/selector.go

    		foundPod := false
    		c.ForEach(gvk.Pod, func(rp *resource.Instance) bool {
    			pNs := rp.Metadata.FullName.Namespace
    			podLabels := labels.Set(rp.Metadata.Labels)
    
    			// Only attempt to match in the same namespace
    			if pNs != sNs {
    				return true
    			}
    
    			if sel.Matches(podLabels) {
    				foundPod = true
    				podsToTelemetries[rp.Metadata.FullName] = append(podsToTelemetries[rp.Metadata.FullName], rs)
    			}
    
    			return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  4. src/internal/trace/testdata/testprog/stress-start-stop.go

    		done := make(chan bool)
    
    		wg.Add(1)
    		go func() {
    			<-done
    			wg.Done()
    		}()
    
    		rp, wp, err := os.Pipe()
    		if err != nil {
    			log.Fatalf("failed to create pipe: %v", err)
    			return
    		}
    		defer func() {
    			rp.Close()
    			wp.Close()
    		}()
    		wg.Add(1)
    		go func() {
    			var tmp [1]byte
    			rp.Read(tmp[:])
    			<-done
    			wg.Done()
    		}()
    		time.Sleep(time.Millisecond)
    
    		go func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. src/internal/trace/testdata/testprog/stress.go

    	go func() {
    		<-done
    		wg.Done()
    	}()
    
    	// Create a goroutine blocked in syscall before tracing.
    	rp, wp, err := os.Pipe()
    	if err != nil {
    		log.Fatalf("failed to create pipe: %v", err)
    	}
    	defer func() {
    		rp.Close()
    		wp.Close()
    	}()
    	wg.Add(1)
    	go func() {
    		var tmp [1]byte
    		rp.Read(tmp[:])
    		<-done
    		wg.Done()
    	}()
    	time.Sleep(time.Millisecond) // give the goroutine above time to block
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/node_container_manager_linux.go

    	if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.MemoryQoS) {
    		if rp.Memory != nil {
    			if rp.Unified == nil {
    				rp.Unified = make(map[string]string)
    			}
    			rp.Unified[Cgroup2MemoryMin] = strconv.FormatInt(*rp.Memory, 10)
    		}
    	}
    
    	cgroupConfig := &CgroupConfig{
    		Name:               cName,
    		ResourceParameters: rp,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  7. pkg/config/analysis/analyzers/sidecar/selector.go

    		foundPod := false
    		c.ForEach(gvk.Pod, func(rp *resource.Instance) bool {
    			pNs := rp.Metadata.FullName.Namespace
    			podLabels := labels.Set(rp.Metadata.Labels)
    
    			// Only attempt to match in the same namespace
    			if pNs != sNs {
    				return true
    			}
    
    			if sel.Matches(podLabels) {
    				foundPod = true
    				podsToSidecars[rp.Metadata.FullName] = append(podsToSidecars[rp.Metadata.FullName], rs)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun May 05 03:44:57 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. src/internal/trace/testdata/testprog/stacks.go

    		if err != nil {
    			log.Printf("failed to accept: %v", err)
    			return
    		}
    		c.Close()
    	}()
    	rp, wp, err := os.Pipe()
    	if err != nil {
    		log.Fatalf("failed to create a pipe: %v", err)
    	}
    	defer rp.Close()
    	defer wp.Close()
    	pipeReadDone := make(chan bool)
    	go func() { // func11
    		var data [1]byte
    		rp.Read(data[:])
    		pipeReadDone <- true
    	}()
    
    	time.Sleep(100 * time.Millisecond)
    	runtime.GC()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  9. src/cmd/go/internal/modindex/read.go

    // Import is the equivalent of build.Import given the information in Module.
    func (rp *IndexPackage) Import(bctxt build.Context, mode build.ImportMode) (p *build.Package, err error) {
    	defer unprotect(protect(), &err)
    
    	ctxt := (*Context)(&bctxt)
    
    	p = &build.Package{}
    
    	p.ImportPath = "."
    	p.Dir = filepath.Join(rp.modroot, rp.dir)
    
    	var pkgerr error
    	switch ctxt.Compiler {
    	case "gccgo", "gc":
    	default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 14:34:32 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  10. cmd/perf-tests.go

    	cli, err := globalSiteReplicationSys.getAdminClient(ctx, deploymentID)
    	if err != nil {
    		result.Error = err.Error()
    		return
    	}
    	rp := cli.GetEndpointURL()
    	reqURL := &url.URL{
    		Scheme: rp.Scheme,
    		Host:   rp.Host,
    		Path:   reqPath,
    	}
    	result.Endpoint = rp.String()
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, reqURL.String(), reader)
    	if err != nil {
    		result.Error = err.Error()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top