- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 193 for StatusOK (0.13 sec)
-
src/net/http/fcgi/child.go
} } func (r *response) Header() http.Header { return r.header } func (r *response) Write(p []byte) (n int, err error) { if !r.wroteHeader { r.WriteHeader(http.StatusOK) } if !r.wroteCGIHeader { r.writeCGIHeader(p) } return r.w.Write(p) } func (r *response) WriteHeader(code int) { if r.wroteHeader { return } r.wroteHeader = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.3K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
for _, h := range tests { ctx.NewSubTest(h.Host).Run(func(t framework.TestContext) { SendRequestOrFail(t, ing, h.Host, h.CredentialName, callType, tlsContext, ExpectedResponse{StatusCode: http.StatusOK}) }) } }) } // RunTestMultiTLSGateways deploys multiple TLS gateways with SDS enabled, and creates kubernetes secret that stores
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
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 { return nil, fmt.Errorf("cannot deserialize response %s", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 13.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/watch_test.go
} request.Header.Add("Accept", "application/json") response, err := http.DefaultClient.Do(request) if err != nil { t.Fatalf("unexpected error: %v", err) } if response.StatusCode != http.StatusOK { b, _ := ioutil.ReadAll(response.Body) t.Fatalf("Unexpected response: %#v\n%s", response, string(b)) } // Close response to cause a cancel on the server if err := response.Body.Close(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 30 17:27:39 UTC 2023 - 30K bytes - Viewed (0) -
pkg/kube/inject/webhook_test.go
body: validReview, contentType: "application/json", wantAllowed: true, wantStatusCode: http.StatusOK, }, { name: "valid(v1 version)", body: validReviewV1, contentType: "application/json", wantAllowed: true, wantStatusCode: http.StatusOK, }, { name: "skipped", body: skipReview, contentType: "application/json",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 39K bytes - Viewed (1) -
pkg/hbone/dialer.go
if resp.TLS != nil && len(resp.TLS.PeerCertificates) > 0 { ids, _ := util.ExtractIDs(resp.TLS.PeerCertificates[0].Extensions) if len(ids) > 0 { remoteID = ids[0] } } if resp.StatusCode != http.StatusOK { return fmt.Errorf("round trip failed: %v", resp.Status) } log.WithLabels("host", r.Host, "remote", remoteID).Info("CONNECT established") go func() { defer conn.Close() defer resp.Body.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus_test.go
tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, } return tf }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/tcp.go
if line != "" { echo.WriteBodyLine(&msgBuilder, requestID, line) } } msg := msgBuilder.String() expected := fmt.Sprintf("%s=%d", string(echo.StatusCodeField), http.StatusOK) if cfg.Request.ExpectedResponse != nil { expected = cfg.Request.ExpectedResponse.GetValue() } if !strings.Contains(msg, expected) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 4.9K bytes - Viewed (0) -
pkg/probe/http/http.go
klog.V(4).Infof("Non fatal body truncation for %s, Response: %v", url.String(), *res) } else { return probe.Failure, "", err } } body := string(b) if res.StatusCode >= http.StatusOK && res.StatusCode < http.StatusBadRequest { if res.StatusCode >= http.StatusMultipleChoices { // Redirect klog.V(4).Infof("Probe terminated redirects for %s, Response: %v", url.String(), *res)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 10 00:37:32 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/graceful_shutdown_test.go
b.counter++ if b.counter == 25 { startServerShutdown <- struct{}{} } handlerLock.Unlock() time.Sleep(60 * time.Second) w.Write([]byte("hello from the backend")) w.WriteHeader(http.StatusOK)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 6.9K bytes - Viewed (0)