(l baker.Record, next func(baker.Record))
| 127 | } |
| 128 | |
| 129 | func (f *ClauseFilter) Process(l baker.Record, next func(baker.Record)) { |
| 130 | if f.matchClause(l, &f.topClause) { |
| 131 | next(l) |
| 132 | } else { |
| 133 | atomic.AddInt64(&f.numFilteredLines, 1) |
| 134 | } |
| 135 | } |
| 136 | |
| 137 | func (f *ClauseFilter) Stats() baker.FilterStats { |
| 138 | return baker.FilterStats{ |