mirror of
https://github.com/yusing/godoxy.git
synced 2025-05-20 12:42:34 +02:00
57292f0fe8
* feat: idle sleep for proxmox LXCs * refactor: replace deprecated docker api types * chore(api): remove debug task list endpoint * refactor: move servemux to gphttp/servemux; favicon.go to v1/favicon * refactor: introduce Pool interface, move agent_pool to agent module * refactor: simplify api code * feat: introduce debug api * refactor: remove net.URL and net.CIDR types, improved unmarshal handling * chore: update Makefile for debug build tag, update README * chore: add gperr.Unwrap method * feat: relative time and duration formatting * chore: add ROOT_DIR environment variable, refactor * migration: move homepage override and icon cache to $BASE_DIR/data, add migration code * fix: nil dereference on marshalling service health * fix: wait for route deletion * chore: enhance tasks debuggability * feat: stdout access logger and MultiWriter * fix(agent): remove agent properly on verify error * fix(metrics): disk exclusion logic and added corresponding tests * chore: update schema and prettify, fix package.json and Makefile * fix: I/O buffer not being shrunk before putting back to pool * feat: enhanced error handling module * chore: deps upgrade * feat: better value formatting and handling --------- Co-authored-by: yusing <yusing@6uo.me>
58 lines
1.7 KiB
Go
58 lines
1.7 KiB
Go
package monitor
|
|
|
|
import (
|
|
"github.com/docker/docker/api/types/container"
|
|
"github.com/yusing/go-proxy/internal/docker"
|
|
|
|
"github.com/yusing/go-proxy/internal/watcher/health"
|
|
)
|
|
|
|
type DockerHealthMonitor struct {
|
|
*monitor
|
|
client *docker.SharedClient
|
|
containerID string
|
|
fallback health.HealthChecker
|
|
}
|
|
|
|
func NewDockerHealthMonitor(client *docker.SharedClient, containerID, alias string, config *health.HealthCheckConfig, fallback health.HealthChecker) *DockerHealthMonitor {
|
|
mon := new(DockerHealthMonitor)
|
|
mon.client = client
|
|
mon.containerID = containerID
|
|
mon.monitor = newMonitor(fallback.URL(), config, mon.CheckHealth)
|
|
mon.fallback = fallback
|
|
mon.service = alias
|
|
return mon
|
|
}
|
|
|
|
func (mon *DockerHealthMonitor) CheckHealth() (result *health.HealthCheckResult, err error) {
|
|
ctx, cancel := mon.ContextWithTimeout("docker health check timed out")
|
|
defer cancel()
|
|
cont, err := mon.client.ContainerInspect(ctx, mon.containerID)
|
|
if err != nil {
|
|
return mon.fallback.CheckHealth()
|
|
}
|
|
status := cont.State.Status
|
|
switch status {
|
|
case "dead", "exited", "paused", "restarting", "removing":
|
|
return &health.HealthCheckResult{
|
|
Healthy: false,
|
|
Detail: "container is " + status,
|
|
}, nil
|
|
case "created":
|
|
return &health.HealthCheckResult{
|
|
Healthy: false,
|
|
Detail: "container is not started",
|
|
}, nil
|
|
}
|
|
if cont.State.Health == nil {
|
|
return mon.fallback.CheckHealth()
|
|
}
|
|
result = new(health.HealthCheckResult)
|
|
result.Healthy = cont.State.Health.Status == container.Healthy
|
|
if len(cont.State.Health.Log) > 0 {
|
|
lastLog := cont.State.Health.Log[len(cont.State.Health.Log)-1]
|
|
result.Detail = lastLog.Output
|
|
result.Latency = lastLog.End.Sub(lastLog.Start)
|
|
}
|
|
return
|
|
}
|