in internal/file_cleaner/file_cleaner.go [226:248]
func (c *FileCleaner) removeFiles(ctx context.Context, toRemoveFunc func(string) bool) error {
walkFunc := func(path string, d fs.DirEntry, err error) error {
select {
case <-ctx.Done():
return ctx.Err()
default:
if toRemoveFunc(path) {
if err := c.removeFunc(path); err != nil {
return err
}
}
return nil
}
}
if err := filepath.WalkDir(c.IndexDir, walkFunc); err != nil {
return err
}
return nil
}