使用 Go 操作远程 Docker 仓库

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《使用 Go 操作远程 Docker 仓库》，聊聊，希望可以帮助到正在努力赚钱的你。

我需要使用 go 和协议 v2 访问私有 docker 注册表。我需要在私有注册表中列出存储库，获取它们的所有标签和其他信息。我应该使用 docker/distribution/registry/client 吗？有此类任务的示例吗？我找不到...官方网站只提供http api文档。

我写了一些代码：

registry, err := client.NewRegistry("https://registry-1.docker.io/", http.DefaultTransport)
    if err != nil {
        log.Error("Error creating the registry: {}", err)
        return
    }

    ctx := context.Background()

    entries := make([]string, 5)

    numFilled, err := registry.Repositories(ctx, entries, "")
    if err != io.EOF {
        log.Error("Error getting the registry: {}", err)
        return
    }

    log.Info("Number of repositories: {}", numFilled)

    _ = registry

当然，docker repo 需要身份验证。但我该如何提供呢？有这样的任务的文档吗？

解决方案

改编自源码包中的测试代码：

import (
    "github.com/docker/distribution/registry/client"
    "github.com/docker/distribution/registry/client/auth"
    "github.com/docker/distribution/registry/client/auth/challenge"
    "github.com/docker/distribution/registry/client/transport"
)
    
type regCredentialStore struct {
    username      string
    password      string
    refreshTokens map[string]string
}

func (tcs *regCredentialStore) Basic(*url.URL) (string, string) {
    return tcs.username, tcs.password
}

func (tcs *regCredentialStore) RefreshToken(u *url.URL, service string) string {
    return tcs.refreshTokens[service]
}

func (tcs *regCredentialStore) SetRefreshToken(u *url.URL, service string, token string) {
    if tcs.refreshTokens != nil {
        tcs.refreshTokens[service] = token
    }
}

func main() {
    creds := &regCredentialStore{username: "user", password: "pwd"}
    challengeManager := challenge.NewSimpleManager()
    _, err = ping(challengeManager, "https://registry-1.docker.io/v2/", "")
    if err != nil {
        .... exit .....
    }
    transport1 := transport.NewTransport(
        nil, auth.NewAuthorizer(challengeManager, auth.NewBasicHandler(creds)))
    reg, err := client.NewRegistry("https://registry-1.docker.io/", transport1)
    ...
}   

func ping(manager challenge.Manager, endpoint, versionHeader string) ([]auth.APIVersion, error) {
    resp, err := http.Get(endpoint)
    if err != nil {
        return nil, err
    }
    defer resp.Body.Close()

    if err := manager.AddResponse(resp); err != nil {
        return nil, err
    }

    return auth.APIVersions(resp, versionHeader), err
}

本篇关于《使用 Go 操作远程 Docker 仓库》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！