Get back copying.

Signed-off-by: Bartlomiej Plotka <[email protected]>

Author: bwplotka

pkg/store/multitsdb.go

@@ -139,11 +139,19 @@ func (s *tenantSeriesSetServer) Send(r *storepb.SeriesResponse) error {
 		s.directCh.send(r)
 		return nil
 	}
+
+	// TODO(bwplotka): Consider avoid copying / learn why it has to copied.
+	chunks := make([]storepb.AggrChunk, len(series.Chunks))
+	copy(chunks, series.Chunks)
+
 	// For series, pass it to our AggChunkSeriesSet.
 	select {
 	case <-s.ctx.Done():
 		return s.ctx.Err()
-	case s.recv <- series:
+	case s.recv <- &storepb.Series{
+		Labels: series.Labels,
+		Chunks: chunks,
+	}:
 		return nil
 	}
 }

pkg/store/proxy.go

@@ -195,7 +195,7 @@ func newCancellableRespChannel(ctx context.Context, buffer int) (*cancellableRes
 	return &cancellableRespSender{ctx: ctx, ch: respCh}, respCh
 }
 
-// send or returns on cancel.
+// send or return on cancel.
 func (s cancellableRespSender) send(r *storepb.SeriesResponse) {
 	select {
 	case <-s.ctx.Done():