Sha256: 6aa9eca86c7eebd34b4852b922596bb2082107a746881874932b25a467e04987

Contents?: true

Size: 1.46 KB

Versions: 1

Compression:

Stored size: 1.46 KB

Contents

require_relative '../helper'
require 'fluent/test/driver/parser'
require 'fluent/plugin/parser'

class ApacheErrorParserTest < ::Test::Unit::TestCase
  def setup
    Fluent::Test.setup
    @parser = Fluent::Test::Driver::Parser.new(Fluent::Plugin.new_parser('apache_error'))
    @parser.configure({})
    @expected = {
      'level' => 'error',
      'client' => '127.0.0.1',
      'message' => 'client denied by server configuration'
    }
  end

  def test_parse
    @parser.instance.parse('[Wed Oct 11 14:32:52 2000] [error] [client 127.0.0.1] client denied by server configuration') { |time, record|
      assert_equal(event_time('Wed Oct 11 14:32:52 2000'), time)
      assert_equal(@expected, record)
    }
  end

  def test_parse_with_pid
    @parser.instance.parse('[Wed Oct 11 14:32:52 2000] [error] [pid 1000] [client 127.0.0.1] client denied by server configuration') { |time, record|
      assert_equal(event_time('Wed Oct 11 14:32:52 2000'), time)
      assert_equal(@expected.merge('pid' => '1000'), record)
    }
  end

  def test_parse_without_client
    @parser.instance.parse('[Wed Oct 11 14:32:52 2000] [notice] Apache/2.2.15 (Unix) DAV/2 configured -- resuming normal operations') { |time, record|
      assert_equal(event_time('Wed Oct 11 14:32:52 2000'), time)
      assert_equal({
                     'level' => 'notice',
                     'message' => 'Apache/2.2.15 (Unix) DAV/2 configured -- resuming normal operations'
                   }, record)
    }
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
fluentd-0.14.1 test/plugin/test_parser_apache_error.rb