Navigation Menu

Skip to content

Commit

Permalink
test: use Fluent::Test::Helpers for v0.14
Browse files Browse the repository at this point in the history
  • Loading branch information
kenhys committed Apr 11, 2017
1 parent 54971f0 commit 8a8e614
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 5 deletions.
4 changes: 3 additions & 1 deletion test/test_input.rb
Expand Up @@ -22,15 +22,17 @@
require "webrick/httpresponse"

require "fluent/test"
require 'fluent/test/helpers'
require "fluent/plugin/in_groonga"

require "http_parser"

class GroongaInputTest < Test::Unit::TestCase
include Fluent::Test::Helpers
setup :before => :append
def setup_fluent
Fluent::Test.setup
@now = Time.parse("2012-10-26T08:45:42Z").to_i
@now = event_time("2012-10-26T08:45:42Z").to_i
Fluent::Engine.now = @now
end

Expand Down
10 changes: 6 additions & 4 deletions test/test_output.rb
Expand Up @@ -22,12 +22,14 @@
require "webrick/httpresponse"

require "fluent/test"
require 'fluent/test/helpers'
require "fluent/plugin/out_groonga"
require "fluent/test/driver/output"

require "http_parser"

class GroongaOutputTest < Test::Unit::TestCase
include Fluent::Test::Helpers
setup :before => :append
def setup_fluent
Fluent::Test.setup
Expand Down Expand Up @@ -99,7 +101,7 @@ class CommandTest < self
def test_basic_command
@response_body = JSON.generate([[0, 0.0, 0.0], true])
driver = create_driver
time = Time.parse("2012-10-26T08:45:42Z").to_i
time = event_time("2012-10-26T08:45:42Z").to_i
driver.run(default_tag: "groonga.command.table_create") do
driver.feed(time, {"name" => "Users"})
end
Expand All @@ -119,7 +121,7 @@ def configuration
def test_one_message
@response_body = JSON.generate([[0, 0.0, 0.0], [1]])
driver = create_driver
time = Time.parse("2012-10-26T08:45:42Z").to_i
time = event_time("2012-10-26T08:45:42Z").to_i
driver.run(default_tag: "log") do
driver.feed(time, {"message" => "1st message"})
end
Expand All @@ -132,7 +134,7 @@ def test_one_message
def test_multiple_messages
@response_body = JSON.generate([[0, 0.0, 0.0], [2]])
driver = create_driver
time = Time.parse("2012-10-26T08:45:42Z").to_i
time = event_time("2012-10-26T08:45:42Z").to_i
driver.run(default_tag: "log") do
driver.feed(time, {"message" => "1st message"})
driver.feed(time + 1, {"message" => "2nd message"})
Expand Down Expand Up @@ -233,7 +235,7 @@ def actual_output_fd
class CommandTest < self
def test_basic_command
driver = create_driver
time = Time.parse("2012-10-26T08:45:42Z").to_i
time = event_time("2012-10-26T08:45:42Z").to_i
driver.run(default_tag: "groonga.command.table_create") do
driver.feed(time, {"name" => "Users"})
end
Expand Down

0 comments on commit 8a8e614

Please sign in to comment.