File tree Expand file tree Collapse file tree 1 file changed +12
-13
lines changed
Expand file tree Collapse file tree 1 file changed +12
-13
lines changed Original file line number Diff line number Diff line change @@ -33,19 +33,18 @@ impl TimedDedupe {
3333 pub fn transform_one ( & mut self , event : Event ) -> Option < Event > {
3434 let cache_entry = build_cache_entry ( & event, & self . fields ) ;
3535 let now = Instant :: now ( ) ;
36- let drop_event = if self . time_config . refresh_on_drop {
37- self . cache
38- . put ( cache_entry, now)
39- . is_some_and ( |time| now. duration_since ( time) < self . time_config . max_age_ms )
40- } else if self
41- . cache
42- . get ( & cache_entry)
43- . is_some_and ( |time| now. duration_since ( * time) < self . time_config . max_age_ms )
44- {
45- true
46- } else {
47- self . cache . put ( cache_entry, now) ;
48- false
36+ let drop_event = match self . cache . get ( & cache_entry) {
37+ Some ( & time) => {
38+ let drop = now. duration_since ( time) < self . time_config . max_age_ms ;
39+ if self . time_config . refresh_on_drop || !drop {
40+ self . cache . put ( cache_entry, now) ;
41+ }
42+ drop
43+ }
44+ None => {
45+ self . cache . put ( cache_entry, now) ;
46+ false
47+ }
4948 } ;
5049 if drop_event {
5150 emit ! ( DedupeEventsDropped { count: 1 } ) ;
You can’t perform that action at this time.
0 commit comments