zstdimpl

Documentation

Overview

Package zstdimpl provides a set of functions for compressing with zstd

Index

• func New(reqs Requires) compression.Compressor
• type Requires
• type ZstdStrategy
  • func (s *ZstdStrategy) Compress(src []byte) ([]byte, error)
  • func (s *ZstdStrategy) CompressBound(sourceLen int) int
  • func (s *ZstdStrategy) ContentEncoding() string
  • func (s *ZstdStrategy) Decompress(src []byte) ([]byte, error)
  • func (s *ZstdStrategy) NewStreamCompressor(output *bytes.Buffer) compression.StreamCompressor

Functions

func New

func New(reqs Requires) compression.Compressor

New returns a new ZstdStrategy

Types

type Requires

type Requires struct {
	Level compression.ZstdCompressionLevel
}

Requires contains the compression level for zstd compression

type ZstdStrategy

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

ZstdStrategy is the strategy for when serializer_compressor_kind is zstd

func (*ZstdStrategy) Compress

func (s *ZstdStrategy) Compress(src []byte) ([]byte, error)

Compress will compress the data with zstd

func (*ZstdStrategy) CompressBound

func (s *ZstdStrategy) CompressBound(sourceLen int) int

CompressBound returns the worst case size needed for a destination buffer when using zstd

func (*ZstdStrategy) ContentEncoding

func (s *ZstdStrategy) ContentEncoding() string

ContentEncoding returns the content encoding value for zstd

func (*ZstdStrategy) Decompress

func (s *ZstdStrategy) Decompress(src []byte) ([]byte, error)

Decompress will decompress the data with zstd

func (*ZstdStrategy) NewStreamCompressor

func (s *ZstdStrategy) NewStreamCompressor(output *bytes.Buffer) compression.StreamCompressor

NewStreamCompressor returns a new zstd Writer