- Sort Score
- Result 10 results
- Languages All
Results 31 - 35 of 35 for readWrite (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go
outerWithCloseNotifyAndFlush // http.Hijacker for the inner object InnerHijacker http.Hijacker } func (wr outerWithCloseNotifyFlushAndHijack) Hijack() (net.Conn, *bufio.ReadWriter, error) { if hijacker, ok := wr.UserProvidedDecorator.(http.Hijacker); ok { return hijacker.Hijack() } return wr.InnerHijacker.Hijack()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
// http.CloseNotifier if the inner object (tw.w) implements http.CloseNotifier. return tw.w.(http.CloseNotifier).CloseNotify() } func (tw *baseTimeoutWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) { tw.mu.Lock() defer tw.mu.Unlock() if tw.timedOut { return nil, nil, http.ErrHandlerTimeout } // the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go
} // WriteHeader implements http.ResponseWriter. func (rl *respLogger) WriteHeader(status int) { rl.recordStatus(status) rl.w.WriteHeader(status) } func (rl *respLogger) Hijack() (net.Conn, *bufio.ReadWriter, error) { rl.hijacked = true // the outer ResponseWriter object returned by WrapForHTTP1Or2 implements // http.Hijacker if the inner object (rl.w) implements http.Hijacker. return rl.w.(http.Hijacker).Hijack()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 10:10:35 UTC 2023 - 9.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper_test.go
func (fw *fakeResponseWriterDecorator) Flush() { if fw.counter != nil { fw.counter.FlushInvoked++ } fw.ResponseWriter.(http.Flusher).Flush() } func (fw *fakeResponseWriterDecorator) Hijack() (net.Conn, *bufio.ReadWriter, error) { if fw.counter != nil { fw.counter.HijackInvoked++ } return fw.ResponseWriter.(http.Hijacker).Hijack() } func (fw *fakeResponseWriterDecorator) CloseNotify() <-chan bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:53 UTC 2021 - 8.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit.go
} func (a *auditResponseWriter) WriteHeader(code int) { a.processCode(code) a.ResponseWriter.WriteHeader(code) } func (a *auditResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) { // fake a response status before protocol switch happens a.processCode(http.StatusSwitchingProtocols) // the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 8.6K bytes - Viewed (0)