Method Process

filter/external_match.go:253–264

(l baker.Record, next func(baker.Record))

}

func (f *ExternalMatch) Process(l baker.Record, next func(baker.Record)) {
	f.mx.RLock()
	_, ok := f.values[string(l.Get(f.cfg.fidx))]
	f.mx.RUnlock()

	if ok != f.cfg.KeepOnMatch {
		atomic.AddInt64(&f.numFilteredLines, 1)
		return
	}

	next(l)
}