func (nsp *NetworkSecurityProbe) DispatchEvent(event model.ProbeEvent) {
	// Enrich event
	nsp.Cache.EnrichEvent(event)
	for eventType, processors := range nsp.Processors {
		if eventType == model.AnyEventType || eventType == event.GetEventType() {
			for _, p := range processors {
				select {
				case p.GetEventChan() <- event:
					break
				default:
					nspLogger.Warn("Processor not ready")
					break
				}
			}
		}
	}
}
// DispatchEvent - Dispatches an event to the processors
Dispatches an event to the processors
// DispatchEvent - Dispatches an event to the processors
func (nsp *NetworkSecurityProbe) DispatchEvent(event model.ProbeEvent) {
	nsp.Cache.EnrichEvent(event)
	for eventType, processors := range nsp.Processors {
		if eventType == model.AnyEventType || eventType == event.GetEventType() {
			for _, p := range processors {
				select {
				case p.GetEventChan() <- event:
					break
				default:
					nspLogger.Warn("Processor not ready")
					break
				}
			}
		}
	}
}
func ( nsp * NetworkSecurityProbe ) DispatchEvent ( event model . ProbeEvent ) { nsp . Cache . EnrichEvent ( event ) for eventType , processors := range nsp . Processors { if eventType == model . AnyEventType || eventType == event . GetEventType ( ) { for _ , p := range processors { select { case p . GetEventChan ( ) <- event : break default : nspLogger . Warn ( " " ) break } } } } }
Dispatches an event to the processors
Dispatches an event to the processors
// Enrich event