format

in lib/fluent/plugin/out_kinesis.rb [114:126]

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

    def format(tag, time, record)
      data = {
        data: @dump_class.dump(record),
        partition_key: get_key(:partition_key,record)
      }

      if @explicit_hash_key or @explicit_hash_key_proc
        data[:explicit_hash_key] = get_key(:explicit_hash_key,record)
      end

      data.to_msgpack
    end