diff --git a/cmd/sync/main.go b/cmd/sync/main.go index 25aa50a2a..d21ce9d35 100644 --- a/cmd/sync/main.go +++ b/cmd/sync/main.go @@ -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 @@ -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) } } @@ -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 +}