- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 77 for StatusCode (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
func (w *tunnelingResponseWriter) WriteHeader(statusCode int) { w.mu.Lock() defer w.mu.Unlock() if w.written { klog.Errorf("WriteHeader called after write") return } if w.hijacked { klog.Errorf("WriteHeader called after hijack") return } w.written = true if statusCode == http.StatusSwitchingProtocols {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
func (c *ControlzClient) GetScopes() ([]*ScopeInfo, error) { var scopeInfos []*ScopeInfo resp, err := c.httpClient.Get(c.baseURL.String()) if err != nil { return nil, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("request not successful %s", resp.Status) } err = json.NewDecoder(resp.Body).Decode(&scopeInfos) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 13.5K bytes - Viewed (0) -
docs/de/docs/advanced/custom-response.md
!!! info Natürlich stammen der eigentliche `Content-Type`-Header, der Statuscode, usw., aus dem `Response`-Objekt, das Sie zurückgegeben haben. ### In OpenAPI dokumentieren und `Response` überschreiben
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Jan 23 13:05:12 UTC 2024 - 13.5K bytes - Viewed (0) -
src/net/http/transfer.go
t := &transferReader{RequestMethod: "GET"} // Unify input isResponse := false switch rr := msg.(type) { case *Response: t.Header = rr.Header t.StatusCode = rr.StatusCode t.ProtoMajor = rr.ProtoMajor t.ProtoMinor = rr.ProtoMinor t.Close = shouldClose(t.ProtoMajor, t.ProtoMinor, t.Header, true) isResponse = true if rr.Request != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 22:14:00 UTC 2024 - 31.1K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver.go
if err != nil { return nil, err } if resp.StatusCode < 200 || resp.StatusCode >= 300 { message := strconv.Quote(string(body)) if len(message) > 100 { message = message[:100] return nil, fmt.Errorf("status %d, message %s(truncated)", resp.StatusCode, message) } return nil, fmt.Errorf("status %d, message %s", resp.StatusCode, message) } return body, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0) -
docs/logging/README.md
"time": "2024-05-09T07:38:10.449688982Z", "event": "", "trigger": "incoming", "api": { "name": "PutObject", "bucket": "testbucket", "object": "hosts", "status": "OK", "statusCode": 200, "rx": 401, "tx": 0, "timeToResponse": "13309747ns", "timeToResponseInNS": "13309747" }, "remotehost": "127.0.0.1", "requestID": "17CDC1F4D7E69123",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 17:15:03 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/http-stats.go
bh.httpStats[bucket] = hstats return } // else { hstats.currentS3Requests.Dec(api) // decrement this once we have the response recorder. hstats.totalS3Requests.Inc(api) code := w.StatusCode switch { case code == 0: case code == 499: // 499 is a good error, shall be counted as canceled. hstats.totalS3Canceled.Inc(api) case code >= http.StatusBadRequest:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 06:25:13 UTC 2024 - 11.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} catch (e: IOException) { failConnection(e) } } } @Throws(IOException::class) internal fun writeSynReset( streamId: Int, statusCode: ErrorCode, ) { writer.rstStream(streamId, statusCode) } internal fun writeWindowUpdateLater( streamId: Int, unacknowledgedBytesRead: Long, ) { writerQueue.execute("$connectionName[$streamId] windowUpdate") {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/spiffe/spiffe.go
} else if resp == nil { errMsg = fmt.Sprintf("Calling %s failed with nil response", endpoint) } else if resp.StatusCode != http.StatusOK { b := make([]byte, 1024) n, _ := resp.Body.Read(b) errMsg = fmt.Sprintf("Calling %s failed with unexpected status: %v, fetching bundle: %s", endpoint, resp.StatusCode, string(b[:n])) } else { break } if startTime.Add(retryTimeout).Before(time.Now()) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.1K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
} defer o.args.CloseRespFn(resp.Body) reqDurNanos := time.Since(reqStartTime).Nanoseconds() o.serviceMetrics.accumRequestRTT(reqStartTime, float64(reqDurNanos)/1e6, true) switch resp.StatusCode { case 200: var result AuthNSuccessResponse if err = json.NewDecoder(resp.Body).Decode(&result); err != nil { return AuthNResponse{}, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0)