(ctx context.Context, rep repo.DirectRepository)
| 39 | } |
| 40 | |
| 41 | func (c *commandIndexInspect) run(ctx context.Context, rep repo.DirectRepository) error { |
| 42 | output := make(chan indexBlobPlusContentInfo) |
| 43 | |
| 44 | var wg sync.WaitGroup |
| 45 | |
| 46 | wg.Go(func() { |
| 47 | c.dumpIndexBlobEntries(output) |
| 48 | }) |
| 49 | |
| 50 | err := c.runWithOutput(ctx, rep, output) |
| 51 | close(output) |
| 52 | wg.Wait() |
| 53 | |
| 54 | return err |
| 55 | } |
| 56 | |
| 57 | func (c *commandIndexInspect) runWithOutput(ctx context.Context, rep repo.DirectRepository, output chan indexBlobPlusContentInfo) error { |
| 58 | switch { |
nothing calls this directly
no test coverage detected