- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 360 for resps (0.2 sec)
-
internal/grid/connection_test.go
errFatal(remoteConn.WaitForConnect(context.Background())) stream, err := remoteConn.NewStream(context.Background(), handlerTest2, []byte(testPayload)) errFatal(err) go func() { for resp := range stream.responses { t.Log("Resp:", resp, err) } gotResp <- struct{}{} }() <-gotCall remote.debugMsg(debugKillOutbound) local.debugMsg(debugKillOutbound)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/authentication.go
authenticationStart := time.Now() if len(apiAuds) > 0 { req = req.WithContext(authenticator.WithAudiences(req.Context(), apiAuds)) } resp, ok, err := auth.AuthenticateRequest(req) authenticationFinish := time.Now() defer func() { metrics(req.Context(), resp, ok, err, apiAuds, authenticationStart, authenticationFinish) }() if err != nil || !ok { if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 6.4K bytes - Viewed (0) -
cmd/crossdomain-xml-handler_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jul 08 14:31:42 UTC 2023 - 1.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/upload/upload.go
if resp.StatusCode >= 400 && resp.StatusCode < 500 { err := os.Remove(fname) if err == nil { u.logger.Printf("Removed local/%s", filepath.Base(fname)) } else { u.logger.Printf("Error removing local/%s: %v", filepath.Base(fname), err) } } return false } // Store a copy of the uploaded report in the uploaded directory. if err := os.WriteFile(newname, buf, 0644); err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 3.4K bytes - Viewed (0) -
src/net/http/httputil/persist.go
cc.re = err return nil, err } } resp, err = http.ReadResponse(r, req) cc.mu.Lock() defer cc.mu.Unlock() if err != nil { cc.re = err return resp, err } cc.lastbody = resp.Body cc.nread++ if resp.Close { cc.re = ErrPersistEOF // don't send any more requests return resp, cc.re } return resp, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go
upgradeHeader := strings.ToLower(resp.Header.Get(httpstream.HeaderUpgrade)) if (resp.StatusCode != http.StatusSwitchingProtocols) || !strings.Contains(connectionHeader, strings.ToLower(httpstream.HeaderUpgrade)) || !strings.Contains(upgradeHeader, strings.ToLower(HeaderSpdy31)) { defer resp.Body.Close() responseError := "" responseErrorBytes, err := io.ReadAll(resp.Body)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/istio-agent/agent_test.go
resp.AgentConfig.ProxyIPAddresses = []string{"127.0.0.1"} // ensures IPv4 binding resp.AgentConfig.Platform = &platform.Unknown{} // disable discovery // Run through opts again to apply settings for _, opt := range opts { resp = opt(resp) } a := NewAgent(resp.ProxyConfig, &resp.AgentConfig, &resp.Security, envoy.ProxyConfig{TestOnly: !resp.envoyEnable}) t.Cleanup(a.Close)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 33.4K bytes - Viewed (0) -
internal/config/policy/plugin/config.go
if o.args.AuthToken != "" { req.Header.Set("Authorization", o.args.AuthToken) } resp, err := o.client.Do(req) if err != nil { return false, err } defer o.args.CloseRespFn(resp.Body) // Read the body to be saved later. opaRespBytes, err := io.ReadAll(resp.Body) if err != nil { return false, err } // Handle large OPA responses when OPA URL is of
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
docs/iam/identity-manager-plugin.go
json.NewEncoder(w).Encode(map[string]string{ "reason": fmt.Sprintf("%v", err), }) } type Resp struct { User string `json:"user"` MaxValiditySeconds int `json:"maxValiditySeconds"` Claims map[string]interface{} `json:"claims"` } var tokens map[string]Resp = map[string]Resp{ "aaa": { User: "Alice", MaxValiditySeconds: 3600,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/util.go
index := index workFn := func() error { st := time.Now() resp, err := doReq(ctx, cfg, index) if err != nil { fwLog.Debugf("request failed: %v", err) return err } fwLog.Debugf("got resp: %v", resp) responsesMu.Lock() responses[index] = resp responseTimes[index] = time.Since(st) responsesMu.Unlock() return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 4.4K bytes - Viewed (0)