# File lib/fluent/plugin/buf_memory.rb, line 75 def initialize super end
# File lib/fluent/plugin/buf_memory.rb, line 94 def before_shutdown(out) if @flush_at_shutdown synchronize do @map.each_key {|key| push(key) } while pop(out) end end end end
# File lib/fluent/plugin/buf_memory.rb, line 85 def configure(conf) super unless @flush_at_shutdown $log.warn "When flush_at_shutdown is false, buf_memory discards buffered chunks at shutdown." $log.warn "Please confirm 'flush_at_shutdown false' configuration is correct or not." end end
# File lib/fluent/plugin/buf_memory.rb, line 114 def enqueue(chunk) end
# File lib/fluent/plugin/buf_memory.rb, line 106 def new_chunk(key) MemoryBufferChunk.new(key) end
# File lib/fluent/plugin/buf_memory.rb, line 110 def resume return [], {} end