rebase from stream connection

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

Author: SungJin1212

pkg/cortexpb/cortex.proto

@@ -43,14 +43,6 @@ message WriteResponse {
   // Exemplars represents X-Prometheus-Remote-Write-Written-Exemplars
   int64 Exemplars = 5;
 }
-message WriteResponse {
-  // Samples represents X-Prometheus-Remote-Write-Written-Samples
-  int64 Samples = 1;
-  // Histograms represents X-Prometheus-Remote-Write-Written-Histograms
-  int64 Histograms = 2;
-  // Exemplars represents X-Prometheus-Remote-Write-Written-Exemplars
-  int64 Exemplars = 3;
-}
 
 message TimeSeries {
   repeated LabelPair labels = 1 [(gogoproto.nullable) = false, (gogoproto.customtype) = "LabelAdapter"];

pkg/distributor/distributor.go

@@ -1195,13 +1195,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