- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 194 for StatusOK (0.19 sec)
-
samples/extauthz/cmd/extauthz/main_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 23 16:58:02 UTC 2023 - 3.6K 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) -
pkg/credentialprovider/config.go
if cfg, err := ReadDockerConfigJSONFile(nil); err == nil { return cfg, nil } // Can't find latest config file so check for the old one return ReadDockercfgFile(nil) } // HTTPError wraps a non-StatusOK error code as an error. type HTTPError struct { StatusCode int URL string } // Error implements error func (he *HTTPError) Error() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 19 15:11:57 UTC 2023 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit.go
// But Audit-Id http header will only be sent when http.ResponseWriter.WriteHeader is called. fakedSuccessStatus := &metav1.Status{ Code: http.StatusOK, Status: metav1.StatusSuccess, Message: "Connection closed early", } if ev.ResponseStatus == nil && longRunningSink != nil { ev.ResponseStatus = fakedSuccessStatus
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/http.go
epLog.Warn("websocket-echo read failed: " + err.Error()) return } body := bytes.Buffer{} h.addResponsePayload(r, &body) body.Write(message) echo.StatusCodeField.Write(&body, strconv.Itoa(http.StatusOK)) // pong err = c.WriteMessage(mt, body.Bytes()) if err != nil { writeError(&body, "websocket-echo write failed: "+err.Error()) return } } // nolint: interfacer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 12.8K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/udp.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 Oct 13 17:19:22 UTC 2022 - 3.4K bytes - Viewed (0) -
docs/sts/client-grants.go
InsecureSkipVerify: true, }, } hclient := http.Client{ Transport: t, } resp, err := hclient.Do(req) if err != nil { return nil, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("%s", resp.Status) } var idpToken JWTToken if err = json.NewDecoder(resp.Body).Decode(&idpToken); err != nil { return nil, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 3.3K 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) -
cmd/kubeadm/app/phases/patchnode/patchnode_test.go
patchRequest = buf.String() default: t.Errorf("request for unexpected HTTP verb: %v", req.Method) http.Error(w, "", http.StatusNotFound) return } w.WriteHeader(http.StatusOK) w.Write(jsonNode) })) defer s.Close() cs, err := clientset.NewForConfig(&restclient.Config{Host: s.URL}) if err != nil { t.Fatalf("unexpected error building clientset: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 3.7K bytes - Viewed (0)