Sha256: 746ce8719382d6e7fa27a3cb7c93bbe5e52fbf551a931f441730335662f0dfa6
Contents?: true
Size: 808 Bytes
Versions: 6
Compression:
Stored size: 808 Bytes
Contents
require_relative '../spec_helper'
require 'logstash/filters/unique'
describe LogStash::Filters::Unique do
it "should register" do
plugin = LogStash::Plugin.lookup("filter", "unique").new("fields" => [])
expect {plugin.register}.to_not raise_error
end
context "when having an array of elements" do
let(:plugin) { LogStash::Filters::Unique.new("fields" => "array") }
let(:data) { { "array" => [1,2,1,2,1,2,1,2], "other_field" => "dummy string" }}
let(:event) { LogStash::Event.new(data) }
before(:each) do
plugin.filter(event)
end
it "filter all events in the array property" do
expect(event["array"]).to eq([1,2])
end
it "does not touch non filtered properties" do
expect(event["other_field"]).to eq("dummy string")
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems