Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for rp (0.02 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/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)
  3. 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)
  4. 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)
  5. pkg/testcerts/testcerts.go

    yQYipvEhYOJ7Dook+8rSfRY7lmLcdURWdOfY/s5U6kBDRqtTvl25zrivwNoLtBIo
    sYJFWchYEbv3k3457yfxawyuNfpwANv60bH7Hm9/ViBgqI5yrgB9Ly2pMDIGUjs2
    1nJBSABGlZKcxRHhVKauv35DYG9hRa/C1AoIUsCziZHLggr9+eZ1CdmHTuKekWVt
    9nriO02MXemKWfCZaRhPADnHf8oPw/rP+R/FrG6JF3JS9EVINQC8c9q0SyWbuwxg
    4u9k9DKk/joZ0cbqlOS74Wvk2GFigIF9uuOhZdHzF/+IYH4ZNM0AFGVoKn+QwFG8
    5kJyW6NsHIn5fOLyrT2rXXT/FJXr/lIJ//hzybIjHBfH4hB8uWvMLN2vrqT71yR6
    dfQxqrTJcxJbidjA5LF0ABOQaJ0ja+OrL3LHofY1f9fXzUWV+Bx6NIvNlZwIxL4G
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Dec 08 16:24:03 UTC 2022
    - 10.9K bytes
    - Viewed (0)
  6. pkg/scheduler/testing/framework/fake_extender.go

    	// and get cached node info by given node name.
    	nodeInfoCopy := f.CachedNodeNameToInfo[node.Node().Name].Snapshot()
    
    	var potentialVictims []*v1.Pod
    
    	removePod := func(rp *v1.Pod) error {
    		return nodeInfoCopy.RemovePod(logger, rp)
    	}
    	addPod := func(ap *v1.Pod) {
    		nodeInfoCopy.AddPod(ap)
    	}
    	// As the first step, remove all the lower priority pods from the node and
    	// check if the given pod can be scheduled.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. src/internal/trace/summary.go

    			g = s.gs[r.Scope.Goroutine()]
    		case ResourceProc:
    			rp := rangeP{id: r.Scope.Proc(), name: r.Name}
    			if goid, ok := s.rangesP[rp]; ok {
    				if goid == ev.Goroutine() {
    					// As the comment in the RangeBegin case states, this is only OK
    					// if we finish on the same goroutine we started on.
    					g = s.gs[goid]
    				}
    				delete(s.rangesP, rp)
    			}
    		}
    		if g == nil {
    			break
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  8. pkg/apis/core/fuzzer/fuzzer.go

    			policies := []core.PullPolicy{core.PullAlways, core.PullNever, core.PullIfNotPresent}
    			*p = policies[c.Rand.Intn(len(policies))]
    		},
    		func(rp *core.RestartPolicy, c fuzz.Continue) {
    			policies := []core.RestartPolicy{core.RestartPolicyAlways, core.RestartPolicyNever, core.RestartPolicyOnFailure}
    			*rp = policies[c.Rand.Intn(len(policies))]
    		},
    		// core.DownwardAPIVolumeFile needs to have a specific func since FieldRef has to be
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 04:32:01 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  9. src/crypto/tls/testdata/Server-TLSv13-ClientAuthRequestedAndGiven

    00000050  58 7d fe c1 e3 78 79 31  48 d2 74 c0 8d 17 97 6f  |X}...xy1H.t....o|
    00000060  30 bb 8a 2c 8c d4 76 3d  3f f0 20 24 3d 5a 21 0c  |0..,..v=?. $=Z!.|
    00000070  37 7b 14 45 e6 69 db ed  52 50 a0 77 e9 a2 84 59  |7{.E.i..RP.w...Y|
    00000080  0c 96 c1 ad 48 ed 8d 9f  00 4d f2 15 86 71 c0 fa  |....H....M...q..|
    00000090  14 b9 77 cb 9f 04 d9 1b  be da 68 8e 31 8f 25 14  |..w.......h.1.%.|
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 25 00:14:50 UTC 2023
    - 13.4K bytes
    - Viewed (0)
  10. pilot/cmd/pilot-agent/status/server_test.go

    				default:
    				}
    			}
    		})
    	}
    }
    
    func TestAdditionalProbes(t *testing.T) {
    	rp := readyProbe{}
    	urp := unreadyProbe{}
    	testCases := []struct {
    		name   string
    		probes []ready.Prober
    		err    error
    	}{
    		{
    			name:   "success probe",
    			probes: []ready.Prober{rp},
    			err:    nil,
    		},
    		{
    			name:   "not ready probe",
    			probes: []ready.Prober{urp},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 42.6K bytes
    - Viewed (0)
Back to top