Go मा डकर कन्टेनरहरू प्रबन्ध गर्दै

कागजात!

जब तपाइँ डकर हबबाट हुकहरू समात्न वा सर्भरमा कन्टेनरहरू स्वचालित रूपमा अद्यावधिक गर्न / चलाउनको लागि रजिस्ट्रीबाट आफ्नै बाइक लेख्ने निर्णय गर्नुहुन्छ, तपाइँले डकर क्ली उपयोगी पाउन सक्नुहुन्छ, जसले तपाइँको प्रणालीमा डकर डेमन व्यवस्थापन गर्न मद्दत गर्दछ।

काम गर्नको लागि तपाईंलाई 1.9.4 भन्दा कम Go संस्करण आवश्यक पर्नेछ

यदि तपाईंले अझै मोड्युलहरूमा स्विच गर्नुभएको छैन भने, निम्न आदेशको साथ Cli स्थापना गर्नुहोस्:

go get github.com/docker/docker/client

कन्टेनर चलाउँदै

निम्न उदाहरणले डकर एपीआई प्रयोग गरेर कन्टेनर कसरी चलाउने भनेर देखाउँछ। आदेश रेखामा तपाईंले आदेश प्रयोग गर्नुहुनेछ 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