diff --git a/internal/streams/streams.go b/internal/streams/streams.go index ff0f5654..2a43e1ab 100644 --- a/internal/streams/streams.go +++ b/internal/streams/streams.go @@ -119,7 +119,7 @@ func GetOrPatch(query url.Values) *Stream { // check if name param provided if name := query.Get("name"); name != "" { - log.Info().Msgf("[streams] create new stream url=%s", source) + log.Info().Msgf("[streams] create new stream %s", name) return Patch(name, source) } @@ -143,6 +143,8 @@ func Delete(id string) { delete(streams, id) } -var log zerolog.Logger -var streams = map[string]*Stream{} -var streamsMu sync.Mutex +var ( + log zerolog.Logger + streams = map[string]*Stream{} + streamsMu sync.Mutex +)