ProcessEvent pushes the event into processor chain. Processors are applied sequentially, so we have to make sure that any processor providing additional context to the next processor is defined first in the chain. If one processor fails, the next processor in chain is invoked.
(evt *event.Event)
| 34 | // sure that any processor providing additional context to the next processor is defined first in the chain. If |
| 35 | // one processor fails, the next processor in chain is invoked. |
| 36 | ProcessEvent(evt *event.Event) (*event.Event, error) |
| 37 | // Close closes the processor chain and frees all allocated resources. |
| 38 | Close() error |
| 39 | } |
no outgoing calls