go/src/internal/zstd/zstd.go

var fuzzing …

type Reader …

// NewReader creates a new Reader that decompresses data from the given reader.
func NewReader(input io.Reader) *Reader { … }

// Reset discards the current state and starts reading a new stream from r.
// This permits reusing a Reader rather than allocating a new one.
func (r *Reader) Reset(input io.Reader) { … }

// Read implements [io.Reader].
func (r *Reader) Read(p []byte) (int, error) { … }

// ReadByte implements [io.ByteReader].
func (r *Reader) ReadByte() (byte, error) { … }

// refillIfNeeded reads the next block if necessary.
func (r *Reader) refillIfNeeded() error { … }

// refill reads and decompresses the next block.
func (r *Reader) refill() error { … }

// readFrameHeader reads the frame header and prepares to read a block.
func (r *Reader) readFrameHeader() error { … }

// skipFrame skips a skippable frame. RFC 3.1.2.
func (r *Reader) skipFrame() error { … }

// readBlock reads the next block from a frame.
func (r *Reader) readBlock() error { … }

// setBufferSize sets the decompressed buffer size.
// When this is called the buffer is empty.
func (r *Reader) setBufferSize(size int) { … }

type zstdError …

func (ze *zstdError) Error() string { … }

func (ze *zstdError) Unwrap() error { … }

func (r *Reader) makeEOFError(off int) error { … }

func (r *Reader) wrapNonEOFError(off int, err error) error { … }

func (r *Reader) makeError(off int, msg string) error { … }

func (r *Reader) wrapError(off int, err error) error { … }