class Fluent::FileBuffer
def enqueue(chunk)
def enqueue(chunk) path = chunk.path mp = path[@buffer_path_prefix.length..-(@buffer_path_suffix.length+1)] m = PATH_MATCH.match(mp) encoded_key = m ? m[1] : "" npath = make_path(encoded_key, "q") chunk.mv(npath) end