write

in src/fluent-plugin-mdsd/lib/fluent/plugin/out_mdsd.rb [81:97]

• 14 lines of code
• 2 McCabe index (conditional complexity)

        def write(chunk)
            if use_source_timestamp
                chunk.msgpack_each {|(tag, time, record)|
                    
                    
                    record[emit_timestamp_name] = Time.at(time)
                    handle_record(tag, record)
                }
            else
                chunk.msgpack_each {|(tag, record)|
                    record[emit_timestamp_name] = Time.now
                    handle_record(tag, record)
                }
            end
            @log.flush
        end