func encodeWriteRequestIntoProtoAndSnappy()

in sandbox/CWMetricStreamExporter/lambda/main.go [254:264]


func encodeWriteRequestIntoProtoAndSnappy(writeRequest *prompb.WriteRequest) *bytes.Reader {
	data, err := proto.Marshal(writeRequest)

	if err != nil {
		panic(err)
	}

	encoded := snappy.Encode(nil, data)
	body := bytes.NewReader(encoded)
	return body
}