Signed-off-by: Guillaume Tardif <guillaume.tardif@gmail.com>
This commit is contained in:
Guillaume Tardif 2020-12-03 15:47:19 +01:00
parent 44b4bc01af
commit 56511a4a3a

View File

@ -267,17 +267,17 @@ func (s *composeService) removeContainers(ctx context.Context, w progress.Writer
if err != nil { if err != nil {
return err return err
} }
for _, c := range containers { for _, container := range containers {
eg.Go(func() error { eg.Go(func() error {
eventName := "Container " + getContainerName(c) eventName := "Container " + getContainerName(container)
w.Event(progress.StoppingEvent(eventName)) w.Event(progress.StoppingEvent(eventName))
err := s.apiClient.ContainerStop(ctx, c.ID, nil) err := s.apiClient.ContainerStop(ctx, container.ID, nil)
if err != nil { if err != nil {
w.Event(progress.ErrorMessageEvent(eventName, "Error while Stopping")) w.Event(progress.ErrorMessageEvent(eventName, "Error while Stopping"))
return err return err
} }
w.Event(progress.RemovingEvent(eventName)) w.Event(progress.RemovingEvent(eventName))
err = s.apiClient.ContainerRemove(ctx, c.ID, moby.ContainerRemoveOptions{}) err = s.apiClient.ContainerRemove(ctx, container.ID, moby.ContainerRemoveOptions{})
if err != nil { if err != nil {
w.Event(progress.ErrorMessageEvent(eventName, "Error while Removing")) w.Event(progress.ErrorMessageEvent(eventName, "Error while Removing"))
return err return err
@ -290,7 +290,7 @@ func (s *composeService) removeContainers(ctx context.Context, w progress.Writer
} }
func (s *composeService) projectFromContainerLabels(ctx context.Context, projectName string) (*types.Project, error) { func (s *composeService) projectFromContainerLabels(ctx context.Context, projectName string) (*types.Project, error) {
cnts, err := s.apiClient.ContainerList(ctx, moby.ContainerListOptions{ containers, err := s.apiClient.ContainerList(ctx, moby.ContainerListOptions{
Filters: filters.NewArgs( Filters: filters.NewArgs(
projectFilter(projectName), projectFilter(projectName),
), ),
@ -298,10 +298,10 @@ func (s *composeService) projectFromContainerLabels(ctx context.Context, project
if err != nil { if err != nil {
return nil, err return nil, err
} }
if len(cnts) == 0 { if len(containers) == 0 {
return nil, nil return nil, nil
} }
options, err := loadProjectOptionsFromLabels(cnts[0]) options, err := loadProjectOptionsFromLabels(containers[0])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -309,9 +309,9 @@ func (s *composeService) projectFromContainerLabels(ctx context.Context, project
fakeProject := &types.Project{ fakeProject := &types.Project{
Name: projectName, Name: projectName,
} }
for _, c := range cnts { for _, container := range containers {
fakeProject.Services = append(fakeProject.Services, types.ServiceConfig{ fakeProject.Services = append(fakeProject.Services, types.ServiceConfig{
Name: c.Labels[serviceLabel], Name: container.Labels[serviceLabel],
}) })
} }
return fakeProject, nil return fakeProject, nil