- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 66 for wroteHeader (0.21 sec)
-
cmd/kube-scheduler/app/options/options_test.go
if username == "" { username = "none, tls" } w.WriteHeader(200) w.Write([]byte(`ok`)) })) defer server.Close() // http server insecureserver := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { username, _, _ = req.BasicAuth() if username == "" { username = "none, http" } w.WriteHeader(200) w.Write([]byte(`ok`)) })) defer insecureserver.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 30.3K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/init_test.go
} } } func TestInitDataClientWithNonDefaultKubeconfig(t *testing.T) { ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { if r.Method != http.MethodHead { w.WriteHeader(http.StatusMethodNotAllowed) } })) defer ts.Close() kubeconfigPath := filepath.Join(t.TempDir(), "custom.conf")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 12:26:20 UTC 2024 - 11.9K bytes - Viewed (0) -
pilot/pkg/trustbundle/trustbundle_test.go
t.Fatalf("failed to get SystemCertPool: %v", err) } stop := test.NewStop(t) // Mock response from TLS Spiffe Server validHandler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { w.WriteHeader(http.StatusOK) _, _ = w.Write([]byte(validSpiffeX509Bundle)) }) server1 := httptest.NewTLSServer(validHandler) caCertPool.AddCert(server1.Certificate()) defer server1.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 13.1K bytes - Viewed (0) -
src/net/http/fcgi/fcgi_test.go
}() rc := &signalingNopWriteCloser{pr, make(chan bool)} handlerDone := make(chan bool) c := newChild(rc, http.HandlerFunc(func( w http.ResponseWriter, r *http.Request, ) { w.WriteHeader(200) close(handlerDone) })) c.serve() <-handlerDone <-rc.closed t.Log("FastCGI child closed connection")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
} twoSecondHandler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { wg.Done() time.Sleep(2 * time.Second) w.WriteHeader(http.StatusOK) graceShutdown = true }) okHandler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { w.WriteHeader(http.StatusOK) }) s.Handler.NonGoRestfulMux.Handle("/test", twoSecondHandler) s.Handler.NonGoRestfulMux.Handle("/200", okHandler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils_test.go
handler := http.HandlerFunc(func(resp http.ResponseWriter, req *http.Request) { t.Logf("request: %+v", *req) switch req.URL.Path { default: t.Logf("The request contains path: %v", req.URL) resp.WriteHeader(http.StatusOK) } }) server.httpServer = httptest.NewTLSServer(handler) t.Logf("Serving TLS at: %v", server.httpServer.URL) return server }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 03:58:11 UTC 2024 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
timeoutCh, cleanup := s.TimeoutFactory.TimeoutCh() defer cleanup() // begin the stream w.Header().Set("Content-Type", s.MediaType) w.Header().Set("Transfer-Encoding", "chunked") w.WriteHeader(http.StatusOK) flusher.Flush() kind := s.Scope.Kind watchEncoder := newWatchEncoder(req.Context(), kind, s.EmbeddedEncoder, s.Encoder, framer) ch := s.Watching.ResultChan() done := req.Context().Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 16:37:25 UTC 2023 - 11.4K bytes - Viewed (0) -
cmd/kube-scheduler/app/server_test.go
if err != nil { t.Fatal(err) } defer os.RemoveAll(tmpDir) // https server server := httptest.NewTLSServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { w.WriteHeader(200) w.Write([]byte(`ok`)) })) defer server.Close() configKubeconfig := filepath.Join(tmpDir, "config.kubeconfig") if err := os.WriteFile(configKubeconfig, []byte(fmt.Sprintf(` apiVersion: v1 kind: Config
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.2K bytes - Viewed (0) -
src/archive/tar/reader_test.go
for _, path := range []string{ "../foo", "/foo", "a/b/../../../c", } { var buf bytes.Buffer tw := NewWriter(&buf) tw.WriteHeader(&Header{ Name: path, }) const securePath = "secure" tw.WriteHeader(&Header{ Name: securePath, }) tw.Close() tr := NewReader(&buf) h, err := tr.Next() if err != ErrInsecurePath {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 21 21:14:38 UTC 2022 - 47.1K bytes - Viewed (0) -
src/net/http/response.go
r1.Close = true } // Process Body,ContentLength,Close,Trailer tw, err := newTransferWriter(r1) if err != nil { return err } err = tw.writeHeader(w, nil) if err != nil { return err } // Rest of header err = r.Header.WriteSubset(w, respExcludeHeader) if err != nil { return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0)