गो मध्ये डॉकर कंटेनर व्यवस्थापित करणे

दस्तऐवजीकरण!

जेव्हा तुम्ही तुमची स्वत:ची बाईक डॉकर हबमधून किंवा सर्व्हरवर कंटेनर स्वयंचलितपणे अपडेट/रन करण्यासाठी रेजिस्ट्रीमधून हुक पकडण्यासाठी लिहिण्याचे ठरवता, तेव्हा तुम्हाला डॉकर क्ली उपयुक्त वाटू शकते, जे तुमच्या सिस्टमवर डॉकर डिमन व्यवस्थापित करण्यात मदत करेल.

कार्य करण्यासाठी तुम्हाला 1.9.4 पेक्षा कमी गो आवृत्तीची आवश्यकता असेल

आपण अद्याप मॉड्यूल्सवर स्विच केले नसल्यास, खालील आदेशासह Cli स्थापित करा:

go get github.com/docker/docker/client

कंटेनर चालवणे

खालील उदाहरण डॉकर API वापरून कंटेनर कसे चालवायचे ते दर्शविते. कमांड लाइनवर तुम्ही कमांड वापराल docker run, परंतु आम्ही आमच्या सेवेमध्ये या कार्याचा सहज सामना करू शकतो.
हे उदाहरण कमांड चालवण्यासारखे आहे 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)
}

चालू असलेल्या कंटेनरची यादी मिळवत आहे

हे उदाहरण कमांड चालवण्यासारखे आहे 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)
    }
}

चालू असलेले सर्व कंटेनर थांबवत आहे

एकदा तुम्ही कंटेनर कसे तयार करायचे आणि चालवायचे हे शिकले की, ते कसे व्यवस्थापित करायचे ते शिकण्याची वेळ आली आहे. खालील उदाहरण सर्व चालू कंटेनर थांबवेल.

हा कोड प्रोडक्शन सर्व्हरवर चालवू नका!

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

एका कंटेनरसाठी लॉग प्रदर्शित करणे

आपण वैयक्तिक कंटेनरसह कार्य करू शकता. खालील उदाहरण निर्दिष्ट अभिज्ञापकासह कंटेनर लॉग प्रदर्शित करते. सुरू करण्यापूर्वी, आपण ज्या कंटेनरचे लॉग प्राप्त करू इच्छिता त्या कंटेनरचा ID बदलणे आवश्यक आहे.

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

प्रतिमांची यादी मिळवत आहे

हे उदाहरण कमांड चालवण्यासारखे आहे 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)
    }
}

खेचणे

हे उदाहरण कमांड चालवण्यासारखे आहे 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)
}

वापरकर्ता प्रमाणीकरणासह प्रतिमा डाउनलोड करत आहे

हे उदाहरण कमांड चालवण्यासारखे आहे docker pull, प्रमाणीकरणासह.

प्रमाणीकरण डेटा स्पष्ट मजकुरात पाठविला जातो. अधिकृत डॉकर रेजिस्ट्री HTTPS वापरते,
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)
}

स्त्रोत: www.habr.com