- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 207 for StatusOK (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:19:46 UTC 2023 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
timeoutCh, cleanup := s.TimeoutFactory.TimeoutCh() defer cleanup() // begin the stream w.Header().Set("Content-Type", s.MediaType) w.Header().Set("Transfer-Encoding", "chunked") w.WriteHeader(http.StatusOK) flusher.Flush() kind := s.Scope.Kind watchEncoder := newWatchEncoder(req.Context(), kind, s.EmbeddedEncoder, s.Encoder, framer) ch := s.Watching.ResultChan() done := req.Context().Done() for {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 16:37:25 UTC 2023 - 11.4K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder_test.go
t.Fatalf("%s: unexpected request: %s (%s)\n%#v", testName, p, req.URL, req) } header := http.Header{} header.Set("Content-Type", runtime.ContentTypeJSON) return &http.Response{ StatusCode: http.StatusOK, Header: header, Body: stringBody(body), }, nil }), }, nil } } func testData() (*v1.PodList, *v1.ServiceList) { pods := &v1.PodList{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 11:58:41 UTC 2023 - 56.1K bytes - Viewed (0) -
pkg/spiffe/spiffe.go
errMsg = fmt.Sprintf("Calling %s failed with error: %v", endpoint, err) } 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 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.1K bytes - Viewed (0) -
tests/integration/security/authz_test.go
} for _, c := range cases { c := c testName := fmt.Sprintf("%s(%s)/http", c.host, c.allow) t.NewSubTest(testName).Run(func(t framework.TestContext) { wantCode := http.StatusOK if !c.allow { wantCode = http.StatusForbidden } opts := echo.CallOptions{ Port: echo.Port{ Protocol: protocol.HTTP, }, HTTP: echo.HTTP{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 23:36:51 UTC 2024 - 50.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
wait.PollImmediateUntil(100*time.Millisecond, func() (bool, error) { var code int c.client.CoreV1().RESTClient().Get().AbsPath("/readyz").Do(context.TODO()).StatusCode(&code) return code == http.StatusOK, nil }, stopCh) wait.NonSlidingUntil(func() { if err := c.UpdatePeerEndpointLeases(); err != nil { runtime.HandleError(fmt.Errorf("unable to update peer endpoint leases: %v", err)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
src/net/http/fs_test.go
testFileLen = 11 ) type wantRange struct { start, end int64 // range [start,end) } var ServeFileRangeTests = []struct { r string code int ranges []wantRange }{ {r: "", code: StatusOK}, {r: "bytes=0-4", code: StatusPartialContent, ranges: []wantRange{{0, 5}}}, {r: "bytes=2-", code: StatusPartialContent, ranges: []wantRange{{2, testFileLen}}},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
pkg/scheduler/extender.go
return err } req.Header.Set("Content-Type", "application/json") resp, err := h.client.Do(req) if err != nil { return err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return fmt.Errorf("failed %v with extender at URL %v, code %v", action, url, resp.StatusCode) } return json.NewDecoder(resp.Body).Decode(result) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.4K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
// closenotify case should be instantaneous. t.Error("Handler never saw CloseNotify") return case <-w.(http.CloseNotifier).CloseNotify(): } w.WriteHeader(http.StatusOK) w.Write([]byte(backendResponse)) })) defer backend.Close() backend.Config.ErrorLog = log.New(io.Discard, "", 0) backendURL, err := url.Parse(backend.URL) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
{ bucketName: bucketName, accessKey: credentials.AccessKey, secretKey: credentials.SecretKey, expectedBucketPolicy: bucketPolicyTemplate, expectedRespStatus: http.StatusOK, }, // Test case - 2. // Case with non-existent bucket name. { bucketName: "non-existent-bucket", accessKey: credentials.AccessKey,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0)