# File lib/fluent/plugin/out_null.rb, line 40 def initialize super @delayed = false @feed_proc = nil end
# File lib/fluent/plugin/out_null.rb, line 30 def prefer_buffered_processing false end
# File lib/fluent/plugin/out_null.rb, line 34 def prefer_delayed_commit @delayed end
# File lib/fluent/plugin/out_null.rb, line 46 def process(tag, es) # Do nothing end
# File lib/fluent/plugin/out_null.rb, line 56 def try_write(chunk) if @feed_proc @feed_proc.call(chunk) end # not to commit chunks for testing # commit_write(chunk.unique_id) end
# File lib/fluent/plugin/out_null.rb, line 50 def write(chunk) if @feed_proc @feed_proc.call(chunk) end end