- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 77 for StatusOK (0.16 sec)
-
src/os/exec.go
// reference was not dropped or status changed. func (p *Process) handlePersistentRelease(reason processStatus) processStatus { if p.mode != modeHandle { panic("handlePersistentRelease called in invalid mode") } for { refs := p.state.Load() status := processStatus(refs & processStatusMask) if status != statusOK {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_test.go
`, t) checkPath(server.URL+"/healthz/poststarthook/delegate-post-start-hook", http.StatusOK, `ok`, t) checkPath(server.URL+"/healthz/poststarthook/wrapping-post-start-hook", http.StatusOK, `ok`, t) checkPath(server.URL+"/foo", http.StatusForbidden, ``, t) checkPath(server.URL+"/bar", http.StatusUnauthorized, ``, t) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 13.1K bytes - Viewed (0) -
tests/integration/security/egress_gateway_origination_test.go
// This root certificate can validate the server cert presented by the echoboot server instance. { name: "simple", statusCode: http.StatusOK, credentialToUse: strings.TrimSuffix(credName, "-cacert"), useGateway: true, }, // Use CA certificate stored as k8s secret with different issuing CA as server's CA.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 15.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete.go
result = &metav1.Status{ Status: metav1.StatusSuccess, Code: http.StatusOK, Details: &metav1.StatusDetails{ Kind: scope.Kind.Kind, }, } } span.AddEvent("About to write a response") defer span.AddEvent("Writing http response done") transformResponseObject(ctx, scope, req, w, http.StatusOK, outputMediaType, result) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 10:00:32 UTC 2023 - 11.4K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server.go
s.mutex.Lock() if err != nil { w.WriteHeader(http.StatusServiceUnavailable) log.Warnf("Envoy proxy is NOT ready: %s", err.Error()) s.lastProbeSuccessful = false } else { w.WriteHeader(http.StatusOK) if !s.lastProbeSuccessful { log.Info("Envoy proxy is ready") } s.lastProbeSuccessful = true } s.mutex.Unlock() } func (s *Server) isReady() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
lastError = errors.WithMessagef(err, "%s /healthz check failed", comp.name) return false, nil } defer func() { _ = resp.Body.Close() }() if resp.StatusCode != http.StatusOK { lastError = errors.Errorf("%s /healthz check failed with status: %d", comp.name, resp.StatusCode) return false, nil } return true, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K 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/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) -
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) -
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)