Function decode

pkg/querier/tripperware/query.go:483–513

(buf *bytes.Buffer, encoding string, logger log.Logger)

}

func decode(buf *bytes.Buffer, encoding string, logger log.Logger) ([]byte, error) {
	// if the response is gzipped, lets unzip it here
	if strings.EqualFold(encoding, "gzip") {
		gReader, err := gzip.NewReader(buf)
		if err != nil {
			return nil, err
		}
		defer runutil.CloseWithLogOnErr(logger, gReader, "close gzip reader")

		return io.ReadAll(gReader)
	}

	// if the response is snappy compressed, decode it here
	if strings.EqualFold(encoding, "snappy") {
		sReader := snappy.NewReader(buf)
		return io.ReadAll(sReader)
	}

	// if the response is zstd compressed, decode it here
	if strings.EqualFold(encoding, "zstd") {
		zReader, err := zstd.NewReader(buf)
		if err != nil {
			return nil, err
		}
		defer runutil.CloseWithLogOnErr(logger, zReader.IOReadCloser(), "close zstd decoder")

		return io.ReadAll(zReader)
	}

	return buf.Bytes(), nil
}

// UnmarshalJSON implements json.Unmarshaler.
func (s *PrometheusData) UnmarshalJSON(data []byte) error {