Process processes a single Record, and then optionally sends it to next filter in the chain. Process might mutate the Record, adding/modifying/removing fields, and might decide to throw it away, or pass it to next filter in chain by calling the next() function. In some cases, a filter might generate
(l Record, next func(Record))
| 94 | // it points to a function that wraps up the filtering chain and sends |
| 95 | // the Record to the output. |
| 96 | Process(l Record, next func(Record)) |
| 97 | |
| 98 | // Stats returns stats about the filter |
| 99 | Stats() FilterStats |
no outgoing calls