- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for StatusCode (0.2 sec)
-
src/net/http/fs_test.go
if rt.r != "" { req.Header.Set("Range", rt.r) } resp, body := getBody(t, fmt.Sprintf("range test %q", rt.r), req, c) if resp.StatusCode != rt.code { t.Errorf("range=%q: StatusCode=%d, want %d", rt.r, resp.StatusCode, rt.code) } if rt.code == StatusRequestedRangeNotSatisfiable { continue } wantContentRange := "" if len(rt.ranges) == 1 { rng := rt.ranges[0]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
StatusCode: 200, Body: closeCheck, }}, ErrorLog: log.New(logBuf, "", 0), ModifyResponse: func(*http.Response) error { return outErr }, } rec := httptest.NewRecorder() rp.ServeHTTP(rec, req) res := rec.Result() if g, e := res.StatusCode, http.StatusBadGateway; g != e { t.Errorf("got res.StatusCode %d; expected %d", g, e) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
resp, err := http.Get(httpURL) if err != nil { t.Fatalf("Got error GETing: %v", err) } defer resp.Body.Close() if resp.StatusCode != expectedErrorCode { t.Errorf("expected status code %d, got %d", expectedErrorCode, resp.StatusCode) } } // Ensure all registered handlers & services have an associated testcase. func TestAuthzCoverage(t *testing.T) { fw := newServerTest()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
src/net/http/client_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
} pluginsWaitTime[pl.Name()] = timeout statusCode = framework.Wait } else { err := status.AsError() logger.Error(err, "Plugin failed", "plugin", pl.Name(), "pod", klog.KObj(pod)) return framework.AsStatus(fmt.Errorf("running Permit plugin %q: %w", pl.Name(), err)).WithPlugin(pl.Name()) } } } if statusCode == framework.Wait { waitingPod := newWaitingPod(pod, pluginsWaitTime)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
src/net/http/transport.go
hasBody := rc.treq.Request.Method != "HEAD" && resp.ContentLength != 0 if resp.Close || rc.treq.Request.Close || resp.StatusCode <= 199 || bodyWritable { // Don't do keep-alive on error if either party requested a close // or we get an unexpected informational (1xx) response. // StatusCode 100 is already handled above. alive = false } if !hasBody || bodyWritable {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, } case minio.ErrorResponse: apiErr = APIError{ Code: e.Code, Description: e.Message, HTTPStatusCode: e.StatusCode, } if strings.Contains(e.Message, "KMS is not configured") { apiErr = APIError{ Code: "NotImplemented", Description: e.Message,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
if filter == nil { return nil } resp := &istio.HTTPRedirect{} if filter.StatusCode != nil { // Istio allows 301, 302, 303, 307, 308. // Gateway allows only 301 and 302. resp.RedirectCode = uint32(*filter.StatusCode) } if filter.Hostname != nil { resp.Authority = string(*filter.Hostname) } if filter.Scheme != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
cmd/batch-handlers.go
clnt := http.Client{Transport: getRemoteInstanceTransport()} resp, err := clnt.Do(req) if err != nil { return err } xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { return errors.New(resp.Status) } return nil } // Notify notifies notification endpoint if configured regarding job failure or success.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
} } func TestSyncReplicaSetDormancy(t *testing.T) { // Setup a test server so we can lie about the current state of pods logger, ctx := ktesting.NewTestContext(t) fakeHandler := utiltesting.FakeHandler{ StatusCode: 200, ResponseBody: "{}", SkipRequestFn: skipListerFunc, T: t, } testServer := httptest.NewServer(&fakeHandler) defer testServer.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)