compressor

Documentation

Index

• Variables
• type Compressor
• type Factory
  • func NewFactory() *Factory
  • func (f *Factory) Create(kind string) (Compressor, error)
  • func (f *Factory) Register(kind string, c Compressor)
• type None
  • func NewNone() *None
  • func (c *None) Compress(src []byte) []byte
  • func (c *None) Decompress(src []byte) ([]byte, error)
• type Snappy
  • func NewSnappy() *Snappy
  • func (c *Snappy) Compress(src []byte) []byte
  • func (c *Snappy) Decompress(src []byte) ([]byte, error)

Variables

var ErrInvalidKind = errors.New("invalid kind")

ErrInvalidKind for compressor.

var Module = fx.Options(
	fx.Provide(NewSnappy),
	fx.Provide(NewFactory),
)

Module for fx.

Types

type Compressor

type Compressor interface {
	Compress(src []byte) []byte
	Decompress(src []byte) ([]byte, error)
}

Compressor allows to have different ways to compress/decompress.

type Factory

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

Factory of compressor.

func NewFactory

func NewFactory() *Factory

NewFactory for compressor.

func (*Factory) Create

func (f *Factory) Create(kind string) (Compressor, error)

Create from kind.

func (*Factory) Register

func (f *Factory) Register(kind string, c Compressor)

Register kind and compressor.

type None

type None struct{}

None for compressor.

func NewNone

func NewNone() *None

NewNone compressor.

func (*None) Compress

func (c *None) Compress(src []byte) []byte

func (*None) Decompress

func (c *None) Decompress(src []byte) ([]byte, error)

type Snappy

type Snappy struct{}

Snappy for compressor.

func NewSnappy

func NewSnappy() *Snappy

NewSnappy compressor.

func (*Snappy) Compress

func (c *Snappy) Compress(src []byte) []byte

func (*Snappy) Decompress

func (c *Snappy) Decompress(src []byte) ([]byte, error)