Add method for testing filtered_with_time

This change allows plugin developers to test their filter_with_time plugins without sideloading a new test driver. Signed-off-by: Takuro Ashie <[email protected]>
fluent · Nov 23, 2022 · 7147700 · 7147700
1 parent c0f1db9
commit 7147700
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/fluent/test/driver/filter.rb b/lib/fluent/test/driver/filter.rb
@@ -37,6 +37,10 @@ def filtered_records
           @filtered.map {|_time, record| record }
         end
 
+        def filtered_time
+          @filtered.map {|_time, record| _time }
+        end
+
         def instance_hook_after_started
           super
           filter_hook = ->(time, record) { @filtered << [time, record] }