retry_records

in lib/fluent/plugin/kinesis_helper/api.rb [144:152]

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

          def retry_records(failed_records)
            case request_type
            when :streams, :firehose
              failed_records.map{|r| r[:original] }
            when :streams_aggregated
              failed_records.first[:original]
            end
          end