TyleoDvDelaware3217/GoDoxy
1
0
Fork 0
mirror of https://github.com/yusing/godoxy.git synced 2025-05-20 20:52:33 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

properly close docker client

Browse source
This commit is contained in:
yusing 2024-12-13 12:54:54 +08:00
parent 68b2d79700
commit 51b8806184
2 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
internal/route/http.go
View file

@ -98,6 +98,7 @@ func (r *HTTPRoute) Start(providerSubtask task.Task) E.Error {
if err == nil { if err == nil {
fallback := monitor.NewHTTPHealthChecker(r.rp.TargetURL, r.HealthCheck) fallback := monitor.NewHTTPHealthChecker(r.rp.TargetURL, r.HealthCheck)
r.HealthMon = monitor.NewDockerHealthMonitor(client, r.Idlewatcher.ContainerID, r.HealthCheck, fallback) r.HealthMon = monitor.NewDockerHealthMonitor(client, r.Idlewatcher.ContainerID, r.HealthCheck, fallback)
r.task.OnCancel("close docker client", client.Close)
} }
} }
if r.HealthMon == nil { if r.HealthMon == nil {

1
internal/route/stream.go
View file

@ -73,6 +73,7 @@ func (r *StreamRoute) Start(providerSubtask task.Task) E.Error {
if err == nil { if err == nil {
fallback := monitor.NewRawHealthChecker(r.TargetURL(), r.HealthCheck) fallback := monitor.NewRawHealthChecker(r.TargetURL(), r.HealthCheck)
r.HealthMon = monitor.NewDockerHealthMonitor(client, r.Idlewatcher.ContainerID, r.HealthCheck, fallback) r.HealthMon = monitor.NewDockerHealthMonitor(client, r.Idlewatcher.ContainerID, r.HealthCheck, fallback)
r.task.OnCancel("close docker client", client.Close)
} }
} }
if r.HealthMon == nil { if r.HealthMon == nil {