Consumer is the core component in the event processing pipeline. The raw event is offloaded from the session buffer, then parsed and converted to typed representation with process state attached to it. The event consumer is responsible for enriching the event with additional attributes. The event is
| 34 | // with additional attributes. The event is sent to the queue where |
| 35 | // all registered listeners are executed. |
| 36 | type Consumer struct { |
| 37 | q *event.Queue |
| 38 | sequencer *event.Sequencer |
| 39 | processors processors.Chain |
| 40 | psnap ps.Snapshotter |
| 41 | config *config.Config |
| 42 | filter filter.Filter |
| 43 | isClosing bool |
| 44 | } |
| 45 | |
| 46 | // NewConsumer builds a new event consumer. |
| 47 | func NewConsumer( |
nothing calls this directly
no outgoing calls
no test coverage detected