Add writer/handler tests

Signed-off-by: Saswata Mukherjee <[email protected]>
thanos-io · Jan 3, 2025 · e113fd7 · e113fd7
1 parent c2b37b4
commit e113fd7
Show file tree

Hide file tree

Showing 10 changed files with 1,059 additions and 44 deletions.
diff --git a/pkg/receive/handler.go b/pkg/receive/handler.go
@@ -1129,11 +1129,12 @@ func (h *Handler) RemoteWriteV2(ctx context.Context, r *storepb.WriteRequestV2)
 	span, ctx := tracing.StartSpan(ctx, "receive_grpc")
 	defer span.Finish()
 
-	req := tenantWreq{
-		r.Tenant: r.Timeseries,
+	wreq := writev2pb.Request{
+		Timeseries: r.Timeseries,
+		Symbols:    r.Symbols,
 	}
 
-	_, err := h.handleRequestV2(ctx, h.logger, uint64(r.Replica), writev2pb.NewSymbolTableFromSymbols(r.Symbols), req)
+	_, err := h.handleRequestV2(ctx, h.logger, uint64(r.Replica), &wreq, r.Tenant)
 	if err != nil {
 		level.Debug(h.logger).Log("msg", "failed to handle request", "err", err)
 	}