zstd

package
v0.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 1, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package zstd implements Zstandard compression.

Index

Constants

View Source
const Code = 4
View Source
const DefaultCompressionLevel = 3

Variables

This section is empty.

Functions

This section is empty.

Types

type CompressionCodec

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

func NewCompressionCodec

func NewCompressionCodec() *CompressionCodec

func NewCompressionCodecWith

func NewCompressionCodecWith(level int) *CompressionCodec

func (*CompressionCodec) Code

func (c *CompressionCodec) Code() int8

Code implements the kafka.CompressionCodec interface.

func (*CompressionCodec) Name added in v0.4.3

func (c *CompressionCodec) Name() string

Name implements the kafka.CompressionCodec interface.

func (*CompressionCodec) NewReader added in v0.4.3

func (c *CompressionCodec) NewReader(r io.Reader) io.ReadCloser

NewReader implements the kafka.CompressionCodec interface.

func (*CompressionCodec) NewWriter added in v0.4.3

func (c *CompressionCodec) NewWriter(w io.Writer) io.WriteCloser

NewWriter implements the kafka.CompressionCodec interface.

Jump to

Keyboard shortcuts

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