| // +build !go1.8 |
| // Code generated by "httpsnoop/codegen"; DO NOT EDIT. |
| |
| package httpsnoop |
| |
| import ( |
| "bufio" |
| "io" |
| "net" |
| "net/http" |
| ) |
| |
| // HeaderFunc is part of the http.ResponseWriter interface. |
| type HeaderFunc func() http.Header |
| |
| // WriteHeaderFunc is part of the http.ResponseWriter interface. |
| type WriteHeaderFunc func(code int) |
| |
| // WriteFunc is part of the http.ResponseWriter interface. |
| type WriteFunc func(b []byte) (int, error) |
| |
| // FlushFunc is part of the http.Flusher interface. |
| type FlushFunc func() |
| |
| // CloseNotifyFunc is part of the http.CloseNotifier interface. |
| type CloseNotifyFunc func() <-chan bool |
| |
| // HijackFunc is part of the http.Hijacker interface. |
| type HijackFunc func() (net.Conn, *bufio.ReadWriter, error) |
| |
| // ReadFromFunc is part of the io.ReaderFrom interface. |
| type ReadFromFunc func(src io.Reader) (int64, error) |
| |
| // Hooks defines a set of method interceptors for methods included in |
| // http.ResponseWriter as well as some others. You can think of them as |
| // middleware for the function calls they target. See Wrap for more details. |
| type Hooks struct { |
| Header func(HeaderFunc) HeaderFunc |
| WriteHeader func(WriteHeaderFunc) WriteHeaderFunc |
| Write func(WriteFunc) WriteFunc |
| Flush func(FlushFunc) FlushFunc |
| CloseNotify func(CloseNotifyFunc) CloseNotifyFunc |
| Hijack func(HijackFunc) HijackFunc |
| ReadFrom func(ReadFromFunc) ReadFromFunc |
| } |
| |
| // Wrap returns a wrapped version of w that provides the exact same interface |
| // as w. Specifically if w implements any combination of: |
| // |
| // - http.Flusher |
| // - http.CloseNotifier |
| // - http.Hijacker |
| // - io.ReaderFrom |
| // |
| // The wrapped version will implement the exact same combination. If no hooks |
| // are set, the wrapped version also behaves exactly as w. Hooks targeting |
| // methods not supported by w are ignored. Any other hooks will intercept the |
| // method they target and may modify the call's arguments and/or return values. |
| // The CaptureMetrics implementation serves as a working example for how the |
| // hooks can be used. |
| func Wrap(w http.ResponseWriter, hooks Hooks) http.ResponseWriter { |
| rw := &rw{w: w, h: hooks} |
| _, i0 := w.(http.Flusher) |
| _, i1 := w.(http.CloseNotifier) |
| _, i2 := w.(http.Hijacker) |
| _, i3 := w.(io.ReaderFrom) |
| switch { |
| // combination 1/16 |
| case !i0 && !i1 && !i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| }{rw, rw} |
| // combination 2/16 |
| case !i0 && !i1 && !i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| io.ReaderFrom |
| }{rw, rw, rw} |
| // combination 3/16 |
| case !i0 && !i1 && i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Hijacker |
| }{rw, rw, rw} |
| // combination 4/16 |
| case !i0 && !i1 && i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Hijacker |
| io.ReaderFrom |
| }{rw, rw, rw, rw} |
| // combination 5/16 |
| case !i0 && i1 && !i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.CloseNotifier |
| }{rw, rw, rw} |
| // combination 6/16 |
| case !i0 && i1 && !i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.CloseNotifier |
| io.ReaderFrom |
| }{rw, rw, rw, rw} |
| // combination 7/16 |
| case !i0 && i1 && i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.CloseNotifier |
| http.Hijacker |
| }{rw, rw, rw, rw} |
| // combination 8/16 |
| case !i0 && i1 && i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.CloseNotifier |
| http.Hijacker |
| io.ReaderFrom |
| }{rw, rw, rw, rw, rw} |
| // combination 9/16 |
| case i0 && !i1 && !i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| }{rw, rw, rw} |
| // combination 10/16 |
| case i0 && !i1 && !i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| io.ReaderFrom |
| }{rw, rw, rw, rw} |
| // combination 11/16 |
| case i0 && !i1 && i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| http.Hijacker |
| }{rw, rw, rw, rw} |
| // combination 12/16 |
| case i0 && !i1 && i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| http.Hijacker |
| io.ReaderFrom |
| }{rw, rw, rw, rw, rw} |
| // combination 13/16 |
| case i0 && i1 && !i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| http.CloseNotifier |
| }{rw, rw, rw, rw} |
| // combination 14/16 |
| case i0 && i1 && !i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| http.CloseNotifier |
| io.ReaderFrom |
| }{rw, rw, rw, rw, rw} |
| // combination 15/16 |
| case i0 && i1 && i2 && !i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| http.CloseNotifier |
| http.Hijacker |
| }{rw, rw, rw, rw, rw} |
| // combination 16/16 |
| case i0 && i1 && i2 && i3: |
| return struct { |
| Unwrapper |
| http.ResponseWriter |
| http.Flusher |
| http.CloseNotifier |
| http.Hijacker |
| io.ReaderFrom |
| }{rw, rw, rw, rw, rw, rw} |
| } |
| panic("unreachable") |
| } |
| |
| type rw struct { |
| w http.ResponseWriter |
| h Hooks |
| } |
| |
| func (w *rw) Unwrap() http.ResponseWriter { |
| return w.w |
| } |
| |
| func (w *rw) Header() http.Header { |
| f := w.w.(http.ResponseWriter).Header |
| if w.h.Header != nil { |
| f = w.h.Header(f) |
| } |
| return f() |
| } |
| |
| func (w *rw) WriteHeader(code int) { |
| f := w.w.(http.ResponseWriter).WriteHeader |
| if w.h.WriteHeader != nil { |
| f = w.h.WriteHeader(f) |
| } |
| f(code) |
| } |
| |
| func (w *rw) Write(b []byte) (int, error) { |
| f := w.w.(http.ResponseWriter).Write |
| if w.h.Write != nil { |
| f = w.h.Write(f) |
| } |
| return f(b) |
| } |
| |
| func (w *rw) Flush() { |
| f := w.w.(http.Flusher).Flush |
| if w.h.Flush != nil { |
| f = w.h.Flush(f) |
| } |
| f() |
| } |
| |
| func (w *rw) CloseNotify() <-chan bool { |
| f := w.w.(http.CloseNotifier).CloseNotify |
| if w.h.CloseNotify != nil { |
| f = w.h.CloseNotify(f) |
| } |
| return f() |
| } |
| |
| func (w *rw) Hijack() (net.Conn, *bufio.ReadWriter, error) { |
| f := w.w.(http.Hijacker).Hijack |
| if w.h.Hijack != nil { |
| f = w.h.Hijack(f) |
| } |
| return f() |
| } |
| |
| func (w *rw) ReadFrom(src io.Reader) (int64, error) { |
| f := w.w.(io.ReaderFrom).ReadFrom |
| if w.h.ReadFrom != nil { |
| f = w.h.ReadFrom(f) |
| } |
| return f(src) |
| } |
| |
| type Unwrapper interface { |
| Unwrap() http.ResponseWriter |
| } |
| |
| // Unwrap returns the underlying http.ResponseWriter from within zero or more |
| // layers of httpsnoop wrappers. |
| func Unwrap(w http.ResponseWriter) http.ResponseWriter { |
| if rw, ok := w.(Unwrapper); ok { |
| // recurse until rw.Unwrap() returns a non-Unwrapper |
| return Unwrap(rw.Unwrap()) |
| } else { |
| return w |
| } |
| } |