vLab-BZH/logstream
2
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Detect tab-separated levels (VictoriaMetrics) and zerolog short levels

Browse Source 
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
cedricandClaude Opus 5.5 committed 2026-09-28 17:03:25 +02:00
1 parent a2c907079a
commit cd0307f6f6
1 file changed
+11 -6
Download Patch File Download Diff File Expand all files Collapse all files
docker.go
+11 -6
View File
@@ -579,12 +579,14 @@ func (m *DockerManager) emit(c DockerContainer, stream string, line []byte) {
} }
// Log level written by the application: JSON ("level":"error"), logfmt // Log level written by the application: JSON ("level":"error"), logfmt
// (level=warn), [ERROR], or an upper-case level word near the start. // (level=warn), [ERROR], a lower-case level between tabs (VictoriaMetrics),
// or an upper-case level word near the start (ERROR, zerolog's INF/WRN…).
var ( var (
levelJSON = regexp.MustCompile(`(?i)"(?:level|lvl|severity|log\.level)"\s*:\s*"([a-z]+)"`) levelJSON = regexp.MustCompile(`(?i)"(?:level|lvl|severity|log\.level)"\s*:\s*"([a-z]+)"`)
levelLogfmt = regexp.MustCompile(`(?i)\b(?:level|lvl|severity)="?([a-z]+)`) levelLogfmt = regexp.MustCompile(`(?i)\b(?:level|lvl|severity)="?([a-z]+)`)
levelBracket = regexp.MustCompile(`(?i)\[\s*(emerg|alert|crit|critical|fatal|panic|err|error|warn|warning|notice|info|debug|trace)\s*\]`) levelBracket = regexp.MustCompile(`(?i)\[\s*(emerg|alert|crit|critical|fatal|panic|err|error|warn|warning|notice|info|debug|trace)\s*\]`)
levelWord = regexp.MustCompile(`\b(EMERG|ALERT|CRIT|CRITICAL|FATAL|PANIC|ERR|ERROR|WARN|WARNING|NOTICE|INFO|DEBUG|TRACE)\b`) levelTab = regexp.MustCompile(`(?:^|\t)(debug|info|warn|warning|error|fatal|panic)\t`)
levelWord = regexp.MustCompile(`\b(EMERG|ALERT|CRIT|CRITICAL|FATAL|FTL|PANIC|PNC|ERR|ERROR|WARN|WARNING|WRN|NOTICE|INFO|INF|DEBUG|DBG|TRACE|TRC)\b`)
) )
func levelNum(word string) (int, bool) { func levelNum(word string) (int, bool) {
@@ -593,17 +595,17 @@ func levelNum(word string) (int, bool) {
return 0, true return 0, true
case "alert": case "alert":
return 1, true return 1, true
case "crit", "critical", "fatal", "panic": case "crit", "critical", "fatal", "ftl", "panic", "pnc":
return 2, true return 2, true
case "err", "error": case "err", "error":
return 3, true return 3, true
case "warn", "warning": case "warn", "warning", "wrn":
return 4, true return 4, true
case "notice": case "notice":
return 5, true return 5, true
case "info", "information": case "info", "information", "inf":
return 6, true return 6, true
case "debug", "trace": case "debug", "dbg", "trace", "trc":
return 7, true return 7, true
} }
return 0, false return 0, false
@@ -621,6 +623,9 @@ func detectLevel(s string) (int, bool) {
if len(head) > 60 { if len(head) > 60 {
head = head[:60] head = head[:60]
} }
if m := levelTab.FindStringSubmatch(head); m != nil {
return levelNum(m[1])
}
if m := levelWord.FindStringSubmatch(head); m != nil { if m := levelWord.FindStringSubmatch(head); m != nil {
return levelNum(m[1]) return levelNum(m[1])
} }