Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 73 of 73 for wroteHeader (0.45 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream_test.go

    			r := NewReader(bytes.NewBuffer([]byte(input)), true, supportedProtocols)
    			s, addr := newServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
    				err := r.Copy(w, req)
    				if err != nil {
    					w.WriteHeader(503)
    				}
    			}))
    			defer s.Close()
    
    			config, err := websocket.NewConfig("ws://"+addr, "http://localhost/")
    			if err != nil {
    				t.Error(err)
    				return
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  2. internal/dsync/dsync-server_test.go

    	}
    	_, err = args.UnmarshalMsg(buf)
    	return args, err
    }
    
    type lockServerHandler struct {
    	lsrv *lockServer
    }
    
    func (lh *lockServerHandler) writeErrorResponse(w http.ResponseWriter, err error) {
    	w.WriteHeader(http.StatusForbidden)
    	w.Write([]byte(err.Error()))
    }
    
    func (lh *lockServerHandler) ForceUnlockHandler(w http.ResponseWriter, r *http.Request) {
    	args, err := getLockArgs(r)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  3. pkg/controller/garbagecollector/dump.go

    		http.Error(w, err.Error(), http.StatusInternalServerError)
    		return
    	}
    
    	w.Header().Set("Content-Type", "text/vnd.graphviz")
    	w.Header().Set("X-Content-Type-Options", "nosniff")
    	w.Write(b.Bytes())
    	w.WriteHeader(http.StatusOK)
    }
    
    func (gc *GarbageCollector) DebuggingHandler() http.Handler {
    	return NewDebugHandler(gc)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 23 17:12:33 UTC 2022
    - 9.5K bytes
    - Viewed (0)
Back to top