(ctx context.Context, containers []containerType.Summary, service *types.ServiceConfig, timeout *time.Duration, volumes bool)
| 334 | } |
| 335 | |
| 336 | func (s *composeService) removeContainers(ctx context.Context, containers []containerType.Summary, service *types.ServiceConfig, timeout *time.Duration, volumes bool) error { |
| 337 | eg, ctx := errgroup.WithContext(ctx) |
| 338 | for _, ctr := range containers { |
| 339 | eg.Go(func() error { |
| 340 | return s.stopAndRemoveContainer(ctx, ctr, service, timeout, volumes) |
| 341 | }) |
| 342 | } |
| 343 | return eg.Wait() |
| 344 | } |
| 345 | |
| 346 | func (s *composeService) stopAndRemoveContainer(ctx context.Context, ctr containerType.Summary, service *types.ServiceConfig, timeout *time.Duration, volumes bool) error { |
| 347 | eventName := getContainerProgressName(ctr) |
no test coverage detected