convert_record

in lib/fluent/plugin/kinesis_helper/format.rb [59:74]

• 15 lines of code
• 5 McCabe index (conditional complexity)

      def convert_record(tag, time, record)
        unless record.is_a? Hash
          raise InvalidRecordError, record
        end
        converted = convert_format(tag, time, record)
        converted[:data] += "\n" if @append_new_line
        if converted[:data].size > MaxRecordSize
          raise ExceedMaxRecordSizeError, converted[:data]
        else
          converted
        end
      rescue SkipRecordError => e
        log.error(truncate e)
        nil
      end