mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
parent
1eef8c9be7
commit
6cb0b538e3
1 changed files with 4 additions and 1 deletions
|
@ -68,8 +68,9 @@ describe LogStash::FilterDelegator do
|
||||||
|
|
||||||
context "when the filter buffer events" do
|
context "when the filter buffer events" do
|
||||||
it "doesn't increment out" do
|
it "doesn't increment out" do
|
||||||
|
allow(metric).to receive(:increment).with(:time_ms, anything)
|
||||||
expect(metric).to receive(:increment).with(:in, events.size)
|
expect(metric).to receive(:increment).with(:in, events.size)
|
||||||
expect(metric).not_to receive(:increment)
|
expect(metric).not_to receive(:increment).with(:out, anything)
|
||||||
|
|
||||||
subject.multi_filter(events)
|
subject.multi_filter(events)
|
||||||
end
|
end
|
||||||
|
@ -92,6 +93,7 @@ describe LogStash::FilterDelegator do
|
||||||
end
|
end
|
||||||
|
|
||||||
it "increments the in/out of the metric" do
|
it "increments the in/out of the metric" do
|
||||||
|
allow(metric).to receive(:increment).with(:time_ms, anything)
|
||||||
expect(metric).to receive(:increment).with(:in, events.size)
|
expect(metric).to receive(:increment).with(:in, events.size)
|
||||||
expect(metric).to receive(:increment).with(:out, events.size * 2)
|
expect(metric).to receive(:increment).with(:out, events.size * 2)
|
||||||
|
|
||||||
|
@ -117,6 +119,7 @@ describe LogStash::FilterDelegator do
|
||||||
end
|
end
|
||||||
|
|
||||||
it "increments the in/out of the metric" do
|
it "increments the in/out of the metric" do
|
||||||
|
allow(metric).to receive(:increment).with(:time_ms, anything)
|
||||||
expect(metric).to receive(:increment).with(:in, events.size)
|
expect(metric).to receive(:increment).with(:in, events.size)
|
||||||
expect(metric).to receive(:increment).with(:out, events.size)
|
expect(metric).to receive(:increment).with(:out, events.size)
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue