- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 71 for StatusOK (0.25 sec)
-
docs/iam/identity-manager-plugin.go
return } rsp, ok := tokens[token] if !ok { w.WriteHeader(http.StatusForbidden) return } fmt.Printf("Allowed for token: %s user: %s\n", token, rsp.User) w.WriteHeader(http.StatusOK) json.NewEncoder(w).Encode(rsp) return } func main() { http.HandleFunc("/", mainHandler) log.Print("Listening on :8081") log.Fatal(http.ListenAndServe(":8081", nil))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 2.1K 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/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) -
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) -
internal/rest/client.go
// If trace is enabled, dump http request and response, // except when the traceErrorsOnly enabled and the response's status code is ok if c.TraceOutput != nil && resp.StatusCode != http.StatusOK { c.dumpHTTP(req, resp) } if resp.StatusCode != http.StatusOK { // If server returns 412 pre-condition failed, it would // mean that authentication succeeded, but another // side-channel check has failed, we shall take
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
tests/integration/security/filebased_tls_origination/egress_gateway_origination_test.go
// --> externalServer(443 with only Simple TLS used and client cert is not verified) "Mutual TLS origination from egress gateway to https endpoint": { destinationRuleMode: "MUTUAL", code: http.StatusOK, gateway: true, fakeRootCert: false, }, // 2. Simple TLS case: // internalClient ) ---HTTP request (Host: some-external-site.com----> Hits listener 0.0.0.0_80 ->
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.9K bytes - Viewed (0) -
internal/config/identity/openid/providercfg.go
client := &http.Client{ Transport: transport, } resp, err := client.Do(req) if err != nil { return nil, err } defer xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { // uncomment this for debugging when needed. // reqBytes, _ := httputil.DumpRequest(req, false) // fmt.Println(string(reqBytes)) // respBytes, _ := httputil.DumpResponse(resp, true)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0)