helpers.rb in logstash-codec-multiline-2.0.8

- old
+ new

@@ -71,10 +71,14 @@
     def trace_for(symbol)
       params = @tracer.assoc(symbol)
       params.nil? ? false : params.last
     end
 
+    def full_trace_for(symbol)
+      @tracer.select{|array| array[0] == symbol}.map(&:last)
+    end
+
     def clear()
       @tracer.clear()
     end
   end
 
@@ -89,10 +93,19 @@
     def warn?() true; end
     def error?() true; end
   end
 
   class AutoFlushTracer < TracerBase
-    def auto_flush() @tracer.push [:auto_flush, true]; end
+    def auto_flush() simulate_execution_delay; @tracer.push [:auto_flush, true]; end
+    def set_delay(delay)
+      @delay = delay
+    end
+
+    def simulate_execution_delay
+      return if @delay.nil? || @delay.zero?
+      sleep @delay
+      @tracer.push [:delay, Time.now.to_f]
+    end
   end
 
   class IdentityMapCodecTracer < TracerBase
     def clone() self.class.new; end
     def decode(data) @tracer.push [:decode, data]; end