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 + %[