- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for closeNotify (3.62 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper_test.go
fw.counter.HijackInvoked++ } return fw.ResponseWriter.(http.Hijacker).Hijack() } func (fw *fakeResponseWriterDecorator) CloseNotify() <-chan bool { if fw.counter != nil { fw.counter.CloseNotifyInvoked++ } //nolint:staticcheck // SA1019 return fw.ResponseWriter.(http.CloseNotifier).CloseNotify()
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/responsewriter/wrapper.go
InnerCloseNotifierFlusher CloseNotifierFlusher } func (wr outerWithCloseNotifyAndFlush) CloseNotify() <-chan bool { if notifier, ok := wr.UserProvidedDecorator.(http.CloseNotifier); ok { return notifier.CloseNotify() } return wr.InnerCloseNotifierFlusher.CloseNotify() } func (wr outerWithCloseNotifyAndFlush) Flush() { if flusher, ok := wr.UserProvidedDecorator.(http.Flusher); ok {
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/endpoints/responsewriter/fake.go
type FakeResponseWriterFlusherCloseNotifier struct { *FakeResponseWriter } func (fw *FakeResponseWriterFlusherCloseNotifier) Flush() {} func (fw *FakeResponseWriterFlusherCloseNotifier) CloseNotify() <-chan bool { return nil } // For HTTP/1.x an http.ResponseWriter object implements // http.Flusher, http.CloseNotifier and http.Hijacker. // It is used for testing purpose only
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 01 19:58:11 UTC 2021 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
// // We are throwing http.ErrAbortHandler deliberately so that a client is notified and to suppress a not helpful stacktrace in the logs panic(http.ErrAbortHandler) } } func (tw *baseTimeoutWriter) CloseNotify() <-chan bool { tw.mu.Lock() defer tw.mu.Unlock() if tw.timedOut { done := make(chan bool) close(done) return done }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/handlers/forwarder.go
outReq.Host = target.Host } // TODO: only supports HTTP 1.1 for now. outReq.Proto = "HTTP/1.1" outReq.ProtoMajor = 1 outReq.ProtoMinor = 1 f.rewriter.Rewrite(outReq) // Disable closeNotify when method GET for http pipelining if outReq.Method == http.MethodGet { quietReq := outReq.WithContext(context.Background()) *outReq = *quietReq } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0)