class Fluent::MemoryBuffer
def before_shutdown(out)
def before_shutdown(out) synchronize do @map.each_key {|key| push(key) } while pop(out) end end end
def configure(conf)
def configure(conf) super end
def enqueue(chunk)
def enqueue(chunk) end
def initialize
def initialize super end
def new_chunk(key)
def new_chunk(key) MemoryBufferChunk.new(key) end
def resume
def resume return [], {} end