Method kill

pkg/compose/kill.go:35–72

(ctx context.Context, projectName string, options api.KillOptions)

}

func (s *composeService) kill(ctx context.Context, projectName string, options api.KillOptions) error {
	services := options.Services

	var containers Containers
	containers, err := s.getContainers(ctx, projectName, oneOffInclude, options.All, services...)
	if err != nil {
		return err
	}

	project := options.Project
	if project == nil {
		project, err = s.getProjectWithResources(ctx, containers, projectName)
		if err != nil {
			return err
		}
	}

	if !options.RemoveOrphans {
		containers = containers.filter(isService(project.ServiceNames()...))
	}
	if len(containers) == 0 {
		return api.ErrNoResources
	}

	return forEachContainerConcurrent(ctx, containers, func(ctx context.Context, ctr container.Summary) error {
		eventName := getContainerProgressName(ctr)
		s.events.On(newEvent(eventName, api.Working, api.StatusKilling))
		_, err := s.apiClient().ContainerKill(ctx, ctr.ID, client.ContainerKillOptions{
			Signal: options.Signal,
		})
		if err != nil {
			s.events.On(errorEvent(eventName, "Error while Killing"))
			return err
		}
		s.events.On(newEvent(eventName, api.Done, api.StatusKilled))
		return nil
	})
}