logtree: implement raw logging
Test Plan: Covered by new tests.
X-Origin-Diff: phab/D640
GitOrigin-RevId: 786ab2851710bf2819dcb91571b3567e8da3e377
diff --git a/core/pkg/logtree/journal_subscriber.go b/core/pkg/logtree/journal_subscriber.go
index d6a91db..e6c7c62 100644
--- a/core/pkg/logtree/journal_subscriber.go
+++ b/core/pkg/logtree/journal_subscriber.go
@@ -55,12 +55,12 @@
}
for _, filter := range sub.filters {
- if !filter(e.origin, e.leveled.severity) {
+ if !filter(e) {
continue
}
}
select {
- case sub.dataC <- &LogEntry{LeveledPayload: e.leveled, DN: e.origin}:
+ case sub.dataC <- e.external():
default:
atomic.AddUint64(&sub.missed, 1)
}