(evt *event.Event, eventsc chan *event.Event)
| 166 | } |
| 167 | |
| 168 | func (r *reader) read(evt *event.Event, eventsc chan *event.Event) { |
| 169 | if evt.Type.OnlyState() { |
| 170 | return |
| 171 | } |
| 172 | if r.filter != nil && !r.filter.Run(evt) { |
| 173 | capDroppedByFilter.Add(1) |
| 174 | return |
| 175 | } |
| 176 | eventsc <- evt |
| 177 | capReadEvents.Add(1) |
| 178 | } |
| 179 | |
| 180 | func (r *reader) updateSnapshotters(evt *event.Event) error { |
| 181 | switch evt.Type { |