class Fluent::Plugin::NullOutput
Attributes
delayed[RW]
feed_proc[RW]
Public Class Methods
new()
click to toggle source
Calls superclass method
Fluent::Compat::Output.new
# File lib/fluent/plugin/out_null.rb, line 40 def initialize super @delayed = false @feed_proc = nil end
Public Instance Methods
prefer_buffered_processing()
click to toggle source
# File lib/fluent/plugin/out_null.rb, line 30 def prefer_buffered_processing false end
prefer_delayed_commit()
click to toggle source
# File lib/fluent/plugin/out_null.rb, line 34 def prefer_delayed_commit @delayed end
process(tag, es)
click to toggle source
# File lib/fluent/plugin/out_null.rb, line 46 def process(tag, es) # Do nothing end
try_write(chunk)
click to toggle source
# 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
write(chunk)
click to toggle source
# File lib/fluent/plugin/out_null.rb, line 50 def write(chunk) if @feed_proc @feed_proc.call(chunk) end end