@@ -207,7 +207,7 @@ func parseRepairAsyncReq(t *testing.T, req *http.Request) repairReq {
207
207
}
208
208
209
209
sched := repairReq {
210
- host : netip .MustParseAddr (req .Host ),
210
+ host : netip .MustParseAddr (req .URL . Hostname () ),
211
211
keyspace : strings .TrimPrefix (req .URL .Path , repairAsyncEndpoint + "/" ),
212
212
table : req .URL .Query ().Get ("columnFamilies" ),
213
213
replicaSet : util2 .ConvertSlice (strings .Split (req .URL .Query ().Get ("hosts" ), "," ), netip .MustParseAddr ),
@@ -237,7 +237,7 @@ func parseTabletRepairReq(t *testing.T, req *http.Request) repairReq {
237
237
}
238
238
239
239
sched := repairReq {
240
- host : netip .MustParseAddr (req .Host ),
240
+ host : netip .MustParseAddr (req .URL . Hostname () ),
241
241
keyspace : req .URL .Query ().Get ("ks" ),
242
242
table : req .URL .Query ().Get ("table" ),
243
243
dcFilter : strings .Split (req .URL .Query ().Get ("dcs_filter" ), "," ),
@@ -270,7 +270,7 @@ func parseRepairAsyncStatusReq(t *testing.T, req *http.Request) repairStatusReq
270
270
}
271
271
272
272
status := repairStatusReq {
273
- host : netip .MustParseAddr (req .Host ),
273
+ host : netip .MustParseAddr (req .URL . Hostname () ),
274
274
id : req .URL .Query ().Get ("id" ),
275
275
}
276
276
if status .id == "" {
@@ -288,7 +288,7 @@ func parseTabletRepairStatusReq(t *testing.T, req *http.Request) repairStatusReq
288
288
}
289
289
290
290
status := repairStatusReq {
291
- host : netip .MustParseAddr (req .Host ),
291
+ host : netip .MustParseAddr (req .URL . Hostname () ),
292
292
id : strings .TrimPrefix (req .URL .Path , waitTaskEndpoint + "/" ),
293
293
}
294
294
if status .id == "" {
0 commit comments