- Sort Score
- Result 10 results
- Languages All
Results 71 - 73 of 73 for wroteHeader (0.45 sec)
-
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) -
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) -
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)