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

      context "and `every` is given as a string" do
        let(:every) { "5" }
        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
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
logstash-filter-sleep-3.0.7	spec/filters/sleep_spec.rb
logstash-filter-sleep-3.0.6	spec/filters/sleep_spec.rb
logstash-filter-sleep-3.0.5	spec/filters/sleep_spec.rb
logstash-filter-sleep-3.0.4	spec/filters/sleep_spec.rb
logstash-filter-sleep-3.0.3	spec/filters/sleep_spec.rb