@@ -11,9 +11,9 @@ import (
11
11
12
12
"github.com/docker/docker/api/types"
13
13
"github.com/docker/docker/api/types/swarm"
14
- "github.com/lucaslorentz/caddy-docker-proxy/plugin/caddyfile"
15
- "github.com/lucaslorentz/caddy-docker-proxy/plugin/config"
16
- "github.com/lucaslorentz/caddy-docker-proxy/plugin/docker"
14
+ "github.com/lucaslorentz/caddy-docker-proxy/v2/ plugin/caddyfile"
15
+ "github.com/lucaslorentz/caddy-docker-proxy/v2/ plugin/config"
16
+ "github.com/lucaslorentz/caddy-docker-proxy/v2/ plugin/docker"
17
17
18
18
"go.uber.org/zap"
19
19
)
@@ -39,11 +39,11 @@ func CreateGenerator(dockerClients []docker.Client, dockerUtils docker.Utils, op
39
39
var labelRegexString = fmt .Sprintf ("^%s(_\\ d+)?(\\ .|$)" , options .LabelPrefix )
40
40
41
41
return & CaddyfileGenerator {
42
- options : options ,
43
- labelRegex : regexp .MustCompile (labelRegexString ),
44
- dockerClients : dockerClients ,
45
- swarmIsAvailable : make ([]bool , len (dockerClients )),
46
- dockerUtils : dockerUtils ,
42
+ options : options ,
43
+ labelRegex : regexp .MustCompile (labelRegexString ),
44
+ dockerClients : dockerClients ,
45
+ swarmIsAvailable : make ([]bool , len (dockerClients )),
46
+ dockerUtils : dockerUtils ,
47
47
}
48
48
}
49
49
@@ -85,7 +85,7 @@ func (g *CaddyfileGenerator) GenerateCaddyfile(logger *zap.Logger) ([]byte, []st
85
85
logger .Debug ("Skipping default Caddyfile because no path is set" )
86
86
}
87
87
88
- for i , dockerClient := range ( g .dockerClients ) {
88
+ for i , dockerClient := range g .dockerClients {
89
89
90
90
// Add Caddyfile from swarm configs
91
91
if g .swarmIsAvailable [i ] {
@@ -96,7 +96,7 @@ func (g *CaddyfileGenerator) GenerateCaddyfile(logger *zap.Logger) ([]byte, []st
96
96
fullConfig , _ , err := dockerClient .ConfigInspectWithRaw (context .Background (), config .ID )
97
97
if err != nil {
98
98
logger .Error ("Failed to inspect Swarm Config" , zap .String ("config" , config .Spec .Name ), zap .Error (err ))
99
-
99
+
100
100
} else {
101
101
block , err := caddyfile .Unmarshal (fullConfig .Spec .Data )
102
102
if err != nil {
@@ -113,7 +113,7 @@ func (g *CaddyfileGenerator) GenerateCaddyfile(logger *zap.Logger) ([]byte, []st
113
113
} else {
114
114
logger .Debug ("Skipping swarm config caddyfiles because swarm is not available" )
115
115
}
116
-
116
+
117
117
// Add containers
118
118
containers , err := dockerClient .ContainerList (context .Background (), types.ContainerListOptions {})
119
119
if err == nil {
@@ -140,14 +140,14 @@ func (g *CaddyfileGenerator) GenerateCaddyfile(logger *zap.Logger) ([]byte, []st
140
140
} else {
141
141
logger .Error ("Failed to get ContainerList" , zap .Error (err ))
142
142
}
143
-
143
+
144
144
// Add services
145
145
if g .swarmIsAvailable [i ] {
146
146
services , err := dockerClient .ServiceList (context .Background (), types.ServiceListOptions {})
147
147
if err == nil {
148
148
for _ , service := range services {
149
149
logger .Debug ("Swarm service" , zap .String ("service" , service .Spec .Name ))
150
-
150
+
151
151
if _ , isControlledServer := service .Spec .Labels [g .options .ControlledServersLabel ]; isControlledServer {
152
152
ips , err := g .getServiceTasksIps (& service , logger , false )
153
153
if err != nil {
@@ -160,7 +160,7 @@ func (g *CaddyfileGenerator) GenerateCaddyfile(logger *zap.Logger) ([]byte, []st
160
160
}
161
161
}
162
162
}
163
-
163
+
164
164
// caddy. labels based config
165
165
serviceCaddyfile , err := g .getServiceCaddyfile (& service , logger )
166
166
if err == nil {
@@ -174,7 +174,7 @@ func (g *CaddyfileGenerator) GenerateCaddyfile(logger *zap.Logger) ([]byte, []st
174
174
}
175
175
} else {
176
176
logger .Debug ("Skipping swarm services because swarm is not available" )
177
- }
177
+ }
178
178
}
179
179
180
180
// Write global blocks first
@@ -213,7 +213,7 @@ func (g *CaddyfileGenerator) GenerateCaddyfile(logger *zap.Logger) ([]byte, []st
213
213
214
214
func (g * CaddyfileGenerator ) checkSwarmAvailability (logger * zap.Logger , isFirstCheck bool ) {
215
215
216
- for i , dockerClient := range ( g .dockerClients ) {
216
+ for i , dockerClient := range g .dockerClients {
217
217
info , err := dockerClient .Info (context .Background ())
218
218
if err == nil {
219
219
newSwarmIsAvailable := info .Swarm .LocalNodeState == swarm .LocalNodeStateActive
@@ -231,7 +231,7 @@ func (g *CaddyfileGenerator) checkSwarmAvailability(logger *zap.Logger, isFirstC
231
231
func (g * CaddyfileGenerator ) getIngressNetworks (logger * zap.Logger ) (map [string ]bool , error ) {
232
232
ingressNetworks := map [string ]bool {}
233
233
234
- for _ , dockerClient := range ( g .dockerClients ) {
234
+ for _ , dockerClient := range g .dockerClients {
235
235
if len (g .options .IngressNetworks ) > 0 {
236
236
networks , err := dockerClient .NetworkList (context .Background (), types.NetworkListOptions {})
237
237
if err != nil {
0 commit comments