compress

Documentation

Index

• Constants
• func GetGzipReader(r io.Reader) (*gzip.Reader, error)
• func GetGzipWriter(w io.Writer) (io.Writer, func())
• func GetLz4Writer(w io.Writer) (io.Writer, func())
• func GetSnappyBlockWriter(w io.Writer) (io.Writer, func())
• func GetSnappyWriter(w io.Writer) (io.Writer, func())
• func GetZstdWriter(w io.Writer) (io.Writer, func())
• func GorillaDecoding(in []byte, out []byte) ([]byte, error)
• func GorillaEncoding(in []byte, out []byte) ([]byte, error)
• func Init()
• func IsEnableMLF() bool
• func PutGzipReader(zr *gzip.Reader)
• func SnappyDecoding(in, out []byte) ([]byte, error)
• func SnappyEncoding(in []byte, out []byte) ([]byte, error)
• type Context
  • func GenerateContext(values []float64) *Context
  • func (ctx *Context) NotCompress() bool
  • func (ctx *Context) RLE() bool
  • func (ctx *Context) Release()
  • func (ctx *Context) Same() bool
  • func (ctx *Context) Snappy() bool
• type Float
  • func NewFloat() *Float
  • func (c *Float) AdaptiveDecoding(in, out []byte) ([]byte, error)
  • func (c *Float) AdaptiveEncoding(in []byte, out []byte) ([]byte, error)
• type RLE
  • func NewRLE(step int) *RLE
  • func (rle *RLE) Decoding(in, out []byte) ([]byte, error)
  • func (rle *RLE) Encoding(in []byte, out []byte) ([]byte, error)
  • func (rle *RLE) SameValueDecoding(in, out []byte) ([]byte, error)
  • func (rle *RLE) SameValueEncoding(in []byte, out []byte) ([]byte, error)
• type SnappyBlockWriter
  • func NewSnappyBlockWriter(w io.Writer) *SnappyBlockWriter
  • func (w *SnappyBlockWriter) Close() error
  • func (w *SnappyBlockWriter) Reset(writer io.Writer)
  • func (w *SnappyBlockWriter) Write(b []byte) (int, error)

Constants

const FloatCompressAlgorithmMLF = "mlf"

const (
	RLEBlockLimit = 1 << 14
)

Functions

func GetGzipReader

func GetGzipReader(r io.Reader) (*gzip.Reader, error)

func GetGzipWriter

func GetGzipWriter(w io.Writer) (io.Writer, func())

func GetLz4Writer

func GetLz4Writer(w io.Writer) (io.Writer, func())

func GetSnappyBlockWriter

func GetSnappyBlockWriter(w io.Writer) (io.Writer, func())

func GetSnappyWriter

func GetSnappyWriter(w io.Writer) (io.Writer, func())

func GetZstdWriter

func GetZstdWriter(w io.Writer) (io.Writer, func())

func GorillaDecoding

func GorillaDecoding(in []byte, out []byte) ([]byte, error)

func GorillaEncoding

func GorillaEncoding(in []byte, out []byte) ([]byte, error)

func Init

func Init()

func IsEnableMLF

func IsEnableMLF() bool

func PutGzipReader

func PutGzipReader(zr *gzip.Reader)

PutGzipReader returns back gzip reader obtained via GetGzipReader.

func SnappyDecoding

func SnappyDecoding(in, out []byte) ([]byte, error)

func SnappyEncoding

func SnappyEncoding(in []byte, out []byte) ([]byte, error)

Types

type Context

type Context struct {
	// contains filtered or unexported fields
}

func GenerateContext

func GenerateContext(values []float64) *Context

func (*Context) NotCompress

func (ctx *Context) NotCompress() bool

func (*Context) RLE

func (ctx *Context) RLE() bool

func (*Context) Release

func (ctx *Context) Release()

func (*Context) Same

func (ctx *Context) Same() bool

func (*Context) Snappy

func (ctx *Context) Snappy() bool

type Float

type Float struct {
	// contains filtered or unexported fields
}

func NewFloat

func NewFloat() *Float

func (*Float) AdaptiveDecoding

func (c *Float) AdaptiveDecoding(in, out []byte) ([]byte, error)

func (*Float) AdaptiveEncoding

func (c *Float) AdaptiveEncoding(in []byte, out []byte) ([]byte, error)

type RLE

type RLE struct {
	// contains filtered or unexported fields
}

func NewRLE

func NewRLE(step int) *RLE

func (*RLE) Decoding

func (rle *RLE) Decoding(in, out []byte) ([]byte, error)

func (*RLE) Encoding

func (rle *RLE) Encoding(in []byte, out []byte) ([]byte, error)

func (*RLE) SameValueDecoding

func (rle *RLE) SameValueDecoding(in, out []byte) ([]byte, error)

func (*RLE) SameValueEncoding

func (rle *RLE) SameValueEncoding(in []byte, out []byte) ([]byte, error)

type SnappyBlockWriter

type SnappyBlockWriter struct {
	// contains filtered or unexported fields
}

func NewSnappyBlockWriter

func NewSnappyBlockWriter(w io.Writer) *SnappyBlockWriter

func (*SnappyBlockWriter) Close

func (w *SnappyBlockWriter) Close() error

func (*SnappyBlockWriter) Reset

func (w *SnappyBlockWriter) Reset(writer io.Writer)

func (*SnappyBlockWriter) Write

func (w *SnappyBlockWriter) Write(b []byte) (int, error)