spec/out_stats_spec.rb in fluent-plugin-stats-0.3.1 vs spec/out_stats_spec.rb in fluent-plugin-stats-0.3.2
- old
+ new
@@ -68,19 +68,19 @@
let(:time) { Time.now.to_i }
let(:messages) do
[
{"4xx_count"=>"1","5xx_count"=>2,"reqtime_max"=>6,"reqtime_min"=>1,"reqtime_avg"=>3},
{"4xx_count"=>"2","5xx_count"=>2,"reqtime_max"=>5,"reqtime_min"=>2,"reqtime_avg"=>2},
- {"4xx_count"=>"3","5xx_count"=>2,"reqtime_max"=>1,"reqtime_min"=>3,"reqtime_avg"=>4},
+ {:'4xx_count'=>"3",:'5xx_count'=>2,:reqtime_max=>1,:reqtime_min=>3,:reqtime_avg=>4},
]
end
let(:emit) do
driver.run { messages.each {|message| driver.emit(message, time) } }
- driver.instance.flush_emit(0)
+ driver.instance.flush_emit
end
let(:empty_emit) do
- driver.instance.flush_emit(0)
+ driver.instance.flush_emit
end
context 'sum/max/min/avg' do
let(:config) do
CONFIG + %[
@@ -217,10 +217,10 @@
context 'aggregate' do
let(:emit) do
driver.run { messages.each {|message| driver.emit_with_tag(message, time, 'foo.bar') } }
driver.run { messages.each {|message| driver.emit_with_tag(message, time, 'foo.bar2') } }
- driver.instance.flush_emit(0)
+ driver.instance.flush_emit
end
context 'aggregate all' do
let(:config) do
CONFIG + %[