format_for_api

in lib/fluent/plugin/kinesis.rb [131:142]

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

      def format_for_api(&block)
        converted = block.call
        size = size_of_values(converted)
        if size > @max_record_size
          raise ExceedMaxRecordSizeError.new(size, converted)
        end
        converted.to_msgpack
      rescue SkipRecordError => e
        log.error(truncate e)
        ''
      end