func()

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
}