Skip to content

Commit ba8245f

Browse files
Update log format
Co-authored-by: Dean Coakley <dean.s.coakley@gmail.com>
1 parent c987214 commit ba8245f

File tree

1 file changed

+26
-2
lines changed

1 file changed

+26
-2
lines changed

cmd/sync/main.go

Lines changed: 26 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,11 @@ func main() {
128128
}
129129

130130
if len(added) > 0 || len(removed) > 0 || len(updated) > 0 {
131-
log.Printf("Updated HTTP servers of %v; Added: %+v, Removed: %+v, Updated: %+v", upstream, added, removed, updated)
131+
addedAddresses := getUpstreamServerAddresses(added)
132+
removedAddresses := getUpstreamServerAddresses(removed)
133+
updatedAddresses := getUpstreamServerAddresses(updated)
134+
log.Printf("Updated HTTP servers of %v for group %v ; Added: %+v, Removed: %+v, Updated: %+v",
135+
upstream.Name, upstream.ScalingGroup, addedAddresses, removedAddresses, updatedAddresses)
132136
}
133137
} else {
134138
var upsServers []nginx.StreamUpstreamServer
@@ -150,7 +154,11 @@ func main() {
150154
}
151155

152156
if len(added) > 0 || len(removed) > 0 || len(updated) > 0 {
153-
log.Printf("Updated Stream servers of %v; Added: %+v, Removed: %+v, Updated: %+v", upstream, added, removed, updated)
157+
addedAddresses := getStreamUpstreamServerAddresses(added)
158+
removedAddresses := getStreamUpstreamServerAddresses(removed)
159+
updatedAddresses := getStreamUpstreamServerAddresses(updated)
160+
log.Printf("Updated Stream servers of %v for group %v ; Added: %+v, Removed: %+v, Updated: %+v",
161+
upstream.Name, upstream.ScalingGroup, addedAddresses, removedAddresses, updatedAddresses)
154162
}
155163
}
156164

@@ -164,3 +172,19 @@ func main() {
164172
}
165173
}
166174
}
175+
176+
func getUpstreamServerAddresses(server []nginx.UpstreamServer) []string {
177+
var upstreamServerAddr []string
178+
for _, s := range server {
179+
upstreamServerAddr = append(upstreamServerAddr, s.Server)
180+
}
181+
return upstreamServerAddr
182+
}
183+
184+
func getStreamUpstreamServerAddresses(server []nginx.StreamUpstreamServer) []string {
185+
var streamUpstreamServerAddr []string
186+
for _, s := range server {
187+
streamUpstreamServerAddr = append(streamUpstreamServerAddr, s.Server)
188+
}
189+
return streamUpstreamServerAddr
190+
}

0 commit comments

Comments
 (0)