Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 182 for StatusOK (0.27 sec)

  1. pkg/ctrlz/home.go

    		if req.URL.Path == "/" {
    			// home page
    			fw.RenderHTML(w, homeTmpl, getHomeInfo())
    		} else if req.URL.Path == "/homej" || req.URL.Path == "/homej/" {
    			fw.RenderJSON(w, http.StatusOK, getHomeInfo())
    		} else if a, err := assets.FS.ReadFile("static" + req.URL.Path); err == nil {
    			// static asset
    			ext := strings.ToLower(filepath.Ext(req.URL.Path))
    			if mime, ok := mimeTypes[ext]; ok {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 24 14:06:41 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/etag.go

    		w.WriteHeader(http.StatusNotModified)
    		return
    	}
    
    	responsewriters.WriteObjectNegotiated(
    		serializer,
    		DiscoveryEndpointRestrictions,
    		targetGV,
    		w,
    		req,
    		http.StatusOK,
    		object,
    		true,
    	)
    }
    
    func calculateETag(resources interface{}) (string, error) {
    	serialized, err := json.Marshal(resources)
    	if err != nil {
    		return "", err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 18:15:22 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. cni/pkg/plugin/cnieventclient.go

    	response, err = cniClient.client.Post(cniClient.url, "application/json", bytes.NewBuffer(eventData))
    	if err != nil {
    		return err
    	}
    	defer response.Body.Close()
    
    	if response.StatusCode != http.StatusOK {
    		return fmt.Errorf("unable to push CNI event, error was %d", response.StatusCode)
    	}
    
    	return nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. internal/config/dns/operator_dns.go

    	if err != nil {
    		if derr := c.Delete(bucket); derr != nil {
    			return newError(bucket, derr)
    		}
    		return err
    	}
    	defer xhttp.DrainBody(resp.Body)
    
    	if resp.StatusCode != http.StatusOK {
    		var errorStringBuilder strings.Builder
    		io.Copy(&errorStringBuilder, io.LimitReader(resp.Body, resp.ContentLength))
    		errorString := errorStringBuilder.String()
    		if resp.StatusCode == http.StatusConflict {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  5. 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)
  6. 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 (1)
  7. 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)
  8. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/group.go

    }
    
    func (s *APIGroupHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) {
    	responsewriters.WriteObjectNegotiated(s.serializer, negotiation.DefaultEndpointRestrictions, schema.GroupVersion{}, w, req, http.StatusOK, &s.group, false)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 20:38:08 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  9. pilot/cmd/pilot-agent/app/wait.go

    		return err
    	}
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	defer resp.Body.Close()
    	_, err = io.ReadAll(resp.Body)
    	if err != nil {
    		return err
    	}
    	if resp.StatusCode != http.StatusOK {
    		return fmt.Errorf("HTTP status code %v", resp.StatusCode)
    	}
    	return nil
    }
    
    func init() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/legacy.go

    		Versions:                   []string{"v1"},
    	}
    
    	responsewriters.WriteObjectNegotiated(s.serializer, negotiation.DefaultEndpointRestrictions, schema.GroupVersion{}, resp, req, http.StatusOK, apiVersions, false)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 22:44:49 UTC 2022
    - 2.7K bytes
    - Viewed (0)
Back to top