- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for rp (0.02 sec)
-
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) -
pkg/kubelet/cm/node_container_manager_linux.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 10.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)