Sha256: 4c0ef74e9cc7a9000cba6717d143675098d890ae7d968709d6716000425261ff
Contents?: true
Size: 1.17 KB
Versions: 7
Compression:
Stored size: 1.17 KB
Contents
# encoding: utf-8
require_relative "../spec_helper"
require "logstash/plugin"
require "logstash/event"
describe LogStash::Filters::Sleep do
let(:time) { 1 }
subject { LogStash::Filters::Sleep.new("time" => time) }
let(:properties) { {:name => "foo"} }
let(:event) { LogStash::Event.new(properties) }
it "should register without errors" do
plugin = LogStash::Plugin.lookup("filter", "sleep").new("time" => time)
expect { plugin.register }.to_not raise_error
end
describe "sleep for a given time" do
let(:time) { 5 }
before(:each) do
subject.register
end
it "should sleep for N seconds and continue" do
expect(subject).to receive(:sleep).with(5)
subject.filter(event)
end
context "when using every N events" do
let(:messages) { 20 }
let(:every) { 5 }
subject { LogStash::Filters::Sleep.new("time" => time, "every" => every ) }
before(:each) do
subject.register
end
it "should sleep for N seconds and continue" do
expect(subject).to receive(:sleep).with(5).exactly(4).times
messages.times do
subject.filter(event)
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems