func benchmarkWrite(ctx context.Context, b *testing.B, fileSize int64, newFS func() FileService) {
 // ...
 var n atomic.Int64
 b.RunParallel(func(pb *testing.PB) {
 for pb.Next() {
 // Each operation creates a new, unique file.
 filePath := fmt.Sprintf("benchmark_write_%d_%d_%d", fileSize, b.N, n.Add(1))
 vector := IOVector{
 FilePath: filePath,
 Entries: []IOEntry{{Data: data, Size: fileSize}},
 }
 err := fs.Write(ctx, vector)
 // ...
 }
 })
}

func benchmarkWrite(ctx context.Context, b *testing.B, fileSize int64, newFS func() FileService) {
 // ...
 // Scenario 1: Create new files (as before)
 b.Run("create new", func(b *testing.B) {
 // ... existing parallel write logic ...
 })
 // Scenario 2: Overwrite existing files
 b.Run("overwrite", func(b *testing.B) {
 // Pre-create a pool of files
 // In parallel, repeatedly write to files from the pool
 // This may require a Delete-then-Write pattern
 })
}

 var n atomic.Int64
+var filePaths []string
+var filePathsMutex sync.Mutex
+
 b.RunParallel(func(pb *testing.PB) {
 	for pb.Next() {
-		filePath := fmt.Sprintf("benchmark_write_%d_%d_%d", fileSize, b.N, n.Add(1))
+		filePath := fmt.Sprintf("benchmark_write_%d_%d", fileSize, n.Add(1))
 
 		vector := IOVector{
 			FilePath: filePath,
 			Entries: []IOEntry{
 				{
 					Size: fileSize,
 					Data: data,
 				},
 			},
 		}
 
 		err := fs.Write(ctx, vector)
 		if err != nil {
 			b.Fatal(err)
 		}
 
+		filePathsMutex.Lock()
+		filePaths = append(filePaths, filePath)
+		filePathsMutex.Unlock()
 	}
 })
 
+b.StopTimer()
+err := fs.Delete(ctx, filePaths...)
+if err != nil {
+	b.Logf("failed to delete files: %v", err)
+}
+

-filePath := fmt.Sprintf("benchmark_write_%d_%d_%d", fileSize, b.N, n.Add(1))
+filePath := fmt.Sprintf("benchmark_write_%d_%d", fileSize, n.Add(1))