mirror of
https://github.com/yusing/godoxy.git
synced 2025-06-09 13:02:33 +02:00
allow agent without docker connected
This commit is contained in:
parent
b7e9a85be0
commit
5f1b78ec84
1 changed files with 7 additions and 2 deletions
|
@ -12,10 +12,15 @@ import (
|
||||||
"github.com/yusing/go-proxy/internal/net/types"
|
"github.com/yusing/go-proxy/internal/net/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func serviceUnavailable(w http.ResponseWriter, r *http.Request) {
|
||||||
|
http.Error(w, "docker socket is not available", http.StatusServiceUnavailable)
|
||||||
|
}
|
||||||
|
|
||||||
func DockerSocketHandler() http.HandlerFunc {
|
func DockerSocketHandler() http.HandlerFunc {
|
||||||
dockerClient, err := docker.ConnectClient(common.DockerHostFromEnv)
|
dockerClient, err := docker.NewClient(common.DockerHostFromEnv)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logging.Fatal().Err(err).Msg("failed to connect to docker client")
|
logging.Warn().Err(err).Msg("failed to connect to docker client")
|
||||||
|
return serviceUnavailable
|
||||||
}
|
}
|
||||||
rp := reverseproxy.NewReverseProxy("docker", types.NewURL(&url.URL{
|
rp := reverseproxy.NewReverseProxy("docker", types.NewURL(&url.URL{
|
||||||
Scheme: "http",
|
Scheme: "http",
|
||||||
|
|
Loading…
Add table
Reference in a new issue