Function Encode

util/compression/compression.go:48–83

Encode returns the encoded form of src for the given compression type. For None or empty message the encoding is not attempted. The buf allows passing various buffer implementations that make encoding more efficient. See NewSyncEncodeBuffer and NewConcurrentEncodeBuffer for further details. For non

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

// Encode is concurrency-safe, however note the concurrency limits for the
// buffer of your choice.
func Encode(t Type, src []byte, buf EncodeBuffer) (ret []byte, err error) {
	if len(src) == 0 || t == "" || t == None {
		return src, nil
	}
	if t == Snappy {
		// If MaxEncodedLen is less than 0 the record is too large to be compressed.
		if snappy.MaxEncodedLen(len(src)) < 0 {
			return src, fmt.Errorf("compression: Snappy can't encode such a large message: %v", len(src))
		}
		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.Encode(b, src), nil
	}
	if t == Zstd {
		if buf == nil {
			return nil, errors.New("zstd requested but EncodeBuffer was not provided")
		}
		b := buf.get()
		defer func() {
			buf.set(ret)
		}()

		return buf.zstdEncBuf().EncodeAll(src, b[:0]), nil
	}
	return nil, fmt.Errorf("unsupported compression type: %s", t)
}

// Decode returns the decoded form of src for the given compression type.
//