Kiam vi decidas skribi vian biciklon por kapti hokojn de la docker-nabo aŭ de la registro por aŭtomate ĝisdatigi/komenci ujojn sur la servilo, Docker Cli povas esti utila por helpi administri la Docker-demonon en via sistemo.
Por funkcii, vi bezonas Go-version almenaŭ 1.9.4
Se vi ankoraŭ ne ŝanĝis al moduloj, instalu Cli per la sekva komando:
go get github.com/docker/docker/client
Kurante ujon
La sekva ekzemplo montras kiel ruli ujon uzante la Docker API. Sur la komandlinio, vi uzus la komandon docker run
, sed ni povas facile trakti ĉi tiun taskon en nia servo.
Ĉi tiu ekzemplo estas ekvivalenta al rulado de la komando 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)
}
Akirante liston de kurantaj ujoj
Ĉi tiu ekzemplo estas ekvivalenta al rulado de la komando 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)
}
}
Ĉesu ĉiujn kurantajn ujojn
Nun kiam vi lernis kiel krei kaj ruli ujojn, estas tempo lerni kiel administri ilin. La sekva ekzemplo ĉesos ĉiujn kurantajn ujojn.
Ne rulu ĉi tiun kodon sur produktadservilo!
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")
}
}
Eligi protokolojn de ununura ujo
Vi povas labori kun individuaj ujoj. La sekva ekzemplo eligas la protokolojn de la ujo kun la specifita ID. Antaŭ ol komenci, vi devas ŝanĝi la ID de la ujo, kies protokolojn vi volas ricevi.
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)
}
Akirante liston de bildoj
Ĉi tiu ekzemplo estas ekvivalenta al rulado de la komando 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)
}
}
tiri
Ĉi tiu ekzemplo estas ekvivalenta al rulado de la komando 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)
}
Elŝutante bildon kun uzanta aŭtentigo
Ĉi tiu ekzemplo estas ekvivalenta al rulado de la komando docker pull
, kun aŭtentigo.
Aŭtentikigdatenoj estas senditaj en klara teksto. La oficialaj docker-registroj uzas HTTPS,
privataj registroj ankaŭ devas esti agorditaj por komuniki per 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)
}
fonto: www.habr.com