Skip to content

Commit

Permalink
Update log format
Browse files Browse the repository at this point in the history
Co-authored-by: Dean Coakley <dean.s.coakley@gmail.com>
  • Loading branch information
LorcanMcVeigh and Dean-Coakley authored Sep 29, 2020
1 parent c987214 commit ba8245f
Showing 1 changed file with 26 additions and 2 deletions.
28 changes: 26 additions & 2 deletions cmd/sync/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,11 @@ func main() {
}

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

if len(added) > 0 || len(removed) > 0 || len(updated) > 0 {
log.Printf("Updated Stream servers of %v; Added: %+v, Removed: %+v, Updated: %+v", upstream, added, removed, updated)
addedAddresses := getStreamUpstreamServerAddresses(added)
removedAddresses := getStreamUpstreamServerAddresses(removed)
updatedAddresses := getStreamUpstreamServerAddresses(updated)
log.Printf("Updated Stream servers of %v for group %v ; Added: %+v, Removed: %+v, Updated: %+v",
upstream.Name, upstream.ScalingGroup, addedAddresses, removedAddresses, updatedAddresses)
}
}

Expand All @@ -164,3 +172,19 @@ func main() {
}
}
}

func getUpstreamServerAddresses(server []nginx.UpstreamServer) []string {
var upstreamServerAddr []string
for _, s := range server {
upstreamServerAddr = append(upstreamServerAddr, s.Server)
}
return upstreamServerAddr
}

func getStreamUpstreamServerAddresses(server []nginx.StreamUpstreamServer) []string {
var streamUpstreamServerAddr []string
for _, s := range server {
streamUpstreamServerAddr = append(streamUpstreamServerAddr, s.Server)
}
return streamUpstreamServerAddr
}

0 comments on commit ba8245f

Please sign in to comment.