aytac/orbiter
1
0
Fork 0
mirror of https://github.com/spaytac/orbiter.git synced 2026-01-22 10:24:41 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Format logrus has json

Browse Source
This commit is contained in:
Gianluca Arbezzano 2017-03-13 23:29:58 +00:00
parent 1709cf5150
commit d2a86fef18
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/events.go
View File

@ -10,11 +10,13 @@ import (
func Events(eventChannel chan *logrus.Entry) func(w http.ResponseWriter, r *http.Request) { func Events(eventChannel chan *logrus.Entry) func(w http.ResponseWriter, r *http.Request) {
return func(w http.ResponseWriter, r *http.Request) { return func(w http.ResponseWriter, r *http.Request) {
logrus.Info("New events") logrus.Info("New events")
formatter := &logrus.JSONFormatter{}
flusher, _ := w.(http.Flusher) flusher, _ := w.(http.Flusher)
for { for {
e := <-eventChannel e := <-eventChannel
fmt.Fprintf(w, "Ciao %d\n", e.Message) b, _ := formatter.Format(e)
flusher.Flush() // Trigger "chunked" encoding and send a chunk... fmt.Fprintf(w, string(b))
flusher.Flush()
} }
} }
} }