rebase from stream connection

Signed-off-by: SungJin1212 <[email protected]>

Author: SungJin1212

pkg/cortexpb/cortex.pb.go

@@ -29,14 +29,12 @@ message StreamWriteRequest {
 message WriteResponse {
   int32 code = 1;
   string message = 2;
-}
-message WriteResponse {
   // Samples represents X-Prometheus-Remote-Write-Written-Samples
-  int64 Samples = 1;
+  int64 Samples = 3;
   // Histograms represents X-Prometheus-Remote-Write-Written-Histograms
-  int64 Histograms = 2;
+  int64 Histograms = 4;
   // Exemplars represents X-Prometheus-Remote-Write-Written-Exemplars
-  int64 Exemplars = 3;
+  int64 Exemplars = 5;
 }
 
 message TimeSeries {

pkg/cortexpb/cortex.proto

@@ -1156,13 +1156,14 @@ func (d *Distributor) send(ctx context.Context, ingester ring.InstanceDesc, time
 	d.inflightClientRequests.Inc()
 	defer d.inflightClientRequests.Dec()
 
+	var resp *cortexpb.WriteResponse
 	if d.cfg.UseStreamPush {
 		req := &cortexpb.WriteRequest{
 			Timeseries: timeseries,
 			Metadata:   metadata,
 			Source:     source,
 		}
-		_, err = c.PushStreamConnection(ctx, req)
+		resp, err = c.PushStreamConnection(ctx, req)
 	} else {
 		req := cortexpb.PreallocWriteRequestFromPool()
 		req.Timeseries = timeseries