kubernetes/vendor/github.com/gorilla/websocket/compression.go

const minCompressionLevel …

const maxCompressionLevel …

const defaultCompressionLevel …

var flateWriterPools …

var flateReaderPool …

func decompressNoContextTakeover(r io.Reader) io.ReadCloser { … }

func isValidCompressionLevel(level int) bool { … }

func compressNoContextTakeover(w io.WriteCloser, level int) io.WriteCloser { … }

type truncWriter …

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

type flateWriteWrapper …

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

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

type flateReadWrapper …

func (r *flateReadWrapper) Read(p []byte) (int, error) { … }

func (r *flateReadWrapper) Close() error { … }