🥇Pamamahala ng mga container ng Docker sa Go

Dokumentasyon!

Kapag nagpasya kang magsulat ng iyong sariling bike para sa paghuli ng mga kawit mula sa docker hub o mula sa registry upang awtomatikong i-update/patakbuhin ang mga lalagyan sa server, maaari mong makitang kapaki-pakinabang ang Docker Cli, na makakatulong na pamahalaan ang Docker daemon sa iyong system.

Upang gumana kakailanganin mo ang bersyon ng Go na hindi bababa sa 1.9.4

Kung hindi ka pa rin lumipat sa mga module, i-install ang Cli gamit ang sumusunod na command:

go get github.com/docker/docker/client

Nagpapatakbo ng lalagyan

Ipinapakita ng sumusunod na halimbawa kung paano magpatakbo ng container gamit ang Docker API. Sa command line gagamitin mo ang command docker run, ngunit madali naming makayanan ang gawaing ito sa aming serbisyo.
Ang halimbawang ito ay katumbas ng pagpapatakbo ng command 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)
}

Pagkuha ng listahan ng mga tumatakbong container

Ang halimbawang ito ay katumbas ng pagpapatakbo ng command 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)
    }
}

Pinahinto ang lahat ng tumatakbong lalagyan

Kapag natutunan mo na kung paano gumawa at magpatakbo ng mga container, oras na para matutunan kung paano pamahalaan ang mga ito. Ihihinto ng sumusunod na halimbawa ang lahat ng tumatakbong container.

Huwag patakbuhin ang code na ito sa isang production server!

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")
    }
}

Pagpapakita ng mga log para sa isang lalagyan

Maaari kang magtrabaho sa mga indibidwal na lalagyan. Ang sumusunod na halimbawa ay nagpapakita ng mga log ng container na may tinukoy na identifier. Bago magsimula, kailangan mong baguhin ang ID ng container na ang mga log ay gusto mong matanggap.

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)
}

Pagkuha ng listahan ng mga larawan

Ang halimbawang ito ay katumbas ng pagpapatakbo ng command 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)
    }
}

Hilahin

Ang halimbawang ito ay katumbas ng pagpapatakbo ng command 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)
}

Nagda-download ng larawan na may pagpapatunay ng user

Ang halimbawang ito ay katumbas ng pagpapatakbo ng command docker pull, na may pagpapatunay.

Ang data ng pagpapatunay ay ipinadala sa malinaw na teksto. Ang opisyal na docker registry ay gumagamit ng HTTPS,
Ang mga pribadong rehistro ay dapat ding i-configure upang maglipat ng data gamit ang 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)
}

Pinagmulan: www.habr.com

Pamamahala ng mga container ng Docker sa Go