diff --git a/agent/go.mod b/agent/go.mod index 63f24984..23db85f0 100644 --- a/agent/go.mod +++ b/agent/go.mod @@ -26,7 +26,6 @@ require ( ) require ( - github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c // indirect github.com/Microsoft/go-winio v0.6.2 // indirect github.com/PuerkitoBio/goquery v1.10.3 // indirect github.com/andybalholm/brotli v1.2.0 // indirect @@ -40,7 +39,6 @@ require ( github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect github.com/distribution/reference v0.6.0 // indirect github.com/docker/cli v29.0.0+incompatible // indirect - github.com/docker/docker v28.5.2+incompatible // indirect github.com/docker/go-connections v0.6.0 // indirect github.com/docker/go-units v0.5.0 // indirect github.com/ebitengine/purego v0.9.1 // indirect @@ -66,14 +64,14 @@ require ( github.com/mattn/go-colorable v0.1.14 // indirect github.com/mattn/go-isatty v0.0.20 // indirect github.com/moby/docker-image-spec v1.3.1 // indirect - github.com/moby/sys/sequential v0.6.0 // indirect + github.com/moby/moby/api v1.52.0 // indirect + github.com/moby/moby/client v0.1.0 // indirect github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect github.com/modern-go/reflect2 v1.0.2 // indirect github.com/opencontainers/go-digest v1.0.0 // indirect github.com/opencontainers/image-spec v1.1.1 // indirect github.com/pelletier/go-toml/v2 v2.2.4 // indirect github.com/pires/go-proxyproto v0.8.1 // indirect - github.com/pkg/errors v0.9.1 // indirect github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect github.com/power-devops/perfstat v0.0.0-20240221224432-82ca36839d55 // indirect github.com/quic-go/qpack v0.5.1 // indirect @@ -105,5 +103,4 @@ require ( golang.org/x/text v0.31.0 // indirect google.golang.org/protobuf v1.36.10 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect - gotest.tools/v3 v3.5.2 // indirect ) diff --git a/agent/go.sum b/agent/go.sum index d2340a3e..35c6a308 100644 --- a/agent/go.sum +++ b/agent/go.sum @@ -1,5 +1,3 @@ -github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c h1:udKWzYgxTojEKWjV8V+WSxDXJ4NFATAsZjh8iIbsQIg= -github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c/go.mod h1:xomTg63KZ2rFqZQzSB4Vz2SUXa1BpHTVz9L5PTmPC4E= github.com/Microsoft/go-winio v0.6.2 h1:F2VQgta7ecxGYO8k3ZZz3RS8fVIXVxONVUPlNERoyfY= github.com/Microsoft/go-winio v0.6.2/go.mod h1:yd8OoFMLzJbo9gZq8j5qaps8bJ9aShtEA8Ipt1oGCvU= github.com/PuerkitoBio/goquery v1.10.3 h1:pFYcNSqHxBD06Fpj/KsbStFRsgRATgnf3LeXiUkhzPo= @@ -24,8 +22,6 @@ github.com/containerd/errdefs v1.0.0 h1:tg5yIfIlQIrxYtu9ajqY42W3lpS19XqdxRQeEwYG github.com/containerd/errdefs v1.0.0/go.mod h1:+YBYIdtsnF4Iw6nWZhJcqGSg/dwvV7tyJ/kCkyJ2k+M= github.com/containerd/errdefs/pkg v0.3.0 h1:9IKJ06FvyNlexW690DXuQNx2KA2cUJXx151Xdx3ZPPE= github.com/containerd/errdefs/pkg v0.3.0/go.mod h1:NJw6s9HwNuRhnjJhM7pylWwMyAkmCQvQ4GpJHEqRLVk= -github.com/containerd/log v0.1.0 h1:TCJt7ioM2cr/tfR8GPbGf9/VRAX8D2B4PjzCpfX540I= -github.com/containerd/log v0.1.0/go.mod h1:VRRf09a7mHDIRezVKTRCrOq78v577GXq3bSa3EhrzVo= github.com/coreos/go-oidc/v3 v3.16.0 h1:qRQUCFstKpXwmEjDQTIbyY/5jF00+asXzSkmkoa/mow= github.com/coreos/go-oidc/v3 v3.16.0/go.mod h1:wqPbKFrVnE90vty060SB40FCJ8fTHTxSwyXJqZH+sI8= github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc= @@ -41,8 +37,6 @@ github.com/djherbis/times v1.6.0 h1:w2ctJ92J8fBvWPxugmXIv7Nz7Q3iDMKNx9v5ocVH20c= github.com/djherbis/times v1.6.0/go.mod h1:gOHeRAz2h+VJNZ5Gmc/o7iD9k4wW7NMVqieYCY99oc0= github.com/docker/cli v29.0.0+incompatible h1:KgsN2RUFMNM8wChxryicn4p46BdQWpXOA1XLGBGPGAw= github.com/docker/cli v29.0.0+incompatible/go.mod h1:JLrzqnKDaYBop7H2jaqPtU4hHvMKP+vjCwu2uszcLI8= -github.com/docker/docker v28.5.2+incompatible h1:DBX0Y0zAjZbSrm1uzOkdr1onVghKaftjlSWt4AFexzM= -github.com/docker/docker v28.5.2+incompatible/go.mod h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk= github.com/docker/go-connections v0.6.0 h1:LlMG9azAe1TqfR7sO+NJttz1gy6KO7VJBh+pMmjSD94= github.com/docker/go-connections v0.6.0/go.mod h1:AahvXYshr6JgfUJGdDCs2b5EZG/vmaMAntpSFH5BFKE= github.com/docker/go-units v0.5.0 h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4= @@ -100,8 +94,6 @@ github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aN github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE= github.com/gotify/server/v2 v2.7.3 h1:nro/ZnxdlZFvxFcw9LREGA8zdk6CK744azwhuhX/A4g= github.com/gotify/server/v2 v2.7.3/go.mod h1:VAtE1RIc/2j886PYs9WPQbMjqbFsoyQ0G8IdFtnAxU0= -github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3 h1:NmZ1PKzSTQbuGHw9DGPFomqkkLWMC+vZCkfs+FHv1Vg= -github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3/go.mod h1:zQrxl1YP88HQlA6i9c63DSVPFklWpGX4OWAc9bFuaH4= github.com/jinzhu/copier v0.4.0 h1:w3ciUoD19shMCRargcpm0cm91ytaBhDvuRpz1ODO/U8= github.com/jinzhu/copier v0.4.0/go.mod h1:DfbEm0FYsaqBcKcFuvmOZb218JkPGtvSHsKg8S8hyyg= github.com/json-iterator/go v1.1.13-0.20220915233716-71ac16282d12 h1:9Nu54bhS/H/Kgo2/7xNSUuC5G28VR8ljfrLKU2G4IjU= @@ -135,19 +127,15 @@ github.com/miekg/dns v1.1.68 h1:jsSRkNozw7G/mnmXULynzMNIsgY2dHC8LO6U6Ij2JEA= github.com/miekg/dns v1.1.68/go.mod h1:fujopn7TB3Pu3JM69XaawiU0wqjpL9/8xGop5UrTPps= github.com/moby/docker-image-spec v1.3.1 h1:jMKff3w6PgbfSa69GfNg+zN/XLhfXJGnEx3Nl2EsFP0= github.com/moby/docker-image-spec v1.3.1/go.mod h1:eKmb5VW8vQEh/BAr2yvVNvuiJuY6UIocYsFu/DxxRpo= -github.com/moby/sys/atomicwriter v0.1.0 h1:kw5D/EqkBwsBFi0ss9v1VG3wIkVhzGvLklJ+w3A14Sw= -github.com/moby/sys/atomicwriter v0.1.0/go.mod h1:Ul8oqv2ZMNHOceF643P6FKPXeCmYtlQMvpizfsSoaWs= -github.com/moby/sys/sequential v0.6.0 h1:qrx7XFUd/5DxtqcoH1h438hF5TmOvzC/lspjy7zgvCU= -github.com/moby/sys/sequential v0.6.0/go.mod h1:uyv8EUTrca5PnDsdMGXhZe6CCe8U/UiTWd+lL+7b/Ko= -github.com/moby/term v0.5.2 h1:6qk3FJAFDs6i/q3W/pQ97SX192qKfZgGjCQqfCJkgzQ= -github.com/moby/term v0.5.2/go.mod h1:d3djjFCrjnB+fl8NJux+EJzu0msscUP+f8it8hPkFLc= +github.com/moby/moby/api v1.52.0 h1:00BtlJY4MXkkt84WhUZPRqt5TvPbgig2FZvTbe3igYg= +github.com/moby/moby/api v1.52.0/go.mod h1:8mb+ReTlisw4pS6BRzCMts5M49W5M7bKt1cJy/YbAqc= +github.com/moby/moby/client v0.1.0 h1:nt+hn6O9cyJQqq5UWnFGqsZRTS/JirUqzPjEl0Bdc/8= +github.com/moby/moby/client v0.1.0/go.mod h1:O+/tw5d4a1Ha/ZA/tPxIZJapJRUS6LNZ1wiVRxYHyUE= github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= -github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A= -github.com/morikuni/aec v1.0.0/go.mod h1:BbKIizmSmc5MMPqRYbxO4ZU0S0+P200+tUnFx7PXmsc= github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U= github.com/opencontainers/go-digest v1.0.0/go.mod h1:0JzlMkj0TRzQZfJkVvzbP0HBR3IKzErnv2BNG4W4MAM= github.com/opencontainers/image-spec v1.1.1 h1:y0fUlFfIZhPF1W537XOLg0/fcx6zcHCJwooC2xJA040= @@ -158,7 +146,6 @@ github.com/pelletier/go-toml/v2 v2.2.4 h1:mye9XuhQ6gvn5h28+VilKrrPoQVanw5PMw/TB0 github.com/pelletier/go-toml/v2 v2.2.4/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY= github.com/pires/go-proxyproto v0.8.1 h1:9KEixbdJfhrbtjpz/ZwCdWDD2Xem0NZ38qMYaASJgp0= github.com/pires/go-proxyproto v0.8.1/go.mod h1:ZKAAyp3cgy5Y5Mo4n9AlScrkCZwUy0g3Jf+slqQVcuU= -github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U= @@ -226,10 +213,6 @@ go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.63.0 h1:RbKq8BG go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.63.0/go.mod h1:h06DGIukJOevXaj/xrNjhi/2098RZzcLTbc0jDAUbsg= go.opentelemetry.io/otel v1.38.0 h1:RkfdswUDRimDg0m2Az18RKOsnI8UDzppJAtj01/Ymk8= go.opentelemetry.io/otel v1.38.0/go.mod h1:zcmtmQ1+YmQM9wrNsTGV/q/uyusom3P8RxwExxkZhjM= -go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0 h1:GqRJVj7UmLjCVyVJ3ZFLdPRmhDUp2zFmQe3RHIOsw24= -go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0/go.mod h1:ri3aaHSmCTVYu2AWv44YMauwAQc0aqI9gHKIcSbI1pU= -go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.38.0 h1:aTL7F04bJHUlztTsNGJ2l+6he8c+y/b//eR0jjjemT4= -go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.38.0/go.mod h1:kldtb7jDTeol0l3ewcmd8SDvx3EmIE7lyvqbasU3QC4= go.opentelemetry.io/otel/metric v1.38.0 h1:Kl6lzIYGAh5M159u9NgiRkmoMKjvbsKtYRwgfrA6WpA= go.opentelemetry.io/otel/metric v1.38.0/go.mod h1:kB5n/QoRM8YwmUahxvI3bO34eVtQf2i4utNVLr9gEmI= go.opentelemetry.io/otel/sdk v1.38.0 h1:l48sr5YbNf2hpCUj/FoGhW9yDkl+Ma+LrVl8qaM5b+E= @@ -238,8 +221,6 @@ go.opentelemetry.io/otel/sdk/metric v1.38.0 h1:aSH66iL0aZqo//xXzQLYozmWrXxyFkBJ6 go.opentelemetry.io/otel/sdk/metric v1.38.0/go.mod h1:dg9PBnW9XdQ1Hd6ZnRz689CbtrUp0wMMs9iPcgT9EZA= go.opentelemetry.io/otel/trace v1.38.0 h1:Fxk5bKrDZJUH+AMyyIXGcFAPah0oRcT+LuNtJrmcNLE= go.opentelemetry.io/otel/trace v1.38.0/go.mod h1:j1P9ivuFsTceSWe1oY+EeW3sc+Pp42sO++GHkg4wwhs= -go.opentelemetry.io/proto/otlp v1.9.0 h1:l706jCMITVouPOqEnii2fIAuO3IVGBRPV5ICjceRb/A= -go.opentelemetry.io/proto/otlp v1.9.0/go.mod h1:xE+Cx5E/eEHw+ISFkwPLwCZefwVjY+pqKg1qcK03+/4= go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0= go.uber.org/mock v0.6.0 h1:hyF9dfmbgIX5EfOdasqLsWD6xqpNZlXblLB/Dbnwv3Y= @@ -288,7 +269,6 @@ golang.org/x/sys v0.0.0-20190916202348-b4ddaad3f8a3/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20201204225414-ed752295db88/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20210616094352-59db8d763f22/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= @@ -334,13 +314,6 @@ golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxb golang.org/x/tools v0.39.0 h1:ik4ho21kwuQln40uelmciQPp9SipgNDdrafrYA4TmQQ= golang.org/x/tools v0.39.0/go.mod h1:JnefbkDPyD8UU2kI5fuf8ZX4/yUeh9W877ZeBONxUqQ= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -google.golang.org/genproto v0.0.0-20251111163417-95abcf5c77ba h1:Ze6qXW0j37YCqZdCD2LkzVSxgEWez0cO4NUyd44DiDY= -google.golang.org/genproto/googleapis/api v0.0.0-20251111163417-95abcf5c77ba h1:B14OtaXuMaCQsl2deSvNkyPKIzq3BjfxQp8d00QyWx4= -google.golang.org/genproto/googleapis/api v0.0.0-20251111163417-95abcf5c77ba/go.mod h1:G5IanEx8/PgI9w6CFcYQf7jMtHQhZruvfM1i3qOqk5U= -google.golang.org/genproto/googleapis/rpc v0.0.0-20251111163417-95abcf5c77ba h1:UKgtfRM7Yh93Sya0Fo8ZzhDP4qBckrrxEr2oF5UIVb8= -google.golang.org/genproto/googleapis/rpc v0.0.0-20251111163417-95abcf5c77ba/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk= -google.golang.org/grpc v1.76.0 h1:UnVkv1+uMLYXoIz6o7chp59WfQUYA2ex/BXQ9rHZu7A= -google.golang.org/grpc v1.76.0/go.mod h1:Ju12QI8M6iQJtbcsV+awF5a4hfJMLi4X0JLo94ULZ6c= google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE= google.golang.org/protobuf v1.36.10/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= @@ -351,3 +324,5 @@ gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gotest.tools/v3 v3.5.2 h1:7koQfIKdy+I8UTetycgUqXWSDwpgv193Ka+qRsmBY8Q= gotest.tools/v3 v3.5.2/go.mod h1:LtdLGcnqToBH83WByAAi/wiwSFCArdFIUV/xxN4pcjA= +pgregory.net/rapid v1.2.0 h1:keKAYRcjm+e1F0oAuU5F5+YPAWcyxNNRK2wud503Gnk= +pgregory.net/rapid v1.2.0/go.mod h1:PY5XlDGj0+V1FCq0o192FdRhpKHGTRIWBgqjDBTrq04= diff --git a/go.mod b/go.mod index 879d10ec..551ce55a 100644 --- a/go.mod +++ b/go.mod @@ -15,7 +15,6 @@ replace github.com/yusing/goutils => ./goutils require ( github.com/PuerkitoBio/goquery v1.10.3 // parsing HTML for extract fav icon github.com/coreos/go-oidc/v3 v3.16.0 // oidc authentication - github.com/docker/docker v28.5.2+incompatible // docker daemon github.com/fsnotify/fsnotify v1.9.0 // file watcher github.com/gin-gonic/gin v1.11.0 // api server github.com/go-acme/lego/v4 v4.28.1 // acme client @@ -36,18 +35,24 @@ require ( ) require ( - github.com/docker/cli v29.0.0+incompatible + github.com/bytedance/gopkg v0.1.3 // xxhash64 for fast hash + github.com/bytedance/sonic v1.14.2 // fast json parsing + github.com/docker/cli v29.0.0+incompatible // needs docker/cli/cli/connhelper connection helper for docker client github.com/goccy/go-yaml v1.18.0 // yaml parsing for different config files - github.com/golang-jwt/jwt/v5 v5.3.0 - github.com/luthermonson/go-proxmox v0.2.3 - github.com/oschwald/maxminddb-golang v1.13.1 + github.com/golang-jwt/jwt/v5 v5.3.0 // jwt authentication + github.com/luthermonson/go-proxmox v0.2.3 // proxmox API client + github.com/moby/moby/api v1.52.0 // docker API + github.com/moby/moby/client v0.1.0 // docker client + github.com/oschwald/maxminddb-golang v1.13.1 // maxminddb for geoip database github.com/quic-go/quic-go v0.56.0 // http3 support - github.com/samber/slog-zerolog/v2 v2.9.0 // indirect - github.com/spf13/afero v1.15.0 - github.com/stretchr/testify v1.11.1 - github.com/yusing/ds v0.3.1 - github.com/yusing/godoxy/agent v0.0.0-20251107090858-f6dcc8f11893 + github.com/shirou/gopsutil/v4 v4.25.10 // system information + github.com/spf13/afero v1.15.0 // afero for file system operations + github.com/stretchr/testify v1.11.1 // testing framework + github.com/valyala/fasthttp v1.68.0 // fast http for health check + github.com/yusing/ds v0.3.1 // data structures and algorithms + github.com/yusing/godoxy/agent v0.0.0-20251113071320-219eedf3c595 github.com/yusing/godoxy/internal/dnsproviders v0.0.0-20251113071320-219eedf3c595 + github.com/yusing/gointernals v0.1.16 github.com/yusing/goutils v0.7.0 ) @@ -106,11 +111,11 @@ require ( github.com/ovh/go-ovh v1.9.0 // indirect github.com/pelletier/go-toml/v2 v2.2.4 // indirect github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c // indirect - github.com/pkg/errors v0.9.1 // indirect github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect github.com/quic-go/qpack v0.5.1 // indirect github.com/samber/lo v1.52.0 // indirect github.com/samber/slog-common v0.19.0 // indirect + github.com/samber/slog-zerolog/v2 v2.9.0 // indirect github.com/scaleway/scaleway-sdk-go v1.0.0-beta.35 // indirect github.com/sirupsen/logrus v1.9.4-0.20230606125235-dd1b4c2e81af // indirect github.com/sony/gobreaker v1.0.0 // indirect @@ -135,14 +140,6 @@ require ( gopkg.in/yaml.v3 v3.0.1 // indirect ) -require ( - github.com/bytedance/gopkg v0.1.3 - github.com/bytedance/sonic v1.14.2 - github.com/shirou/gopsutil/v4 v4.25.10 - github.com/valyala/fasthttp v1.68.0 - github.com/yusing/gointernals v0.1.16 -) - require ( github.com/akamai/AkamaiOPEN-edgegrid-golang/v11 v11.1.0 // indirect github.com/andybalholm/brotli v1.2.0 // indirect @@ -151,7 +148,6 @@ require ( github.com/cloudwego/base64x v0.1.6 // indirect github.com/containerd/errdefs v1.0.0 // indirect github.com/containerd/errdefs/pkg v0.3.0 // indirect - github.com/containerd/log v0.1.0 // indirect github.com/fatih/color v1.18.0 // indirect github.com/gin-contrib/sse v1.1.0 // indirect github.com/go-ole/go-ole v1.3.0 // indirect @@ -159,14 +155,10 @@ require ( github.com/go-resty/resty/v2 v2.16.5 // indirect github.com/goccy/go-json v0.10.5 // indirect github.com/google/go-querystring v1.1.0 // indirect - github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3 // indirect github.com/klauspost/compress v1.18.1 // indirect github.com/klauspost/cpuid/v2 v2.3.0 // indirect github.com/linode/linodego v1.61.0 // indirect github.com/lufia/plan9stats v0.0.0-20251013123823-9fd1530e3ec3 // indirect - github.com/moby/sys/atomicwriter v0.1.0 // indirect - github.com/moby/term v0.5.2 // indirect - github.com/morikuni/aec v1.0.0 // indirect github.com/nrdcg/oci-go-sdk/common/v1065 v1065.104.1 // indirect github.com/nrdcg/oci-go-sdk/dns/v1065 v1065.104.1 // indirect github.com/pierrec/lz4/v4 v4.1.21 // indirect @@ -180,8 +172,6 @@ require ( github.com/valyala/bytebufferpool v1.0.0 // indirect github.com/vultr/govultr/v3 v3.24.0 // indirect github.com/yusufpapurcu/wmi v1.2.4 // indirect - go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.38.0 // indirect - go.opentelemetry.io/proto/otlp v1.9.0 // indirect golang.org/x/arch v0.23.0 // indirect google.golang.org/genproto v0.0.0-20251111163417-95abcf5c77ba // indirect google.golang.org/genproto/googleapis/api v0.0.0-20251111163417-95abcf5c77ba // indirect diff --git a/go.sum b/go.sum index 9f82c7bc..ddcd8731 100644 --- a/go.sum +++ b/go.sum @@ -23,8 +23,6 @@ github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/resourcegraph/armresourceg github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/resourcegraph/armresourcegraph v0.9.0/go.mod h1:wVEOJfGTj0oPAUGA1JuRAvz/lxXQsWW16axmHPP47Bk= github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/resources/armresources v1.2.0 h1:Dd+RhdJn0OTtVGaeDLZpcumkIVCtA/3/Fo42+eoYvVM= github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/resources/armresources v1.2.0/go.mod h1:5kakwfW5CjC9KK+Q4wjXAg+ShuIm2mBMua0ZFj2C8PE= -github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c h1:udKWzYgxTojEKWjV8V+WSxDXJ4NFATAsZjh8iIbsQIg= -github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c/go.mod h1:xomTg63KZ2rFqZQzSB4Vz2SUXa1BpHTVz9L5PTmPC4E= github.com/AzureAD/microsoft-authentication-extensions-for-go/cache v0.1.1 h1:WJTmL004Abzc5wDB5VtZG2PJk5ndYDgVacGqfirKxjM= github.com/AzureAD/microsoft-authentication-extensions-for-go/cache v0.1.1/go.mod h1:tCcJZ0uHAmvjsVYzEFivsRTN00oz5BEsRgQHu5JZ9WE= github.com/AzureAD/microsoft-authentication-library-for-go v1.6.0 h1:XRzhVemXdgvJqCH0sFfrBUTnUJSBrBf7++ypk+twtRs= @@ -62,8 +60,6 @@ github.com/containerd/errdefs v1.0.0 h1:tg5yIfIlQIrxYtu9ajqY42W3lpS19XqdxRQeEwYG github.com/containerd/errdefs v1.0.0/go.mod h1:+YBYIdtsnF4Iw6nWZhJcqGSg/dwvV7tyJ/kCkyJ2k+M= github.com/containerd/errdefs/pkg v0.3.0 h1:9IKJ06FvyNlexW690DXuQNx2KA2cUJXx151Xdx3ZPPE= github.com/containerd/errdefs/pkg v0.3.0/go.mod h1:NJw6s9HwNuRhnjJhM7pylWwMyAkmCQvQ4GpJHEqRLVk= -github.com/containerd/log v0.1.0 h1:TCJt7ioM2cr/tfR8GPbGf9/VRAX8D2B4PjzCpfX540I= -github.com/containerd/log v0.1.0/go.mod h1:VRRf09a7mHDIRezVKTRCrOq78v577GXq3bSa3EhrzVo= github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= @@ -77,8 +73,6 @@ github.com/djherbis/times v1.6.0 h1:w2ctJ92J8fBvWPxugmXIv7Nz7Q3iDMKNx9v5ocVH20c= github.com/djherbis/times v1.6.0/go.mod h1:gOHeRAz2h+VJNZ5Gmc/o7iD9k4wW7NMVqieYCY99oc0= github.com/docker/cli v29.0.0+incompatible h1:KgsN2RUFMNM8wChxryicn4p46BdQWpXOA1XLGBGPGAw= github.com/docker/cli v29.0.0+incompatible/go.mod h1:JLrzqnKDaYBop7H2jaqPtU4hHvMKP+vjCwu2uszcLI8= -github.com/docker/docker v28.5.2+incompatible h1:DBX0Y0zAjZbSrm1uzOkdr1onVghKaftjlSWt4AFexzM= -github.com/docker/docker v28.5.2+incompatible/go.mod h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk= github.com/docker/go-connections v0.6.0 h1:LlMG9azAe1TqfR7sO+NJttz1gy6KO7VJBh+pMmjSD94= github.com/docker/go-connections v0.6.0/go.mod h1:AahvXYshr6JgfUJGdDCs2b5EZG/vmaMAntpSFH5BFKE= github.com/docker/go-units v0.5.0 h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4= @@ -157,8 +151,6 @@ github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aN github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE= github.com/gotify/server/v2 v2.7.3 h1:nro/ZnxdlZFvxFcw9LREGA8zdk6CK744azwhuhX/A4g= github.com/gotify/server/v2 v2.7.3/go.mod h1:VAtE1RIc/2j886PYs9WPQbMjqbFsoyQ0G8IdFtnAxU0= -github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3 h1:NmZ1PKzSTQbuGHw9DGPFomqkkLWMC+vZCkfs+FHv1Vg= -github.com/grpc-ecosystem/grpc-gateway/v2 v2.27.3/go.mod h1:zQrxl1YP88HQlA6i9c63DSVPFklWpGX4OWAc9bFuaH4= github.com/h2non/gock v1.2.0 h1:K6ol8rfrRkUOefooBC8elXoaNGYkpp7y2qcxGG6BzUE= github.com/h2non/gock v1.2.0/go.mod h1:tNhoxHYW2W42cYkYb1WqzdbYIieALC99kpYr7rH/BQk= github.com/h2non/parth v0.0.0-20190131123155-b4df798d6542 h1:2VTzZjLZBgl62/EtslCrtky5vbi9dd7HrQPQIx6wqiw= @@ -214,19 +206,15 @@ github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0= github.com/moby/docker-image-spec v1.3.1 h1:jMKff3w6PgbfSa69GfNg+zN/XLhfXJGnEx3Nl2EsFP0= github.com/moby/docker-image-spec v1.3.1/go.mod h1:eKmb5VW8vQEh/BAr2yvVNvuiJuY6UIocYsFu/DxxRpo= -github.com/moby/sys/atomicwriter v0.1.0 h1:kw5D/EqkBwsBFi0ss9v1VG3wIkVhzGvLklJ+w3A14Sw= -github.com/moby/sys/atomicwriter v0.1.0/go.mod h1:Ul8oqv2ZMNHOceF643P6FKPXeCmYtlQMvpizfsSoaWs= -github.com/moby/sys/sequential v0.6.0 h1:qrx7XFUd/5DxtqcoH1h438hF5TmOvzC/lspjy7zgvCU= -github.com/moby/sys/sequential v0.6.0/go.mod h1:uyv8EUTrca5PnDsdMGXhZe6CCe8U/UiTWd+lL+7b/Ko= -github.com/moby/term v0.5.2 h1:6qk3FJAFDs6i/q3W/pQ97SX192qKfZgGjCQqfCJkgzQ= -github.com/moby/term v0.5.2/go.mod h1:d3djjFCrjnB+fl8NJux+EJzu0msscUP+f8it8hPkFLc= +github.com/moby/moby/api v1.52.0 h1:00BtlJY4MXkkt84WhUZPRqt5TvPbgig2FZvTbe3igYg= +github.com/moby/moby/api v1.52.0/go.mod h1:8mb+ReTlisw4pS6BRzCMts5M49W5M7bKt1cJy/YbAqc= +github.com/moby/moby/client v0.1.0 h1:nt+hn6O9cyJQqq5UWnFGqsZRTS/JirUqzPjEl0Bdc/8= +github.com/moby/moby/client v0.1.0/go.mod h1:O+/tw5d4a1Ha/ZA/tPxIZJapJRUS6LNZ1wiVRxYHyUE= github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= -github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A= -github.com/morikuni/aec v1.0.0/go.mod h1:BbKIizmSmc5MMPqRYbxO4ZU0S0+P200+tUnFx7PXmsc= github.com/nrdcg/goacmedns v0.2.0 h1:ADMbThobzEMnr6kg2ohs4KGa3LFqmgiBA22/6jUWJR0= github.com/nrdcg/goacmedns v0.2.0/go.mod h1:T5o6+xvSLrQpugmwHvrSNkzWht0UGAwj2ACBMhh73Cg= github.com/nrdcg/oci-go-sdk/common/v1065 v1065.104.1 h1:kR8dHXC53heV4fttilXXkDkGmkdC5bvQ2XgbVBoD+ns= @@ -251,7 +239,6 @@ github.com/pires/go-proxyproto v0.8.1 h1:9KEixbdJfhrbtjpz/ZwCdWDD2Xem0NZ38qMYaAS github.com/pires/go-proxyproto v0.8.1/go.mod h1:ZKAAyp3cgy5Y5Mo4n9AlScrkCZwUy0g3Jf+slqQVcuU= github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c h1:+mdjkGKdHQG3305AYmdv1U2eRNDiU2ErMBj1gwrq8eQ= github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c/go.mod h1:7rwL4CYBLnjLxUqIJNnCWiEdr3bn6IUYi15bNlnbCCU= -github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= github.com/pkg/xattr v0.4.9 h1:5883YPCtkSd8LFbs13nXplj9g9tlrwoJRjgpgMu1/fE= github.com/pkg/xattr v0.4.9/go.mod h1:di8WF84zAKk8jzR1UBTEWh9AUlIZZ7M/JNt8e9B6ktU= @@ -337,10 +324,6 @@ go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.63.0 h1:RbKq8BG go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.63.0/go.mod h1:h06DGIukJOevXaj/xrNjhi/2098RZzcLTbc0jDAUbsg= go.opentelemetry.io/otel v1.38.0 h1:RkfdswUDRimDg0m2Az18RKOsnI8UDzppJAtj01/Ymk8= go.opentelemetry.io/otel v1.38.0/go.mod h1:zcmtmQ1+YmQM9wrNsTGV/q/uyusom3P8RxwExxkZhjM= -go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0 h1:GqRJVj7UmLjCVyVJ3ZFLdPRmhDUp2zFmQe3RHIOsw24= -go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0/go.mod h1:ri3aaHSmCTVYu2AWv44YMauwAQc0aqI9gHKIcSbI1pU= -go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.38.0 h1:aTL7F04bJHUlztTsNGJ2l+6he8c+y/b//eR0jjjemT4= -go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.38.0/go.mod h1:kldtb7jDTeol0l3ewcmd8SDvx3EmIE7lyvqbasU3QC4= go.opentelemetry.io/otel/metric v1.38.0 h1:Kl6lzIYGAh5M159u9NgiRkmoMKjvbsKtYRwgfrA6WpA= go.opentelemetry.io/otel/metric v1.38.0/go.mod h1:kB5n/QoRM8YwmUahxvI3bO34eVtQf2i4utNVLr9gEmI= go.opentelemetry.io/otel/sdk v1.38.0 h1:l48sr5YbNf2hpCUj/FoGhW9yDkl+Ma+LrVl8qaM5b+E= @@ -349,8 +332,6 @@ go.opentelemetry.io/otel/sdk/metric v1.38.0 h1:aSH66iL0aZqo//xXzQLYozmWrXxyFkBJ6 go.opentelemetry.io/otel/sdk/metric v1.38.0/go.mod h1:dg9PBnW9XdQ1Hd6ZnRz689CbtrUp0wMMs9iPcgT9EZA= go.opentelemetry.io/otel/trace v1.38.0 h1:Fxk5bKrDZJUH+AMyyIXGcFAPah0oRcT+LuNtJrmcNLE= go.opentelemetry.io/otel/trace v1.38.0/go.mod h1:j1P9ivuFsTceSWe1oY+EeW3sc+Pp42sO++GHkg4wwhs= -go.opentelemetry.io/proto/otlp v1.9.0 h1:l706jCMITVouPOqEnii2fIAuO3IVGBRPV5ICjceRb/A= -go.opentelemetry.io/proto/otlp v1.9.0/go.mod h1:xE+Cx5E/eEHw+ISFkwPLwCZefwVjY+pqKg1qcK03+/4= go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0= go.uber.org/mock v0.6.0 h1:hyF9dfmbgIX5EfOdasqLsWD6xqpNZlXblLB/Dbnwv3Y= @@ -476,3 +457,5 @@ gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gotest.tools/v3 v3.5.2 h1:7koQfIKdy+I8UTetycgUqXWSDwpgv193Ka+qRsmBY8Q= gotest.tools/v3 v3.5.2/go.mod h1:LtdLGcnqToBH83WByAAi/wiwSFCArdFIUV/xxN4pcjA= +pgregory.net/rapid v1.2.0 h1:keKAYRcjm+e1F0oAuU5F5+YPAWcyxNNRK2wud503Gnk= +pgregory.net/rapid v1.2.0/go.mod h1:PY5XlDGj0+V1FCq0o192FdRhpKHGTRIWBgqjDBTrq04= diff --git a/internal/api/v1/docker/container.go b/internal/api/v1/docker/container.go index 108a9815..18eeaeca 100644 --- a/internal/api/v1/docker/container.go +++ b/internal/api/v1/docker/container.go @@ -4,6 +4,7 @@ import ( "net/http" "github.com/gin-gonic/gin" + "github.com/moby/moby/client" "github.com/yusing/godoxy/internal/docker" apitypes "github.com/yusing/goutils/apitypes" ) @@ -34,30 +35,30 @@ func GetContainer(c *gin.Context) { return } - client, err := docker.NewClient(dockerHost) + dockerClient, err := docker.NewClient(dockerHost) if err != nil { c.Error(apitypes.InternalServerError(err, "failed to create docker client")) return } - defer client.Close() + defer dockerClient.Close() - cont, err := client.ContainerInspect(c.Request.Context(), id) + cont, err := dockerClient.ContainerInspect(c.Request.Context(), id, client.ContainerInspectOptions{}) if err != nil { c.Error(apitypes.InternalServerError(err, "failed to inspect container")) return } var state ContainerState - if cont.State != nil { - state = cont.State.Status + if cont.Container.State != nil { + state = cont.Container.State.Status } c.JSON(http.StatusOK, &Container{ Server: dockerHost, - Name: cont.Name, - ID: cont.ID, - Image: cont.Image, + Name: cont.Container.Name, + ID: cont.Container.ID, + Image: cont.Container.Image, State: state, }) } diff --git a/internal/api/v1/docker/containers.go b/internal/api/v1/docker/containers.go index 4d6c1d05..a07c24eb 100644 --- a/internal/api/v1/docker/containers.go +++ b/internal/api/v1/docker/containers.go @@ -4,8 +4,9 @@ import ( "context" "sort" - "github.com/docker/docker/api/types/container" "github.com/gin-gonic/gin" + "github.com/moby/moby/api/types/container" + "github.com/moby/moby/client" gperr "github.com/yusing/goutils/errs" _ "github.com/yusing/goutils/apitypes" @@ -39,12 +40,12 @@ func GetContainers(ctx context.Context, dockerClients DockerClients) ([]Containe errs := gperr.NewBuilder("failed to get containers") containers := make([]Container, 0) for server, dockerClient := range dockerClients { - conts, err := dockerClient.ContainerList(ctx, container.ListOptions{All: true}) + conts, err := dockerClient.ContainerList(ctx, client.ContainerListOptions{All: true}) if err != nil { errs.Add(err) continue } - for _, cont := range conts { + for _, cont := range conts.Items { containers = append(containers, Container{ Server: server, Name: cont.Names[0], diff --git a/internal/api/v1/docker/info.go b/internal/api/v1/docker/info.go index f5f79248..b96fc1d3 100644 --- a/internal/api/v1/docker/info.go +++ b/internal/api/v1/docker/info.go @@ -4,8 +4,9 @@ import ( "context" "sort" - dockerSystem "github.com/docker/docker/api/types/system" "github.com/gin-gonic/gin" + dockerSystem "github.com/moby/moby/api/types/system" + "github.com/moby/moby/client" gperr "github.com/yusing/goutils/errs" strutils "github.com/yusing/goutils/strings" @@ -64,13 +65,13 @@ func GetDockerInfo(ctx context.Context, dockerClients DockerClients) ([]dockerIn i := 0 for name, dockerClient := range dockerClients { - info, err := dockerClient.Info(ctx) + info, err := dockerClient.Info(ctx, client.InfoOptions{}) if err != nil { errs.Add(err) continue } - info.Name = name - dockerInfos[i] = toDockerInfo(info) + info.Info.Name = name + dockerInfos[i] = toDockerInfo(info.Info) i++ } diff --git a/internal/api/v1/docker/logs.go b/internal/api/v1/docker/logs.go index 917ee1f2..867fdf47 100644 --- a/internal/api/v1/docker/logs.go +++ b/internal/api/v1/docker/logs.go @@ -6,9 +6,9 @@ import ( "fmt" "net/http" - "github.com/docker/docker/api/types/container" - "github.com/docker/docker/pkg/stdcopy" "github.com/gin-gonic/gin" + "github.com/moby/moby/api/pkg/stdcopy" + "github.com/moby/moby/client" "github.com/rs/zerolog/log" "github.com/yusing/godoxy/internal/docker" apitypes "github.com/yusing/goutils/apitypes" @@ -70,7 +70,7 @@ func Logs(c *gin.Context) { } defer dockerClient.Close() - opts := container.LogsOptions{ + opts := client.ContainerLogsOptions{ ShowStdout: queryParams.Stdout, ShowStderr: queryParams.Stderr, Since: queryParams.Since, diff --git a/internal/api/v1/docker/restart.go b/internal/api/v1/docker/restart.go index 5a72eb30..b43207bb 100644 --- a/internal/api/v1/docker/restart.go +++ b/internal/api/v1/docker/restart.go @@ -4,17 +4,23 @@ import ( "net/http" "github.com/gin-gonic/gin" + "github.com/moby/moby/client" "github.com/yusing/godoxy/internal/docker" apitypes "github.com/yusing/goutils/apitypes" ) +type RestartRequest struct { + ID string `json:"id" binding:"required"` + client.ContainerRestartOptions +} + // @x-id "restart" // @BasePath /api/v1 // @Summary Restart container // @Description Restart container by container id // @Tags docker // @Produce json -// @Param request body StopRequest true "Request" +// @Param request body RestartRequest true "Request" // @Success 200 {object} apitypes.SuccessResponse // @Failure 400 {object} apitypes.ErrorResponse "Invalid request" // @Failure 403 {object} apitypes.ErrorResponse @@ -22,7 +28,7 @@ import ( // @Failure 500 {object} apitypes.ErrorResponse // @Router /docker/restart [post] func Restart(c *gin.Context) { - var req StopRequest + var req RestartRequest if err := c.ShouldBindJSON(&req); err != nil { c.JSON(http.StatusBadRequest, apitypes.Error("invalid request", err)) return @@ -42,7 +48,7 @@ func Restart(c *gin.Context) { defer client.Close() - err = client.ContainerRestart(c.Request.Context(), req.ID, req.StopOptions) + _, err = client.ContainerRestart(c.Request.Context(), req.ID, req.ContainerRestartOptions) if err != nil { c.Error(apitypes.InternalServerError(err, "failed to restart container")) return diff --git a/internal/api/v1/docker/start.go b/internal/api/v1/docker/start.go index ad3eb176..cd6a0ccb 100644 --- a/internal/api/v1/docker/start.go +++ b/internal/api/v1/docker/start.go @@ -3,15 +3,15 @@ package dockerapi import ( "net/http" - "github.com/docker/docker/api/types/container" "github.com/gin-gonic/gin" + "github.com/moby/moby/client" "github.com/yusing/godoxy/internal/docker" apitypes "github.com/yusing/goutils/apitypes" ) type StartRequest struct { ID string `json:"id" binding:"required"` - container.StartOptions + client.ContainerStartOptions } // @x-id "start" @@ -48,7 +48,7 @@ func Start(c *gin.Context) { defer client.Close() - err = client.ContainerStart(c.Request.Context(), req.ID, req.StartOptions) + _, err = client.ContainerStart(c.Request.Context(), req.ID, req.ContainerStartOptions) if err != nil { c.Error(apitypes.InternalServerError(err, "failed to start container")) return diff --git a/internal/api/v1/docker/stop.go b/internal/api/v1/docker/stop.go index 5db90737..32a235e2 100644 --- a/internal/api/v1/docker/stop.go +++ b/internal/api/v1/docker/stop.go @@ -3,15 +3,15 @@ package dockerapi import ( "net/http" - "github.com/docker/docker/api/types/container" "github.com/gin-gonic/gin" + "github.com/moby/moby/client" "github.com/yusing/godoxy/internal/docker" apitypes "github.com/yusing/goutils/apitypes" ) type StopRequest struct { ID string `json:"id" binding:"required"` - container.StopOptions + client.ContainerStopOptions } // @x-id "stop" @@ -48,7 +48,7 @@ func Stop(c *gin.Context) { defer client.Close() - err = client.ContainerStop(c.Request.Context(), req.ID, req.StopOptions) + _, err = client.ContainerStop(c.Request.Context(), req.ID, req.ContainerStopOptions) if err != nil { c.Error(apitypes.InternalServerError(err, "failed to stop container")) return diff --git a/internal/docker/client.go b/internal/docker/client.go index 427b281c..6bf84ec4 100644 --- a/internal/docker/client.go +++ b/internal/docker/client.go @@ -14,7 +14,7 @@ import ( "unsafe" "github.com/docker/cli/cli/connhelper" - "github.com/docker/docker/client" + "github.com/moby/moby/client" "github.com/rs/zerolog/log" "github.com/yusing/godoxy/agent/pkg/agent" "github.com/yusing/godoxy/internal/common" @@ -110,6 +110,8 @@ func Clients() map[string]*SharedClient { return clients } +var versionArg = client.WithVersion("v1.51.0") + // NewClient creates a new Docker client connection to the specified host. // // Returns existing client if available. @@ -152,7 +154,7 @@ func NewClient(host string, unique ...bool) (*SharedClient, error) { opt = []client.Opt{ client.WithHost(agent.DockerHost), client.WithHTTPClient(cfg.NewHTTPClient()), - client.WithAPIVersionNegotiation(), + versionArg, } addr = "tcp://" + cfg.Addr dial = cfg.DialContext @@ -163,7 +165,7 @@ func NewClient(host string, unique ...bool) (*SharedClient, error) { case common.DockerHostFromEnv: opt = []client.Opt{ client.WithHostFromEnv(), - client.WithAPIVersionNegotiation(), + versionArg, } default: helper, err := connhelper.GetConnectionHelper(host) @@ -179,19 +181,19 @@ func NewClient(host string, unique ...bool) (*SharedClient, error) { opt = []client.Opt{ client.WithHTTPClient(httpClient), client.WithHost(helper.Host), - client.WithAPIVersionNegotiation(), + versionArg, client.WithDialContext(helper.Dialer), } } else { opt = []client.Opt{ client.WithHost(host), - client.WithAPIVersionNegotiation(), + versionArg, } } } } - client, err := client.NewClientWithOpts(opt...) + client, err := client.New(opt...) if err != nil { return nil, err } diff --git a/internal/docker/container.go b/internal/docker/container.go index d0c187ef..50490505 100644 --- a/internal/docker/container.go +++ b/internal/docker/container.go @@ -11,8 +11,9 @@ import ( "strconv" "strings" - "github.com/docker/docker/api/types/container" "github.com/docker/go-connections/nat" + "github.com/moby/moby/api/types/container" + "github.com/moby/moby/client" "github.com/yusing/godoxy/agent/pkg/agent" "github.com/yusing/godoxy/internal/serialization" "github.com/yusing/godoxy/internal/types" @@ -92,24 +93,24 @@ func IsBlacklisted(c *types.Container) bool { } func UpdatePorts(c *types.Container) error { - client, err := NewClient(c.DockerHost) + dockerClient, err := NewClient(c.DockerHost) if err != nil { return err } - defer client.Close() + defer dockerClient.Close() - inspect, err := client.ContainerInspect(context.Background(), c.ContainerID) + inspect, err := dockerClient.ContainerInspect(context.Background(), c.ContainerID, client.ContainerInspectOptions{}) if err != nil { return err } - for port := range inspect.Config.ExposedPorts { - proto, portStr := nat.SplitProtoPort(string(port)) + for port := range inspect.Container.Config.ExposedPorts { + proto, portStr := nat.SplitProtoPort(port.String()) portInt, _ := nat.ParsePort(portStr) if portInt == 0 { continue } - c.PublicPortMapping[portInt] = container.Port{ + c.PublicPortMapping[portInt] = container.PortSummary{ PublicPort: uint16(portInt), //nolint:gosec PrivatePort: uint16(portInt), //nolint:gosec Type: proto, @@ -207,8 +208,8 @@ func setPrivateHostname(c *types.Container, helper containerHelper) { } if c.Network != "" { v, ok := helper.NetworkSettings.Networks[c.Network] - if ok { - c.PrivateHostname = v.IPAddress + if ok && v.IPAddress.IsValid() { + c.PrivateHostname = v.IPAddress.String() return } // try {project_name}_{network_name} @@ -216,9 +217,9 @@ func setPrivateHostname(c *types.Container, helper containerHelper) { oldNetwork, newNetwork := c.Network, fmt.Sprintf("%s_%s", proj, c.Network) if newNetwork != oldNetwork { v, ok = helper.NetworkSettings.Networks[newNetwork] - if ok { + if ok && v.IPAddress.IsValid() { c.Network = newNetwork // update network to the new one - c.PrivateHostname = v.IPAddress + c.PrivateHostname = v.IPAddress.String() return } } @@ -229,9 +230,9 @@ func setPrivateHostname(c *types.Container, helper containerHelper) { } // fallback to first network if no network is specified for k, v := range helper.NetworkSettings.Networks { - if v.IPAddress != "" { + if v.IPAddress.IsValid() { c.Network = k // update network to the first network - c.PrivateHostname = v.IPAddress + c.PrivateHostname = v.IPAddress.String() return } } diff --git a/internal/docker/container_helper.go b/internal/docker/container_helper.go index 7dab7609..cea49859 100644 --- a/internal/docker/container_helper.go +++ b/internal/docker/container_helper.go @@ -3,7 +3,7 @@ package docker import ( "strings" - "github.com/docker/docker/api/types/container" + "github.com/moby/moby/api/types/container" "github.com/yusing/ds/ordered" "github.com/yusing/godoxy/internal/types" strutils "github.com/yusing/goutils/strings" diff --git a/internal/docker/container_test.go b/internal/docker/container_test.go index 3dddd829..8423451b 100644 --- a/internal/docker/container_test.go +++ b/internal/docker/container_test.go @@ -3,7 +3,7 @@ package docker import ( "testing" - "github.com/docker/docker/api/types/container" + "github.com/moby/moby/api/types/container" expect "github.com/yusing/goutils/testing" ) diff --git a/internal/docker/list_containers.go b/internal/docker/list_containers.go index e1a98e52..0e9d197e 100644 --- a/internal/docker/list_containers.go +++ b/internal/docker/list_containers.go @@ -3,11 +3,11 @@ package docker import ( "context" - "github.com/docker/docker/api/types/container" - "github.com/docker/docker/client" + "github.com/moby/moby/api/types/container" + "github.com/moby/moby/client" ) -var listOptions = container.ListOptions{ +var listOptions = client.ContainerListOptions{ // created|restarting|running|removing|paused|exited|dead // Filters: filters.NewArgs( // filters.Arg("status", "created"), @@ -30,7 +30,7 @@ func ListContainers(ctx context.Context, clientHost string) ([]container.Summary if err != nil { return nil, err } - return containers, nil + return containers.Items, nil } func IsErrConnectionFailed(err error) bool { diff --git a/internal/idlewatcher/provider/docker.go b/internal/idlewatcher/provider/docker.go index 9f9bb2ce..f8929322 100644 --- a/internal/idlewatcher/provider/docker.go +++ b/internal/idlewatcher/provider/docker.go @@ -3,7 +3,8 @@ package provider import ( "context" - "github.com/docker/docker/api/types/container" + "github.com/moby/moby/api/types/container" + "github.com/moby/moby/client" "github.com/yusing/godoxy/internal/docker" idlewatcher "github.com/yusing/godoxy/internal/idlewatcher/types" "github.com/yusing/godoxy/internal/types" @@ -17,7 +18,7 @@ type DockerProvider struct { containerID string } -var startOptions = container.StartOptions{} +var startOptions = client.ContainerStartOptions{} func NewDockerProvider(dockerHost, containerID string) (idlewatcher.Provider, error) { client, err := docker.NewClient(dockerHost) @@ -32,34 +33,41 @@ func NewDockerProvider(dockerHost, containerID string) (idlewatcher.Provider, er } func (p *DockerProvider) ContainerPause(ctx context.Context) error { - return p.client.ContainerPause(ctx, p.containerID) + _, err := p.client.ContainerPause(ctx, p.containerID, client.ContainerPauseOptions{}) + return err } func (p *DockerProvider) ContainerUnpause(ctx context.Context) error { - return p.client.ContainerUnpause(ctx, p.containerID) + _, err := p.client.ContainerUnpause(ctx, p.containerID, client.ContainerUnpauseOptions{}) + return err } func (p *DockerProvider) ContainerStart(ctx context.Context) error { - return p.client.ContainerStart(ctx, p.containerID, startOptions) + _, err := p.client.ContainerStart(ctx, p.containerID, startOptions) + return err } func (p *DockerProvider) ContainerStop(ctx context.Context, signal types.ContainerSignal, timeout int) error { - return p.client.ContainerStop(ctx, p.containerID, container.StopOptions{ + _, err := p.client.ContainerStop(ctx, p.containerID, client.ContainerStopOptions{ Signal: string(signal), Timeout: &timeout, }) + return err } func (p *DockerProvider) ContainerKill(ctx context.Context, signal types.ContainerSignal) error { - return p.client.ContainerKill(ctx, p.containerID, string(signal)) + _, err := p.client.ContainerKill(ctx, p.containerID, client.ContainerKillOptions{ + Signal: string(signal), + }) + return err } func (p *DockerProvider) ContainerStatus(ctx context.Context) (idlewatcher.ContainerStatus, error) { - status, err := p.client.ContainerInspect(ctx, p.containerID) + status, err := p.client.ContainerInspect(ctx, p.containerID, client.ContainerInspectOptions{}) if err != nil { return idlewatcher.ContainerStatusError, err } - switch status.State.Status { + switch status.Container.State.Status { case container.StateRunning: return idlewatcher.ContainerStatusRunning, nil case container.StateExited, container.StateDead, container.StateRestarting: @@ -67,12 +75,12 @@ func (p *DockerProvider) ContainerStatus(ctx context.Context) (idlewatcher.Conta case container.StatePaused: return idlewatcher.ContainerStatusPaused, nil } - return idlewatcher.ContainerStatusError, idlewatcher.ErrUnexpectedContainerStatus.Subject(status.State.Status) + return idlewatcher.ContainerStatusError, idlewatcher.ErrUnexpectedContainerStatus.Subject(string(status.Container.State.Status)) } func (p *DockerProvider) Watch(ctx context.Context) (eventCh <-chan watcher.Event, errCh <-chan gperr.Error) { return p.watcher.EventsWithOptions(ctx, watcher.DockerListOptions{ - Filters: watcher.NewDockerFilter( + Filters: watcher.NewDockerFilters( watcher.DockerFilterContainer, watcher.DockerFilterContainerNameID(p.containerID), watcher.DockerFilterStart, diff --git a/internal/route/provider/docker_labels_test.go b/internal/route/provider/docker_labels_test.go index bb7e4b54..54ffca3b 100644 --- a/internal/route/provider/docker_labels_test.go +++ b/internal/route/provider/docker_labels_test.go @@ -3,8 +3,8 @@ package provider import ( "testing" - "github.com/docker/docker/api/types/container" "github.com/goccy/go-yaml" + "github.com/moby/moby/api/types/container" "github.com/yusing/godoxy/internal/docker" expect "github.com/yusing/goutils/testing" @@ -25,7 +25,7 @@ func TestParseDockerLabels(t *testing.T) { Names: []string{"container"}, Labels: labels, State: "running", - Ports: []container.Port{ + Ports: []container.PortSummary{ {Type: "tcp", PrivatePort: 1234, PublicPort: 1234}, }, }, "/var/run/docker.sock"), diff --git a/internal/route/provider/docker_test.go b/internal/route/provider/docker_test.go index 65c6df0d..e8e6a3ea 100644 --- a/internal/route/provider/docker_test.go +++ b/internal/route/provider/docker_test.go @@ -1,12 +1,13 @@ package provider import ( + "net/netip" "testing" "time" - "github.com/docker/docker/api/types/container" - "github.com/docker/docker/api/types/network" - "github.com/docker/docker/client" + "github.com/moby/moby/api/types/container" + "github.com/moby/moby/api/types/network" + "github.com/moby/moby/client" D "github.com/yusing/godoxy/internal/docker" "github.com/yusing/godoxy/internal/route" routeTypes "github.com/yusing/godoxy/internal/route/types" @@ -274,7 +275,7 @@ func TestPrivateIPLocalhost(t *testing.T) { NetworkSettings: &container.NetworkSettingsSummary{ Networks: map[string]*network.EndpointSettings{ "network": { - IPAddress: testDockerIP, + IPAddress: netip.MustParseAddr(testDockerIP), }, }, }, @@ -292,7 +293,7 @@ func TestPrivateIPRemote(t *testing.T) { NetworkSettings: &container.NetworkSettingsSummary{ Networks: map[string]*network.EndpointSettings{ "network": { - IPAddress: testDockerIP, + IPAddress: netip.MustParseAddr(testDockerIP), }, }, }, @@ -314,11 +315,11 @@ func TestStreamDefaultValues(t *testing.T) { NetworkSettings: &container.NetworkSettingsSummary{ Networks: map[string]*network.EndpointSettings{ "network": { - IPAddress: privIP, + IPAddress: netip.MustParseAddr(privIP), }, }, }, - Ports: []container.Port{ + Ports: []container.PortSummary{ {Type: "udp", PrivatePort: privPort, PublicPort: pubPort}, }, } @@ -371,7 +372,7 @@ func TestImplicitExcludeDatabase(t *testing.T) { t.Run("exposed port detection", func(t *testing.T) { r, ok := makeRoutes(&container.Summary{ Names: dummyNames, - Ports: []container.Port{ + Ports: []container.PortSummary{ {Type: "tcp", PrivatePort: 5432, PublicPort: 5432}, }, })["a"] diff --git a/internal/route/provider/provider.go b/internal/route/provider/provider.go index 85dd2da0..68fe1d9f 100644 --- a/internal/route/provider/provider.go +++ b/internal/route/provider/provider.go @@ -8,7 +8,7 @@ import ( "sync" "time" - "github.com/docker/docker/client" + "github.com/moby/moby/client" "github.com/rs/zerolog" "github.com/yusing/godoxy/agent/pkg/agent" "github.com/yusing/godoxy/internal/common" diff --git a/internal/route/route.go b/internal/route/route.go index 3f67b194..007b0082 100644 --- a/internal/route/route.go +++ b/internal/route/route.go @@ -13,7 +13,6 @@ import ( "sync" "time" - "github.com/docker/docker/api/types/container" "github.com/rs/zerolog/log" "github.com/yusing/godoxy/agent/pkg/agent" "github.com/yusing/godoxy/internal/docker" @@ -878,7 +877,7 @@ var preferredPortOrder = []int{ 8443, } -func preferredPort(portMapping map[int]container.Port) (res int) { +func preferredPort(portMapping types.PortMapping) (res int) { for _, port := range preferredPortOrder { if _, ok := portMapping[port]; ok { return port diff --git a/internal/route/route_test.go b/internal/route/route_test.go index f4664ef1..c84bcf82 100644 --- a/internal/route/route_test.go +++ b/internal/route/route_test.go @@ -3,7 +3,6 @@ package route import ( "testing" - "github.com/docker/docker/api/types/container" "github.com/yusing/godoxy/internal/common" route "github.com/yusing/godoxy/internal/route/types" "github.com/yusing/godoxy/internal/types" @@ -137,7 +136,7 @@ func TestRouteValidate(t *testing.T) { } func TestPreferredPort(t *testing.T) { - ports := map[int]container.Port{ + ports := types.PortMapping{ 22: {PrivatePort: 22}, 1000: {PrivatePort: 1000}, 3000: {PrivatePort: 80}, diff --git a/internal/types/docker.go b/internal/types/docker.go index 89b32e11..1e1c3f8d 100644 --- a/internal/types/docker.go +++ b/internal/types/docker.go @@ -2,7 +2,7 @@ package types import ( "github.com/bytedance/sonic" - "github.com/docker/docker/api/types/container" + "github.com/moby/moby/api/types/container" "github.com/yusing/ds/ordered" "github.com/yusing/godoxy/agent/pkg/agent" "github.com/yusing/godoxy/internal/utils" @@ -12,7 +12,7 @@ import ( type ( LabelMap = map[string]any - PortMapping = map[int]container.Port + PortMapping = map[int]container.PortSummary Container struct { _ utils.NoCopy diff --git a/internal/watcher/docker_watcher.go b/internal/watcher/docker_watcher.go index 7a8a8fc2..247a2a4c 100644 --- a/internal/watcher/docker_watcher.go +++ b/internal/watcher/docker_watcher.go @@ -5,9 +5,8 @@ import ( "errors" "time" - dockerEvents "github.com/docker/docker/api/types/events" - "github.com/docker/docker/api/types/filters" - "github.com/docker/docker/client" + dockerEvents "github.com/moby/moby/api/types/events" + "github.com/moby/moby/client" "github.com/rs/zerolog/log" "github.com/yusing/godoxy/internal/docker" "github.com/yusing/godoxy/internal/watcher/events" @@ -16,23 +15,42 @@ import ( type ( DockerWatcher string - DockerListOptions = dockerEvents.ListOptions + DockerListOptions = client.EventsListOptions + DockerFilters = client.Filters ) +type DockerFilter struct { + Term string + Values []string +} + +func NewDockerFilter(term string, values ...string) DockerFilter { + return DockerFilter{ + Term: term, + Values: values, + } +} + +func NewDockerFilters(filters ...DockerFilter) client.Filters { + f := make(client.Filters, len(filters)) + for _, filter := range filters { + f.Add(filter.Term, filter.Values...) + } + return f +} + // https://docs.docker.com/reference/api/engine/version/v1.47/#tag/System/operation/SystemPingHead var ( - DockerFilterContainer = filters.Arg("type", string(dockerEvents.ContainerEventType)) - DockerFilterStart = filters.Arg("event", string(dockerEvents.ActionStart)) - DockerFilterStop = filters.Arg("event", string(dockerEvents.ActionStop)) - DockerFilterDie = filters.Arg("event", string(dockerEvents.ActionDie)) - DockerFilterDestroy = filters.Arg("event", string(dockerEvents.ActionDestroy)) - DockerFilterKill = filters.Arg("event", string(dockerEvents.ActionKill)) - DockerFilterPause = filters.Arg("event", string(dockerEvents.ActionPause)) - DockerFilterUnpause = filters.Arg("event", string(dockerEvents.ActionUnPause)) + DockerFilterContainer = NewDockerFilter("type", string(dockerEvents.ContainerEventType)) + DockerFilterStart = NewDockerFilter("event", string(dockerEvents.ActionStart)) + DockerFilterStop = NewDockerFilter("event", string(dockerEvents.ActionStop)) + DockerFilterDie = NewDockerFilter("event", string(dockerEvents.ActionDie)) + DockerFilterDestroy = NewDockerFilter("event", string(dockerEvents.ActionDestroy)) + DockerFilterKill = NewDockerFilter("event", string(dockerEvents.ActionKill)) + DockerFilterPause = NewDockerFilter("event", string(dockerEvents.ActionPause)) + DockerFilterUnpause = NewDockerFilter("event", string(dockerEvents.ActionUnPause)) - NewDockerFilter = filters.NewArgs - - optionsDefault = DockerListOptions{Filters: NewDockerFilter( + optionsDefault = DockerListOptions{Filters: NewDockerFilters( DockerFilterContainer, DockerFilterStart, // DockerFilterStop, @@ -51,8 +69,8 @@ var ( } ) -func DockerFilterContainerNameID(nameOrID string) filters.KeyValuePair { - return filters.Arg("container", nameOrID) +func DockerFilterContainerNameID(nameOrID string) DockerFilter { + return NewDockerFilter("container", nameOrID) } func NewDockerWatcher(host string) DockerWatcher { @@ -80,15 +98,15 @@ func (w DockerWatcher) EventsWithOptions(ctx context.Context, options DockerList client.Close() }() - cEventCh, cErrCh := client.Events(ctx, options) + chs := client.Events(ctx, options) defer log.Debug().Str("host", client.Address()).Msg("docker watcher closed") for { select { case <-ctx.Done(): return - case msg := <-cEventCh: + case msg := <-chs.Messages: w.handleEvent(msg, eventCh) - case err := <-cErrCh: + case err := <-chs.Err: if err == nil { continue } @@ -117,7 +135,7 @@ func (w DockerWatcher) EventsWithOptions(ctx context.Context, options DockerList // connection successful, trigger reload (reload routes) eventCh <- reloadTrigger // reopen event channel - cEventCh, cErrCh = client.Events(ctx, options) + chs = client.Events(ctx, options) } } }() diff --git a/internal/watcher/events/events.go b/internal/watcher/events/events.go index 4fe137cd..f088f0c0 100644 --- a/internal/watcher/events/events.go +++ b/internal/watcher/events/events.go @@ -3,7 +3,7 @@ package events import ( "fmt" - dockerEvents "github.com/docker/docker/api/types/events" + dockerEvents "github.com/moby/moby/api/types/events" ) type ( diff --git a/internal/watcher/health/monitor/docker.go b/internal/watcher/health/monitor/docker.go index fba9ee44..776b97d3 100644 --- a/internal/watcher/health/monitor/docker.go +++ b/internal/watcher/health/monitor/docker.go @@ -5,7 +5,8 @@ import ( "net/url" "github.com/bytedance/sonic" - "github.com/docker/docker/api/types/container" + "github.com/moby/moby/api/types/container" + "github.com/moby/moby/client" "github.com/rs/zerolog/log" "github.com/yusing/godoxy/internal/docker" "github.com/yusing/godoxy/internal/types" @@ -88,7 +89,7 @@ func (mon *DockerHealthMonitor) CheckHealth() (types.HealthCheckResult, error) { defer cancel() // the actual inspect response is intercepted and returned as RequestInterceptedError - _, err := mon.client.ContainerInspect(ctx, mon.containerID) + _, err := mon.client.ContainerInspect(ctx, mon.containerID, client.ContainerInspectOptions{}) var interceptedErr *httputils.RequestInterceptedError if !httputils.AsRequestInterceptedError(err, &interceptedErr) { @@ -111,7 +112,7 @@ func (mon *DockerHealthMonitor) CheckHealth() (types.HealthCheckResult, error) { mon.numDockerFailures = 0 return types.HealthCheckResult{ Healthy: false, - Detail: "container is " + status, + Detail: "container is " + string(status), }, nil case "created": mon.numDockerFailures = 0