- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 123 for StatusOK (0.23 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
// http.StatusServiceUnavailable // and api error codes // Note that if we specify a versioned Status object here, we may need to // create one for the tests, also // Success: // http.StatusOK, http.StatusCreated, http.StatusAccepted, http.StatusNoContent // // test/integration/auth_test.go is currently the most comprehensive status code test for _, s := range a.group.Serializer.SupportedMediaTypes() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
if !healthy { metrics.ProxyHealthzTotal.WithLabelValues("503").Inc() resp.WriteHeader(http.StatusServiceUnavailable) } else { metrics.ProxyHealthzTotal.WithLabelValues("200").Inc() resp.WriteHeader(http.StatusOK) // In older releases, the returned "lastUpdated" time indicated the last // time the proxier sync loop ran, even if nothing had changed. To // preserve compatibility, we use the same semantics: the returned
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0) -
cmd/admin-handlers_test.go
} rec := httptest.NewRecorder() adminTestBed.router.ServeHTTP(rec, req) resp, _ := io.ReadAll(rec.Body) if rec.Code != http.StatusOK { t.Errorf("Expected to receive %d status code but received %d. Body (%s)", http.StatusOK, rec.Code, string(resp)) } result := &serviceResult{} if err := json.Unmarshal(resp, result); err != nil { t.Error(err) } _ = result
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.8K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
expectedRespStatus: http.StatusOK, lifecycleResponse: []byte(``), errorResponse: APIErrorResponse{}, shouldPass: true, }, { method: http.MethodGet, accessKey: creds.AccessKey,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 11.3K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
client := &http.Client{ Transport: r.transport, } resp, err := client.Get(pCfg.JWKS.URL.String()) if err != nil { return err } defer r.closeRespFn(resp.Body) if resp.StatusCode != http.StatusOK { return errors.New(resp.Status) } return r.pubKeys.parseAndAdd(resp.Body) } // ErrTokenExpired - error token expired var ( ErrTokenExpired = errors.New("token expired") )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 18:10:41 UTC 2024 - 8.3K bytes - Viewed (0) -
internal/s3select/select_test.go
if err = s3Select.Open(newStringRSC(in)); err != nil { t.Fatal(err) } w := &testResponseWriter{} s3Select.Evaluate(w) s3Select.Close() resp := http.Response{ StatusCode: http.StatusOK, Body: io.NopCloser(bytes.NewReader(w.response)), ContentLength: int64(len(w.response)), } res, err := minio.NewSelectResults(&resp, "testbucket") if err != nil { t.Error(err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 76.2K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig_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 - 3.8K bytes - Viewed (0) -
tests/integration/security/egress_sidecar_tls_origination_test.go
credentialToUse: credNameGeneric, from: apps.Ns1.A, drSelector: "a", authorizeSidecar: true, expectedResponse: ingressutil.ExpectedResponse{ StatusCode: http.StatusOK, }, }, // Mutual TLS origination from an unauthorized sidecar to https endpoint // This will result in a 503 with the UH flag because the cluster will // stay warming until a valid secret is sent.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 10.4K bytes - Viewed (0) -
src/net/http/filetransport.go
pr.res.StatusCode = code pr.res.Status = fmt.Sprintf("%d %s", code, StatusText(code)) } func (pr *populateResponse) Write(p []byte) (n int, err error) { if !pr.wroteHeader { pr.WriteHeader(StatusOK) } pr.hasContent = true if !pr.sentResponse { pr.sendResponse() } return pr.pw.Write(p)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/log/uds.go
} resp, err := u.client.Post(u.url, "application/json", bytes.NewReader(msg)) if err != nil { return fmt.Errorf("failed to send logs to uds server %v: %v", u.url, err) } if resp.StatusCode != http.StatusOK { return fmt.Errorf("uds server returns non-ok status %v: %v", u.url, resp.Status) } return nil } // Write implements zapcore.Core. Log messages will be temporarily buffered and sent to
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 16 00:20:01 UTC 2024 - 3.4K bytes - Viewed (0)