boyska/circolog
1
2
Fork 1
Code Issues 6 Pull requests 1 Releases Wiki Activity

add -fmt=json to circolog-tail

Browse source
This commit is contained in:
boyska 2019-03-24 20:17:09 +01:00
parent 7dc3b5a7bb
commit 00cb135913
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
cmd/circolog-tail/main.go
View file

@ -57,6 +57,9 @@ func main() {
addr := flag.String("addr", "localhost:9080", "http service address") addr := flag.String("addr", "localhost:9080", "http service address")
querySocket := flag.String("socket", "", "Path to a unix domain socket for the HTTP server") querySocket := flag.String("socket", "", "Path to a unix domain socket for the HTTP server")
backlogLimit := flag.Int("n", -1, "Limit the backlog length, defaults to no limit (-1)") backlogLimit := flag.Int("n", -1, "Limit the backlog length, defaults to no limit (-1)")
var format formatter.Format
format = formatter.FormatSyslog
flag.Var(&format, "fmt", "Output format [syslog|json]")
var filter filtering.ExprValue var filter filtering.ExprValue
flag.Var(&filter, "where", "sql-like query to filter logs") flag.Var(&filter, "where", "sql-like query to filter logs")
// TODO: change to color-mode=auto/no/always // TODO: change to color-mode=auto/no/always
@ -120,11 +123,13 @@ func main() {
if !filter.Validate(parsed) { if !filter.Validate(parsed) {
continue continue
} }
if err := formatter.WriteFormatted(os.Stdout, formatter.FormatSyslog, parsed); err != nil { if err := formatter.WriteFormatted(os.Stdout, format, parsed); err != nil {
log.Println("error printing", err) log.Println("error printing", err)
} }
if format == formatter.FormatSyslog { // oops
fmt.Println() fmt.Println()
} }
}
}() }()
for { for {