@@ -272,21 +272,23 @@ func TestSectionsForStreamMatchers(t *testing.T) {
272
272
require .NoError (t , err )
273
273
}
274
274
275
- buf := bytes .NewBuffer (make ([]byte , 0 , 1024 * 1024 ))
276
- stats , err := builder .Flush (buf )
275
+ minTime , maxTime := builder .TimeRange ()
276
+
277
+ obj , closer , err := builder .Flush ()
277
278
require .NoError (t , err )
279
+ t .Cleanup (func () { _ = closer .Close () })
278
280
279
281
bucket := objstore .NewInMemBucket ()
280
282
281
283
uploader := uploader .New (uploader.Config {SHAPrefixSize : 2 }, bucket , tenantID , log .NewNopLogger ())
282
284
require .NoError (t , uploader .RegisterMetrics (prometheus .NewPedanticRegistry ()))
283
285
284
- path , err := uploader .Upload (context .Background (), buf )
286
+ path , err := uploader .Upload (context .Background (), obj )
285
287
require .NoError (t , err )
286
288
287
289
metastoreUpdater := NewUpdater (UpdaterConfig {}, bucket , tenantID , log .NewNopLogger ())
288
290
289
- err = metastoreUpdater .Update (context .Background (), path , stats . MinTimestamp , stats . MaxTimestamp )
291
+ err = metastoreUpdater .Update (context .Background (), path , minTime , maxTime )
290
292
require .NoError (t , err )
291
293
292
294
mstore := NewObjectMetastore (bucket , log .NewNopLogger (), prometheus .NewPedanticRegistry ())
0 commit comments