Sha256: 62514b25aff1f71358d90a1415b9ccd92ddfde864edb4a647392476f057bd7cc
Contents?: true
Size: 1.95 KB
Versions: 5
Compression:
Stored size: 1.95 KB
Contents
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/filters/metricize"
describe LogStash::Filters::Metricize do
describe "all defaults" do
config <<-CONFIG
filter {
metricize {
metrics => ["metric1"]
}
}
CONFIG
sample("message" => "hello world", "metric1" => "value1") do
insist { subject }.is_a? Array
insist { subject.length } == 2
subject.each_with_index do |s,i|
if i == 0 # last one should be original event
insist { s["metric1"] } == "value1"
reject { s }.include?("metric")
else
insist { s["metric"]} == "metric1"
insist { s["value"]} == "value1"
reject { s }.include?("metric1")
end
insist { s["message"] } == "hello world"
end
end
end
describe "Complex use" do
config <<-CONFIG
filter {
metricize {
drop_original_event => true
metric_field_name => "key"
value_field_name => "value"
metrics => ["metric0", "metric1","metric2"]
}
}
CONFIG
sample("metric1" => "value1", "metric2" => "value2", "metric3" => "value3", "message" => "hello world") do
insist { subject }.is_a? Array
insist { subject.length } == 2
# Verify first metrics event
insist { subject[0]["message"] } == "hello world"
insist { subject[0]["metric3"] } == "value3"
insist { subject[0]["key"] } == "metric1"
insist { subject[0]["value"] } == "value1"
reject { subject[0] }.include?("metric1")
reject { subject[0] }.include?("metric2")
# Verify second metrics event
insist { subject[1]["message"] } == "hello world"
insist { subject[1]["metric3"] } == "value3"
insist { subject[1]["key"] } == "metric2"
insist { subject[1]["value"] } == "value2"
reject { subject[1] }.include?("metric1")
reject { subject[1] }.include?("metric2")
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems