Kuwongolera zotengera za Docker mu Go

Zolemba!

Mukasankha kulemba njinga yanu kuti mugwire mbedza kuchokera pa docker kapena kuchokera ku registry kuti musinthe / kuyendetsa zotengera pa seva, mutha kupeza Docker Cli yothandiza, yomwe ingakuthandizeni kuyang'anira daemon ya Docker pakompyuta yanu.

Kuti mugwire ntchito muyenera Go mtundu wosachepera 1.9.4

Ngati simunasinthebe kukhala ma module, ikani Cli ndi lamulo ili:

go get github.com/docker/docker/client

Kuyendetsa chidebe

Chitsanzo chotsatirachi chikuwonetsa momwe mungayendetsere chidebe pogwiritsa ntchito Docker API. Pa mzere wolamula mungagwiritse ntchito lamulo docker run, koma tingapirire mosavuta ntchito imeneyi muutumiki wathu.
Chitsanzo ichi ndi chofanana ndi kuyendetsa lamulo docker run alpine echo hello world

package main {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Делаем docker pull
    reader, err := cli.ImagePull(ctx, "docker.io/library/alpine", types.ImagePullOptions{})
    if err != nil {
        panic(err)
    }
    io.Copy(os.Stdout, reader)

    hostBinding := nat.PortBinding{
        HostIP:   "0.0.0.0",
        HostPort: "8000",
    }
    containerPort, err := nat.NewPort("tcp", "80")
    if err != nil {
        panic("Unable to get the port")
    }
    portBinding := nat.PortMap{containerPort: []nat.PortBinding{hostBinding}}

    // Создаем контейнер с заданной конфигурацией
    resp, err := cli.ContainerCreate(ctx, &container.Config{
        Image: "alpine",
        Cmd:   []string{"echo", "hello world"},
        Tty:   true,
    }, &container.HostConfig{
        PortBindings: portBinding,
    }, nil, "")
    if err != nil {
        panic(err)
    }

    // Запускаем контейнер
    if err := cli.ContainerStart(ctx, resp.ID, types.ContainerStartOptions{}); err != nil {
        panic(err)
    }

    // Получаем логи контейнера
    out, err := cli.ContainerLogs(ctx, resp.ID, types.ContainerLogsOptions{ShowStdout: true})
    if err != nil {
        panic(err)
    }
    io.Copy(os.Stdout, out)
}

Kupeza mndandanda wa zotengera zomwe zikuyenda

Chitsanzo ichi ndi chofanana ndi kuyendetsa lamulo docker ps

package main

import (
    "context"
    "fmt"

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

func main() {
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Получение списка запуцщенных контейнеров(docker ps)
    containers, err := cli.ContainerList(context.Background(), types.ContainerListOptions{})
    if err != nil {
        panic(err)
    }

    // Вывод всех идентификаторов контейнеров
    for _, container := range containers {
        fmt.Println(container.ID)
    }
}

Kuyimitsa zotengera zonse zothamanga

Mutaphunzira kupanga ndi kuyendetsa zotengera, ndi nthawi yoti mudziwe momwe mungasamalire. Chitsanzo chotsatirachi chidzayimitsa zotengera zonse zomwe zikuyenda.

Osayendetsa khodi iyi pa seva yopanga!

package main

import (
    "context"
    "fmt"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Получение списка запуцщенных контейнеров(docker ps)
    containers, err := cli.ContainerList(ctx, types.ContainerListOptions{})
    if err != nil {
        panic(err)
    }

    for _, c := range containers {
        fmt.Print("Stopping container ", c.ID[:10], "... ")
        if err := cli.ContainerStop(ctx, c.ID, nil); err != nil {
            panic(err)
        }
        fmt.Println("Success")
    }
}

Kuwonetsa zipika za chidebe chimodzi

Mutha kugwira ntchito ndi zotengera zamunthu. Chitsanzo chotsatirachi chikuwonetsa zipika zokhala ndi zozindikiritsa zomwe zatchulidwa. Musanayambe, muyenera kusintha ID ya chidebe amene zipika mukufuna kulandira.

package main

import (
    "context"
    "io"
    "os"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    options := types.ContainerLogsOptions{ShowStdout: true}
    // Измените id контейнера здесь
    out, err := cli.ContainerLogs(ctx, "f1064a8a4c82", options)
    if err != nil {
        panic(err)
    }
    io.Copy(os.Stdout, out)
}

Kupeza mndandanda wazithunzi

Chitsanzo ichi ndi chofanana ndi kuyendetsa lamulo docker image ls

package main

import (
    "context"
    "fmt"

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

func main() {
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Получение списка образов
    images, err := cli.ImageList(context.Background(), types.ImageListOptions{})
    if err != nil {
        panic(err)
    }

    for _, image := range images {
        fmt.Println(image.ID)
    }
}

Kokani

Chitsanzo ichi ndi chofanana ndi kuyendetsa lamulo docker pull

package main

import (
    "context"
    "io"
    "os"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // docker pull alpine
    out, err := cli.ImagePull(ctx, "docker.io/library/alpine", types.ImagePullOptions{})
    if err != nil {
        panic(err)
    }
    defer out.Close()
    io.Copy(os.Stdout, out)
}

Kutsitsa chithunzi ndi kutsimikizika kwa ogwiritsa ntchito

Chitsanzo ichi ndi chofanana ndi kuyendetsa lamulo docker pull, ndi kutsimikizika.

Deta yotsimikizira imatumizidwa m'mawu omveka bwino. Registry yovomerezeka ya docker imagwiritsa ntchito HTTPS,
zolembera zapadera ziyeneranso kukonzedwa kuti zisamutse deta pogwiritsa ntchito HTTPS.

package main

import (
    "context"
    "encoding/base64"
    "encoding/json"
    "io"
    "os"

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

func main() {
    ctx := context.Background()
    cli, err := client.NewEnvClient()
    if err != nil {
        panic(err)
    }

    // Создание конфига с данными для аутентификации
    authConfig := types.AuthConfig{
        Username: "username",
        Password: "password",
    }
    encodedJSON, err := json.Marshal(authConfig)
    if err != nil {
        panic(err)
    }
    authStr := base64.URLEncoding.EncodeToString(encodedJSON)

    out, err := cli.ImagePull(ctx, "docker.io/library/alpine", types.ImagePullOptions{RegistryAuth: authStr})
    if err != nil {
        panic(err)
    }

    defer out.Close()
    io.Copy(os.Stdout, out)
}

Source: www.habr.com