build_records_array_to_put

in lib/fluent/plugin/out_kinesis.rb [251:269]

• 18 lines of code
• 3 McCabe index (conditional complexity)

    def build_records_array_to_put(data_list)
      records_array = []
      records = []
      records_payload_length = 0
      data_list.each{|data_to_put|
        payload = data_to_put[:data]
        partition_key = data_to_put[:partition_key]
        if records.length >= PUT_RECORDS_MAX_COUNT or (records_payload_length + payload.length + partition_key.length) >= PUT_RECORDS_MAX_DATA_SIZE
          records_array.push(records)
          records = []
          records_payload_length = 0
        end
        records.push(data_to_put)
        records_payload_length += (payload.length + partition_key.length)
      }
      records_array.push(records) unless records.empty?
      records_array
    end