使用 golang 将 docker 镜像拉取到本地注册表

Question

我正在尝试构建一个自动化工具来使用 golang 拉取 docker 镜像。

这是脚本的简化版本：

package dockermgr

import (
    "context"


    "github.com/docker/docker/api/types"
    "github.com/docker/docker/client"
)


func getClient() (*client.Client, error) {

    return client.NewClientWithOpts(client.FromEnv)
}

func ImagePull(image models.DockerImage) error {
    // TODO: Is docker daemon running?
    cli, err := getClient()

    if err != nil {
        panic(err)
    }

    defer cli.Close()

    reader, err := cli.ImagePull(
        context.Background(),
        image.GetNameAndTag(),
        types.ImagePullOptions{})

    if err != nil {
        panic(err)
    }

    defer reader.Close()

    return err

}

它显然拉取了图像，但是当我返回终端并执行

docker image list

时，我看不到指定的图像被拉取并保存到本地注册表中。

我想知道它是否调用了它自己的 docker 守护进程而不是使用本地的。但似乎并非如此。如果我尝试暂停本地 docker 守护进程，它会在我执行此操作时重新唤醒。

那我错过了什么？

Answer 1

我最初建议打印

PullImage

返回的事件以查看导致问题的错误。后来@SercioSoydanov 在其中一条评论中提到：

如果您在读卡器耗尽之前不使用它，Image Pull 操作会在它完成之前被中断

所以我编辑了我的答案以使其更有意义。当

ImagePull

返回时，并不意味着图像被拉出（这不是很好，因为至少函数名称和文档没有显示）。所以问题中原始实现的问题是它存在得太早了。一个明显的解决方案是坚持阅读@SercioSoydanov 在评论中提到的所有事件。但是由于实现预期的行为与消耗这些事件无关，我添加了另一个实现，它更复杂但在逻辑上更有意义（只是为了作为一个答案）。

程序会一直停留，直到图像被实际拉出。

func getClient() (*client.Client, error) {
    return client.NewClientWithOpts(client.FromEnv)
}

func main() {
    ImagePull()
}

func ImagePull() error {
    cli, err := getClient()

    if err != nil {
        panic(err)
    }

    defer cli.Close()

    events, err := cli.ImagePull(
        context.Background(),
        "busybox:1.35",
        types.ImagePullOptions{},
    )

    if err != nil {
        panic(err)
    }
    defer events.Close()

    wg := sync.WaitGroup{}
    wg.Add(1)
    go func(wg *sync.WaitGroup) {
        time.Sleep(1 * time.Second)
        list, err := cli.ImageList(context.Background(), types.ImageListOptions{})
        if err != nil {
            panic(err)
        }
        for _, ims := range list {
            for _, tag := range ims.RepoTags {
                if strings.HasPrefix(tag, "busybox:1.35") {
                    wg.Done()
                }
            }
        }
    }(&wg)
    wg.Wait()
    return nil
}