compressor

Documentation

Index

• Constants
• Variables
• func IsSupportedCompressor(compressor string) bool
• type Compressor
  • func Get(c Type) (Compressor, error)
• type GzipCompressor
  • func NewGzipCompressor() *GzipCompressor
  • func (c *GzipCompressor) Decode(src []byte) ([]byte, error)
  • func (c *GzipCompressor) Encode(src []byte) ([]byte, error)
• type LzoCompressor
  • func NewLzoCompressor() *LzoCompressor
  • func (c *LzoCompressor) Decode(src []byte) ([]byte, error)
  • func (c *LzoCompressor) Encode(src []byte) ([]byte, error)
• type NoneCompressor
  • func NewNoneCompressor() *NoneCompressor
  • func (c *NoneCompressor) Decode(src []byte) ([]byte, error)
  • func (c *NoneCompressor) Encode(src []byte) ([]byte, error)
• type SnappyCompressor
  • func NewSnappyCompressor() *SnappyCompressor
  • func (c *SnappyCompressor) Decode(src []byte) ([]byte, error)
  • func (c *SnappyCompressor) Encode(src []byte) ([]byte, error)
• type Type
  • func AvailableCompressors() []Type
• type ZstdCompressor
  • func NewZstdCompressor() *ZstdCompressor
  • func (c *ZstdCompressor) Decode(src []byte) ([]byte, error)
  • func (c *ZstdCompressor) Encode(src []byte) ([]byte, error)

Constants

const (
	None   Type = "none"
	Snappy      = "snappy"
	Gzip        = "gzip"
	Lzo         = "lzo"
	Zstd        = "zstd"
)

Variables

var GetExtensionFileByCompressor = map[Type]string{
	None:   "",
	Snappy: ".snappy",
	Gzip:   ".gz",
	Lzo:    ".lzo",
	Zstd:   ".zst",
}

Functions

func IsSupportedCompressor

func IsSupportedCompressor(compressor string) bool

Types

type Compressor

type Compressor interface {
	Encode(src []byte) ([]byte, error)
	Decode(str []byte) ([]byte, error)
}

func Get

func Get(c Type) (Compressor, error)

type GzipCompressor

type GzipCompressor struct {
}

func NewGzipCompressor

func NewGzipCompressor() *GzipCompressor

func (*GzipCompressor) Decode

func (c *GzipCompressor) Decode(src []byte) ([]byte, error)

func (*GzipCompressor) Encode

func (c *GzipCompressor) Encode(src []byte) ([]byte, error)

type LzoCompressor

type LzoCompressor struct {
}

func NewLzoCompressor

func NewLzoCompressor() *LzoCompressor

func (*LzoCompressor) Decode

func (c *LzoCompressor) Decode(src []byte) ([]byte, error)

func (*LzoCompressor) Encode

func (c *LzoCompressor) Encode(src []byte) ([]byte, error)

type NoneCompressor

type NoneCompressor struct {
}

NoneCompressor do nothing

func NewNoneCompressor

func NewNoneCompressor() *NoneCompressor

func (*NoneCompressor) Decode

func (c *NoneCompressor) Decode(src []byte) ([]byte, error)

Decode do nothing: output is equal to input

func (*NoneCompressor) Encode

func (c *NoneCompressor) Encode(src []byte) ([]byte, error)

Encode do nothing: output is equal to input

type SnappyCompressor

type SnappyCompressor struct {
}

func NewSnappyCompressor

func NewSnappyCompressor() *SnappyCompressor

func (*SnappyCompressor) Decode

func (c *SnappyCompressor) Decode(src []byte) ([]byte, error)

func (*SnappyCompressor) Encode

func (c *SnappyCompressor) Encode(src []byte) ([]byte, error)

type Type

type Type string

func AvailableCompressors

func AvailableCompressors() []Type

type ZstdCompressor

type ZstdCompressor struct {
}

func NewZstdCompressor

func NewZstdCompressor() *ZstdCompressor

func (*ZstdCompressor) Decode

func (c *ZstdCompressor) Decode(src []byte) ([]byte, error)

func (*ZstdCompressor) Encode

func (c *ZstdCompressor) Encode(src []byte) ([]byte, error)