Sha256: 9727da2ddf636ee3fb64c2890d0691684c2cdaa6f06ade06a0a6757ab00733b6
Contents?: true
Size: 1.79 KB
Versions: 20
Compression:
Stored size: 1.79 KB
Contents
# encoding: utf-8
require "spec_helper"
require "logstash/pipeline"
require "logstash/pipeline_reporter"
require_relative "../support/helpers"
require_relative "../support/mocks_classes"
#TODO: Figure out how to add more tests that actually cover inflight events
#This will require some janky multithreading stuff
describe LogStash::PipelineReporter do
let(:generator_count) { 5 }
let(:config) do
"input { generator { count => #{generator_count} } } output { dummyoutput {} } "
end
let(:pipeline) { mock_pipeline_from_string(config)}
let(:reporter) { pipeline.reporter }
before do
allow(LogStash::Plugin).to receive(:lookup).with("output", "dummyoutput").and_return(::LogStash::Outputs::DummyOutput)
allow(LogStash::Plugin).to receive(:lookup).with("input", "generator").and_call_original
allow(LogStash::Plugin).to receive(:lookup).with("codec", "plain").and_call_original
@pre_snapshot = reporter.snapshot
pipeline.run
@post_snapshot = reporter.snapshot
end
after do
pipeline.shutdown
end
describe "events filtered" do
it "should start at zero" do
expect(@pre_snapshot.events_filtered).to eql(0)
end
it "should end at the number of generated events" do
expect(@post_snapshot.events_filtered).to eql(generator_count)
end
end
describe "events consumed" do
it "should start at zero" do
expect(@pre_snapshot.events_consumed).to eql(0)
end
it "should end at the number of generated events" do
expect(@post_snapshot.events_consumed).to eql(generator_count)
end
end
describe "inflight count" do
it "should be zero before running" do
expect(@pre_snapshot.inflight_count).to eql(0)
end
it "should be zero after running" do
expect(@post_snapshot.inflight_count).to eql(0)
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems