Method ImageTag

agent/app/service/image.go:401–442

(req dto.ImageTag)

}

func (u *ImageService) ImageTag(req dto.ImageTag) error {
	client, err := docker.NewDockerClient()
	if err != nil {
		return err
	}
	defer client.Close()

	imageItem, err := client.ImageInspect(context.Background(), req.SourceID)
	if err != nil {
		return err
	}

	for _, tag := range req.Tags {
		isNew := true
		for _, tagOld := range imageItem.RepoTags {
			if tag == tagOld {
				isNew = false
				break
			}
		}
		if isNew {
			if err := client.ImageTag(context.TODO(), req.SourceID, tag); err != nil {
				return err
			}
		}
	}
	for _, tagOld := range imageItem.RepoTags {
		isDel := true
		for _, tag := range req.Tags {
			if tag == tagOld {
				isDel = false
				break
			}
		}
		if isDel {
			if _, err := client.ImageRemove(context.TODO(), tagOld, image.RemoveOptions{}); err != nil {
				return err
			}
		}
	}
	return nil
}

func (u *ImageService) ImagePush(req dto.ImagePush) error {
	client, err := docker.NewDockerClient()