module Fluent::Compat::BufferedEventStreamMixin
Public Instance Methods
each(&block)
click to toggle source
# File lib/fluent/compat/output.rb, line 57 def each(&block) msgpack_each(&block) end
key()
click to toggle source
# File lib/fluent/compat/output.rb, line 65 def key metadata.tag end
repeatable?()
click to toggle source
# File lib/fluent/compat/output.rb, line 53 def repeatable? true end
to_msgpack_stream()
click to toggle source
# File lib/fluent/compat/output.rb, line 61 def to_msgpack_stream read end