Skip ingester tailer filtering if no filter is set

pull/1083/head
Marco Pracucci 6 years ago committed by Sandeep Sukhani
parent 3e0621ebf6
commit 42040f2d5b
  1. 7
      pkg/ingester/tailer.go

@ -128,9 +128,14 @@ func (t *tailer) send(stream logproto.Stream) {
}
func (t *tailer) filterEntriesInStream(stream *logproto.Stream) {
// Optimization: skip filtering entirely, if no filter is set
if t.filter == nil {
return
}
var filteredEntries []logproto.Entry
for _, e := range stream.Entries {
if t.filter == nil || t.filter([]byte(e.Line)) {
if t.filter([]byte(e.Line)) {
filteredEntries = append(filteredEntries, e)
}
}

Loading…
Cancel
Save