acually postoverflow _before_ reprocessing (#1739)
Co-authored-by: sabban <15465465+sabban@users.noreply.github.com>
This commit is contained in:
parent
b2130b1593
commit
f3317f78d5
|
@ -144,10 +144,6 @@ LOOP:
|
||||||
buckets.Bucket_map.Delete(event.Overflow.Mapkey)
|
buckets.Bucket_map.Delete(event.Overflow.Mapkey)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
if event.Overflow.Reprocess {
|
|
||||||
log.Debugf("Overflow being reprocessed.")
|
|
||||||
input <- event
|
|
||||||
}
|
|
||||||
/* process post overflow parser nodes */
|
/* process post overflow parser nodes */
|
||||||
event, err := parser.Parse(postOverflowCTX, event, postOverflowNodes)
|
event, err := parser.Parse(postOverflowCTX, event, postOverflowNodes)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -158,6 +154,10 @@ LOOP:
|
||||||
log.Printf("[%s] is whitelisted, skip.", *event.Overflow.Alert.Message)
|
log.Printf("[%s] is whitelisted, skip.", *event.Overflow.Alert.Message)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
if event.Overflow.Reprocess {
|
||||||
|
log.Debugf("Overflow being reprocessed.")
|
||||||
|
input <- event
|
||||||
|
}
|
||||||
if dumpStates {
|
if dumpStates {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue