docker - 使用 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图像列表时，我看不到拉取并保存到本地注册表中的指定图像。

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

那么我错过了什么？

Answer 1

我最初建议打印 PullImage 返回的事件以查看导致问题的错误。后来@SercioSoydanov 在其中一条评论中提到:

if you don't consume the reader until it's depleted, the Image Pull operation gets interrupted before it can finish

所以我编辑了我的答案，使它更有意义。当返回 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
}