Method ImageRemove

agent/app/service/image.go:499–540

(req dto.BatchDelete)

}

func (u *ImageService) ImageRemove(req dto.BatchDelete) error {
	client, err := docker.NewDockerClient()
	if err != nil {
		return err
	}
	defer client.Close()
	taskItem, err := task.NewTaskWithOps(strings.Join(req.Names, ","), task.TaskDelete, task.TaskScopeImage, req.TaskID, 1)
	if err != nil {
		global.LOG.Errorf("new task for create container failed, err: %v", err)
		return err
	}

	for _, id := range req.Names {
		taskItem.AddSubTask(i18n.GetMsgByKey("TaskDelete")+id, func(t *task.Task) error {
			imageItem, err := client.ImageInspect(context.TODO(), id)
			if err != nil {
				return err
			}
			if _, err := client.ImageRemove(context.TODO(), id, image.RemoveOptions{Force: req.Force, PruneChildren: true}); err != nil {
				if strings.Contains(err.Error(), "image is being used") || strings.Contains(err.Error(), "is using") {
					if strings.Contains(id, "sha256:") {
						return buserr.New("ErrObjectInUsed")
					}
					return buserr.WithDetail("ErrInUsed", id, nil)
				}
				if strings.Contains(err.Error(), "image has dependent") {
					return buserr.New("ErrObjectBeDependent")
				}
				return err
			}
			taskItem.Log(i18n.GetMsgWithMap("ImageRemoveHelper", map[string]interface{}{"name": id, "size": common.LoadSizeUnit2F(float64(imageItem.Size))}))
			return nil
		}, nil)
	}
	if len(req.TaskID) == 0 {
		return taskItem.Execute()
	}
	go func() {
		_ = taskItem.Execute()
	}()
	return nil
}

func checkUsed(imageID string, containers []container.Summary) bool {
	for _, container := range containers {