Function Remove

pkg/cmd/image/remove.go:36–203

Remove removes a list of `images`.

(ctx context.Context, client *containerd.Client, args []string, options types.ImageRemoveOptions)

// Remove removes a list of `images`.
func Remove(ctx context.Context, client *containerd.Client, args []string, options types.ImageRemoveOptions) error {
	var delOpts []images.DeleteOpt
	if !options.Async {
		delOpts = append(delOpts, images.SynchronousDelete())
	}

	cs := client.ContentStore()
	is := client.ImageService()
	containerList, err := client.Containers(ctx)
	if err != nil {
		return err
	}
	usedImages := make(map[string]string)
	runningImages := make(map[string]string)
	for _, container := range containerList {
		image, err := container.Image(ctx)
		if err != nil {
			continue
		}

		// if err != nil, simply go to `default`
		switch cStatus, _ := containerutil.ContainerStatus(ctx, container); cStatus.Status {
		case containerd.Running, containerd.Pausing, containerd.Paused:
			runningImages[image.Name()] = container.ID()
		default:
			usedImages[image.Name()] = container.ID()
		}
	}

	walker := &imagewalker.ImageWalker{
		Client: client,
		OnFound: func(ctx context.Context, found imagewalker.Found) error {
			if found.NameMatchIndex == -1 {
				// if found multiple images, return error unless in force-mode and
				// there is only 1 unique image.
				if found.MatchCount > 1 && !(options.Force && found.UniqueImages == 1) {
					return fmt.Errorf("multiple IDs found with provided prefix: %s", found.Req)
				}
			} else if found.NameMatchIndex != found.MatchIndex {
				// when there is an image with a name matching the argument but the argument is a digest short id,
				// the deletion process is not performed.
				return nil
			}

			if cid, ok := runningImages[found.Image.Name]; ok {
				if options.Force {
					// This is a running image, so, we need to keep a ref on it so that containerd does not GC the layers
					// First create the new image with an empty name
					originalName := found.Image.Name
					found.Image.Name = ":"
					if _, err = is.Create(ctx, found.Image); err != nil {
						return err
					}

					// Now, delete the original
					if err = is.Delete(ctx, originalName, delOpts...); err != nil {
						return err
					}