kubernetes/vendor/go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp/wrap.go

var _ …

type bodyWrapper …

func (w *bodyWrapper) Read(b []byte) (int, error) { … }

func (w *bodyWrapper) Close() error { … }

var _ …

type respWriterWrapper …

func (w *respWriterWrapper) Header() http.Header { … }

func (w *respWriterWrapper) Write(p []byte) (int, error) { … }

// WriteHeader persists initial statusCode for span attribution.
// All calls to WriteHeader will be propagated to the underlying ResponseWriter
// and will persist the statusCode from the first call.
// Blocking consecutive calls to WriteHeader alters expected behavior and will
// remove warning logs from net/http where developers will notice incorrect handler implementations.
func (w *respWriterWrapper) WriteHeader(statusCode int) { … }

func (w *respWriterWrapper) Flush() { … }