- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 90 for rr (0.03 sec)
-
src/expvar/expvar_test.go
m2 := NewMap("map2") for i := 0; i < 9; i++ { m2.Add(strconv.Itoa(i), int64(i)) } rr := httptest.NewRecorder() rr.Body = new(bytes.Buffer) expvarHandler(rr, nil) want := `{ "map1": {"a": 1, "z": 2}, "map2": {"0": 0, "1": 1, "2": 2, "3": 3, "4": 4, "5": 5, "6": 6, "7": 7, "8": 8} } ` if got := rr.Body.String(); got != want { t.Errorf("HTTP handler wrote:\n%s\nWant:\n%s", got, want) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:46:19 UTC 2024 - 13.4K bytes - Viewed (0) -
src/fmt/scan.go
// io.Reader inside r. func (r *readRune) ReadRune() (rr rune, size int, err error) { if r.peekRune >= 0 { rr = r.peekRune r.peekRune = ^r.peekRune size = utf8.RuneLen(rr) return } r.buf[0], err = r.readByte() if err != nil { return } if r.buf[0] < utf8.RuneSelf { // fast check for common ASCII case rr = rune(r.buf[0]) size = 1 // Known to be 1.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:56:20 UTC 2024 - 31.9K bytes - Viewed (0) -
tests/integration/security/util/cert/cert.go
}, Check: check.NoError(), }) if result.Responses.Len() != 1 { t.Fatalf("dump cert failed, no responses") } var certs []string for _, rr := range result.Responses[0].Body() { var s string if err := json.Unmarshal([]byte(rr), &s); err != nil { t.Fatalf("failed to unmarshal: %v", err) } certs = append(certs, s) } return certs }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 16:44:37 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/check/checkers.go
// Gather the networks that were reached. networkHits := make(map[string]int) for _, rr := range result.Responses { c := allClusters.GetByName(rr.Cluster) if c != nil { networkHits[c.NetworkName()]++ } } // Verify that all expected networks were reached. for network := range expectedByNetwork {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 03 16:19:07 UTC 2023 - 17.5K bytes - Viewed (0) -
test/escape5.go
r, s = leaktoret22(q, p) return r, s } func leaktoret22f(p, q *int) (r, s *int) { // ERROR "leaking param: p to result s" "leaking param: q to result r" rr, ss := leaktoret22(q, p) return rr, ss } var gp *int func leaktosink(p *int) *int { // ERROR "leaking param: p" gp = p return p } func f1() { var x int p := noleak(&x) _ = p } func f2() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 18:50:24 UTC 2023 - 5.3K bytes - Viewed (0) -
pkg/proxy/ipvs/README.md
Prot LocalAddress:Port Scheduler Flags -> RemoteAddress:Port Forward Weight ActiveConn InActConn TCP 10.0.0.1:443 rr persistent 10800 -> 192.168.0.1:6443 Masq 1 1 0 TCP 10.0.0.10:53 rr -> 172.17.0.2:53 Masq 1 0 0 UDP 10.0.0.10:53 rr -> 172.17.0.2:53 Masq 1 0 0 ``` ### Why kube-proxy can't start IPVS mode
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 02:32:29 UTC 2021 - 18.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator_test.go
auds := []string{} for i := 0; i < rr.Intn(4); i++ { auds = append(auds, string(uuid.NewUUID())) } choice := rr.Float64() switch { case choice < 0.9: r.ok = true r.err = nil // add some realistic annotations on ~20% of successful authentications if f := rr.Float64(); f < 0.2 { r.annotations = map[string]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 20.3K bytes - Viewed (0) -
pkg/kubelet/token/token_manager_test.go
}, } if c.requestTweaks != nil { c.requestTweaks(tr) } mgr := NewManager(nil) mgr.clock = clock rr := mgr.requiresRefresh(tr) if rr != c.expectRefresh { t.Fatalf("unexpected requiresRefresh result, got: %v, want: %v", rr, c.expectRefresh) } }) } } func TestDeleteServiceAccountToken(t *testing.T) { type request struct { name, namespace string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 04 00:16:47 UTC 2022 - 16.2K bytes - Viewed (0) -
src/image/color/ycbcr.go
// RGBToCMYK converts an RGB triple to a CMYK quadruple. func RGBToCMYK(r, g, b uint8) (uint8, uint8, uint8, uint8) { rr := uint32(r) gg := uint32(g) bb := uint32(b) w := rr if w < gg { w = gg } if w < bb { w = bb } if w == 0 { return 0, 0, 0, 0xff } c := (w - rr) * 0xff / w m := (w - gg) * 0xff / w y := (w - bb) * 0xff / w return uint8(c), uint8(m), uint8(y), uint8(0xff - w)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 10.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
running: atomic.NewBool(false), } } type RunnableRegistry struct { serviceregistry.Instance running *atomic.Bool } func (rr *RunnableRegistry) Run(stop <-chan struct{}) { if rr.running.Load() { panic("--- registry has been run twice ---") } rr.running.Store(true) <-stop } func expectRunningOrFail(t *testing.T, ctrl *Controller, want bool) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0)