compress

package

v1.4.0 Latest Latest Go to latest Published: Apr 12, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/openGemini/openGemini

Links

Documentation ¶

Index ¶

Constants
func GetGzipReader(r io.Reader) (*gzip.Reader, error)
func GetGzipWriter(w io.Writer) *gzip.Writer
func GetLz4Writer(w io.Writer) *lz4.Writer
func GetSnappyReader(r io.Reader) *snappy.Reader
func GetSnappyWriter(w io.Writer) *snappy.Writer
func GetZstdReader(r io.Reader) *zstd.Decoder
func GetZstdWriter(w io.Writer) *zstd.Encoder
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 PutGzipWriter(gz *gzip.Writer)
func PutLz4Writer(lz4Writer *lz4.Writer)
func PutSnappyReader(snappyReader *snappy.Reader)
func PutSnappyWriter(snappyWriter *snappy.Writer)
func PutZstdReader(zstdDecoder *zstd.Decoder)
func PutZstdWriter(zstdEncoder *zstd.Encoder)
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)

Constants ¶

View Source

const FloatCompressAlgorithmMLF = "mlf"

View Source

const (
	RLEBlockLimit = 1 << 14
)

Variables ¶

This section is empty.

Functions ¶

func GetGzipReader ¶ added in v1.4.0

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

func GetGzipWriter ¶ added in v1.4.0

func GetGzipWriter(w io.Writer) *gzip.Writer

func GetLz4Writer ¶ added in v1.4.0

func GetLz4Writer(w io.Writer) *lz4.Writer

func GetSnappyReader ¶ added in v1.4.0

func GetSnappyReader(r io.Reader) *snappy.Reader

func GetSnappyWriter ¶ added in v1.4.0

func GetSnappyWriter(w io.Writer) *snappy.Writer

func GetZstdReader ¶ added in v1.4.0

func GetZstdReader(r io.Reader) *zstd.Decoder

func GetZstdWriter ¶ added in v1.4.0

func GetZstdWriter(w io.Writer) *zstd.Encoder

func GorillaDecoding ¶

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

func GorillaEncoding ¶

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

func Init ¶ added in v1.3.0

func Init()

func IsEnableMLF ¶ added in v1.3.0

func IsEnableMLF() bool

func PutGzipReader ¶ added in v1.4.0

func PutGzipReader(zr *gzip.Reader)

PutGzipReader returns back gzip reader obtained via GetGzipReader.

func PutGzipWriter ¶ added in v1.4.0

func PutGzipWriter(gz *gzip.Writer)

func PutLz4Writer ¶ added in v1.4.0

func PutLz4Writer(lz4Writer *lz4.Writer)

func PutSnappyReader ¶ added in v1.4.0

func PutSnappyReader(snappyReader *snappy.Reader)

func PutSnappyWriter ¶ added in v1.4.0

func PutSnappyWriter(snappyWriter *snappy.Writer)

func PutZstdReader ¶ added in v1.4.0

func PutZstdReader(zstdDecoder *zstd.Decoder)

func PutZstdWriter ¶ added in v1.4.0

func PutZstdWriter(zstdEncoder *zstd.Encoder)

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)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mlf

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL