compressions

Apr 21, 2024

Changes in this version

+ var ErrIsBusy = errors.New("the system is busy for compression")

+ func CalculatePoolSize() int

+ func CanIgnore(err error) bool

+ func GenerateCompressLevel(minLevel int, maxLevel int) (level int)

+ func IsBusy() bool

type BaseReader

+ func (this *BaseReader) IncreaseHit() uint32

type BaseWriter

+ func (this *BaseWriter) IncreaseHit() uint32

type Reader

+ IncreaseHit func() uint32

type Writer

+ IncreaseHit func() uint32

Jan 21, 2024

Changes in this version

+ func SupportEncoding(encoding string) bool

+ func WrapHTTPResponse(resp *http.Response)

Jul 17, 2022

Changes in this version

type ContentEncoding

+ const ContentEncodingZSTD

type Reader

+ func NewZSTDReader(reader io.Reader) (Reader, error)

type Writer

+ func NewZSTDWriter(writer io.Writer, level int) (Writer, error)

+ type ZSTDReader struct

+ func (this *ZSTDReader) Close() error

+ func (this *ZSTDReader) RawClose() error

+ func (this *ZSTDReader) Read(p []byte) (n int, err error)

+ func (this *ZSTDReader) Reset(reader io.Reader) error

+ type ZSTDWriter struct

+ func (this *ZSTDWriter) Close() error

+ func (this *ZSTDWriter) Flush() error

+ func (this *ZSTDWriter) Level() int

+ func (this *ZSTDWriter) RawClose() error

+ func (this *ZSTDWriter) Reset(writer io.Writer)

+ func (this *ZSTDWriter) Write(p []byte) (int, error)

Jun 20, 2022

Changes in this version

+ var ErrNotSupportedContentEncoding = errors.New("not supported content encoding")

+ type BaseReader struct

+ func (this *BaseReader) Finish(obj Reader) error

+ func (this *BaseReader) ResetFinish()

+ func (this *BaseReader) SetPool(pool *ReaderPool)

+ type BaseWriter struct

+ func (this *BaseWriter) Finish(obj Writer) error

+ func (this *BaseWriter) ResetFinish()

+ func (this *BaseWriter) SetPool(pool *WriterPool)

+ type BrotliReader struct

+ func (this *BrotliReader) Close() error

+ func (this *BrotliReader) RawClose() error

+ func (this *BrotliReader) Read(p []byte) (n int, err error)

+ func (this *BrotliReader) Reset(reader io.Reader) error

+ type BrotliWriter struct

+ func (this *BrotliWriter) Close() error

+ func (this *BrotliWriter) Flush() error

+ func (this *BrotliWriter) Level() int

+ func (this *BrotliWriter) RawClose() error

+ func (this *BrotliWriter) Reset(newWriter io.Writer)

+ func (this *BrotliWriter) Write(p []byte) (int, error)

+ type ContentEncoding = string

+ const ContentEncodingBr

+ const ContentEncodingDeflate

+ const ContentEncodingGzip

+ func AllEncodings() []ContentEncoding

+ type DeflateReader struct

+ func (this *DeflateReader) Close() error

+ func (this *DeflateReader) RawClose() error

+ func (this *DeflateReader) Read(p []byte) (n int, err error)

+ func (this *DeflateReader) Reset(reader io.Reader) error

+ type DeflateWriter struct

+ func (this *DeflateWriter) Close() error

+ func (this *DeflateWriter) Flush() error

+ func (this *DeflateWriter) Level() int

+ func (this *DeflateWriter) RawClose() error

+ func (this *DeflateWriter) Reset(writer io.Writer)

+ func (this *DeflateWriter) Write(p []byte) (int, error)

+ type GzipReader struct

+ func (this *GzipReader) Close() error

+ func (this *GzipReader) RawClose() error

+ func (this *GzipReader) Read(p []byte) (n int, err error)

+ func (this *GzipReader) Reset(reader io.Reader) error

+ type GzipWriter struct

+ func (this *GzipWriter) Close() error

+ func (this *GzipWriter) Flush() error

+ func (this *GzipWriter) Level() int

+ func (this *GzipWriter) RawClose() error

+ func (this *GzipWriter) Reset(writer io.Writer)

+ func (this *GzipWriter) Write(p []byte) (int, error)

+ type Reader interface

+ Close func() error

+ RawClose func() error

+ Read func(p []byte) (n int, err error)

+ Reset func(reader io.Reader) error

+ ResetFinish func()

+ SetPool func(pool *ReaderPool)

+ func NewBrotliReader(reader io.Reader) (Reader, error)

+ func NewDeflateReader(reader io.Reader) (Reader, error)

+ func NewGzipReader(reader io.Reader) (Reader, error)

+ func NewReader(reader io.Reader, contentEncoding ContentEncoding) (Reader, error)

+ type ReaderPool struct

+ func NewReaderPool(maxSize int, newFunc func(reader io.Reader) (Reader, error)) *ReaderPool

+ func (this *ReaderPool) Get(parentReader io.Reader) (Reader, error)

+ func (this *ReaderPool) Put(reader Reader)

+ type Writer interface

+ Close func() error

+ Flush func() error

+ Level func() int

+ RawClose func() error

+ Reset func(writer io.Writer)

+ ResetFinish func()

+ SetPool func(pool *WriterPool)

+ Write func(p []byte) (int, error)

+ func NewBrotliWriter(writer io.Writer, level int) (Writer, error)

+ func NewDeflateWriter(writer io.Writer, level int) (Writer, error)

+ func NewGzipWriter(writer io.Writer, level int) (Writer, error)

+ func NewWriter(writer io.Writer, compressType serverconfigs.HTTPCompressionType, level int) (Writer, error)

+ type WriterPool struct

+ func NewWriterPool(maxSize int, maxLevel int, ...) *WriterPool

+ func (this *WriterPool) Get(parentWriter io.Writer, level int) (Writer, error)

+ func (this *WriterPool) Put(writer Writer)