create_driver

in benchmark/task.rake [77:96]

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

  def create_driver(type, conf = default_config)
    klass = case type
            when :streams
              Fluent::Plugin::KinesisStreamsOutput
            when :streams_aggregated
              Fluent::Plugin::KinesisStreamsAggregatedOutput
            when :firehose
              Fluent::Plugin::KinesisFirehoseOutput
            end
    conf += case type
            when :streams, :streams_aggregated
              "stream_name fluent-plugin-test"
            when :firehose
              "delivery_stream_name fluent-plugin-test"
            end

    Fluent::Test::Driver::Output.new(klass) do
    end.configure(conf)
  end