Documentation ¶
Index ¶
Constants ¶
View Source
const ( GZIP_TYPE = "gzip" ZLIB_TYPE = "zlib" DEFLATE_TYPE = "deflate" SNAPPY_TYPE = "snappy" ZSTD_TYPE = "zstd" )
Variables ¶
View Source
var (
ErrUnknownCompressionType = errors.New("unknown-compression-type")
)
Functions ¶
Types ¶
type Compressor ¶
type Compressor[I, O []byte] struct { // contains filtered or unexported fields }
Compressor is a generic task capable of compress a []byte into zstd or gzip.
func NewCompressor ¶
func NewCompressor[T, K []byte](compressionType string, logger *slog.Logger) *Compressor[T, K]
Creates a new Compressor task.
type Decompressor ¶
type Decompressor[T, K []byte] struct { // contains filtered or unexported fields }
Decompressor is a generic task capable of decompress []byte compressed with ZSTD or GZIP
func NewDecompressor ¶
func NewDecompressor[I, O []byte](compressionType string, logger *slog.Logger) *Decompressor[I, O]
Click to show internal directories.
Click to hide internal directories.