Function Decode

util/compression/compression.go:93–122

Decode returns the decoded form of src for the given compression type. The buf allows passing various buffer implementations that make decoding more efficient. See NewSyncDecodeBuffer and NewConcurrentDecodeBuffer for further details. For non-zstd compression types, it is valid to pass nil buf. De

(t Type, src []byte, buf DecodeBuffer)

// Decode is concurrency-safe, however note the concurrency limits for the
// buffer of your choice.
func Decode(t Type, src []byte, buf DecodeBuffer) (ret []byte, err error) {
	if len(src) == 0 || t == "" || t == None {
		return src, nil
	}
	if t == Snappy {
		var b []byte
		if buf != nil {
			b = buf.get()
			defer func() {
				buf.set(ret)
			}()
		}
		// The snappy library uses `len` to calculate if we need a new buffer.
		// In order to allocate as few buffers as possible make the length
		// equal to the capacity.
		b = b[:cap(b)]
		return snappy.Decode(b, src)
	}
	if t == Zstd {
		if buf == nil {
			return nil, errors.New("zstd requested but DecodeBuffer was not provided")
		}
		b := buf.get()
		defer func() {
			buf.set(ret)
		}()
		return buf.zstdDecBuf().DecodeAll(src, b[:0])
	}
	return nil, fmt.Errorf("unsupported compression type: %s", t)
}