mirror of
https://github.com/yusing/godoxy.git
synced 2025-05-20 12:42:34 +02:00
80bc018a7f
* chore: replace gopkg.in/yaml.v3 vs goccy/go-yaml; replace encoding/json with bytedance/sonic * fix: yaml unmarshal panic * feat: custom json marshaler implementation * chore: fix import and err marshal handling --------- Co-authored-by: yusing <yusing@6uo.me>
57 lines
1.3 KiB
Go
57 lines
1.3 KiB
Go
package dockerapi
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"sort"
|
|
|
|
"github.com/yusing/go-proxy/pkg/json"
|
|
|
|
dockerSystem "github.com/docker/docker/api/types/system"
|
|
"github.com/yusing/go-proxy/internal/gperr"
|
|
"github.com/yusing/go-proxy/internal/utils/strutils"
|
|
)
|
|
|
|
type dockerInfo dockerSystem.Info
|
|
|
|
func (d *dockerInfo) MarshalJSONTo(buf []byte) []byte {
|
|
return json.MarshalTo(map[string]any{
|
|
"name": d.Name,
|
|
"version": d.ServerVersion,
|
|
"containers": map[string]int{
|
|
"total": d.Containers,
|
|
"running": d.ContainersRunning,
|
|
"paused": d.ContainersPaused,
|
|
"stopped": d.ContainersStopped,
|
|
},
|
|
"images": d.Images,
|
|
"n_cpu": d.NCPU,
|
|
"memory": strutils.FormatByteSize(d.MemTotal),
|
|
}, buf)
|
|
}
|
|
|
|
func DockerInfo(w http.ResponseWriter, r *http.Request) {
|
|
serveHTTP[dockerInfo](w, r, GetDockerInfo)
|
|
}
|
|
|
|
func GetDockerInfo(ctx context.Context, dockerClients DockerClients) ([]dockerInfo, gperr.Error) {
|
|
errs := gperr.NewBuilder("failed to get docker info")
|
|
dockerInfos := make([]dockerInfo, len(dockerClients))
|
|
|
|
i := 0
|
|
for name, dockerClient := range dockerClients {
|
|
info, err := dockerClient.Info(ctx)
|
|
if err != nil {
|
|
errs.Add(err)
|
|
continue
|
|
}
|
|
info.Name = name
|
|
dockerInfos[i] = dockerInfo(info)
|
|
i++
|
|
}
|
|
|
|
sort.Slice(dockerInfos, func(i, j int) bool {
|
|
return dockerInfos[i].Name < dockerInfos[j].Name
|
|
})
|
|
return dockerInfos, errs.Error()
|
|
}
|