- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 122 for StatusOK (0.62 sec)
-
cmd/api-response.go
func writeSuccessResponseJSON(w http.ResponseWriter, response []byte) { writeResponse(w, http.StatusOK, response, mimeJSON) } // writeSuccessResponseXML writes success headers and response if any, // with content-type set to `application/xml`. func writeSuccessResponseXML(w http.ResponseWriter, response []byte) { writeResponse(w, http.StatusOK, response, mimeXML) } // writeSuccessNoContent writes success headers with http status 204
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.5K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.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 }, ch) wait.NonSlidingUntil(func() { // Service definition is not reconciled after first // run, ports and type will be corrected only during // start.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
pkg/test/framework/components/zipkin/kube.go
resp, err := client.Get(c.address + fmt.Sprintf(tracesAPI, limit, spanName, annotationQuery)) if err != nil { scopes.Framework.Debugf("zipking err %v", err) return nil, err } if resp.StatusCode != http.StatusOK { scopes.Framework.Debugf("response err %v", resp.StatusCode) return nil, fmt.Errorf("zipkin api returns non-ok: %v", resp.StatusCode) } defer resp.Body.Close() body, err := io.ReadAll(resp.Body)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 19:29:38 UTC 2023 - 8K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/grpc.go
} ip := "0.0.0.0" if peerInfo, ok := peer.FromContext(ctx); ok { ip, _, _ = net.SplitHostPort(peerInfo.Addr.String()) } echo.StatusCodeField.Write(&body, strconv.Itoa(http.StatusOK)) echo.ServiceVersionField.Write(&body, h.Version) echo.ServicePortField.Write(&body, strconv.Itoa(portNumber)) echo.ClusterField.WriteNonEmpty(&body, h.Cluster) echo.NamespaceField.WriteNonEmpty(&body, h.Namespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 25 17:30:37 UTC 2023 - 8.7K bytes - Viewed (0) -
samples/extauthz/cmd/extauthz/main.go
response.Header().Set(resultHeader, resultAllowed) response.Header().Set(overrideHeader, request.Header.Get(overrideHeader)) response.Header().Set(receivedHeader, l) response.WriteHeader(http.StatusOK) } else { log.Printf("[HTTP][denied]: %s", l) response.Header().Set(resultHeader, resultDenied) response.Header().Set(overrideHeader, request.Header.Get(overrideHeader)) response.Header().Set(receivedHeader, l)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 15 18:23:48 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/version.go
if err != nil { return "", errors.Errorf("unable to read content of URL %q: %s", url, err.Error()) } bodyString := strings.TrimSpace(string(body)) if resp.StatusCode != http.StatusOK { msg := fmt.Sprintf("unable to fetch file. URL: %q, status: %v", url, resp.Status) return bodyString, errors.New(msg) } return bodyString, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 10:50:19 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/kubelet/server/server.go
func writeJSONResponse(response *restful.Response, data []byte) { if data == nil { response.WriteHeader(http.StatusOK) // do not write a nil representation return } response.Header().Set(restful.HEADER_ContentType, restful.MIME_JSON) response.WriteHeader(http.StatusOK) if _, err := response.Write(data); err != nil { klog.ErrorS(err, "Error writing response") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
pilot/pkg/trustbundle/trustbundle_test.go
} stop := test.NewStop(t) // Mock response from TLS Spiffe Server validHandler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { w.WriteHeader(http.StatusOK) _, _ = w.Write([]byte(validSpiffeX509Bundle)) }) server1 := httptest.NewTLSServer(validHandler) caCertPool.AddCert(server1.Certificate()) defer server1.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 13.1K bytes - Viewed (0) -
src/net/http/cgi/host.go
rw.WriteHeader(http.StatusInternalServerError) h.printf("cgi: missing required Content-Type in headers") return } if statusCode == 0 { statusCode = http.StatusOK } // Copy headers to rw's headers, after we've decided not to // go into handleInternalRedirect, which won't want its rw // headers to have been touched. for k, vv := range headers {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 20:46:32 UTC 2024 - 10.4K bytes - Viewed (0) -
src/cmd/pprof/pprof.go
TLSClientConfig: tlsConfig, }, } resp, err := client.Get(source) if err != nil { return nil, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return nil, statusCodeError(resp) } return profile.Parse(resp.Body) } func statusCodeError(resp *http.Response) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 9.5K bytes - Viewed (0)