- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 193 for StatusOK (0.17 sec)
-
src/net/http/httptest/recorder.go
type ResponseRecorder struct { // Code is the HTTP response code set by WriteHeader. // // Note that if a Handler never calls WriteHeader or Write, // this might end up being 0, rather than the implicit // http.StatusOK. To get the implicit value, use the Result // method. Code int // HeaderMap contains the headers explicitly set by the Handler. // It is an internal detail. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_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: Wed Apr 10 21:51:29 UTC 2024 - 8.9K bytes - Viewed (0) -
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/proxy/healthcheck/service_health.go
resp.Header().Set("X-Content-Type-Options", "nosniff") resp.Header().Set("X-Load-Balancing-Endpoint-Weight", strconv.Itoa(count)) if count != 0 && kubeProxyHealthy { resp.WriteHeader(http.StatusOK) } else { resp.WriteHeader(http.StatusServiceUnavailable) } fmt.Fprint(resp, strings.Trim(dedent.Dedent(fmt.Sprintf(` { "service": { "namespace": %q, "name": %q },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K 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) -
pkg/controller/garbagecollector/dump.go
return } w.Header().Set("Content-Type", "text/vnd.graphviz") w.Header().Set("X-Content-Type-Options", "nosniff") w.Write(b.Bytes()) w.WriteHeader(http.StatusOK) } func (gc *GarbageCollector) DebuggingHandler() http.Handler { return NewDebugHandler(gc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 17:12:33 UTC 2022 - 9.5K 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)