Sha256: 2516b34f121161cd11bc5425a5b5ee6513983098ac9c7eecdd5cc3e28c8ba945
Contents?: true
Size: 1.83 KB
Versions: 5
Compression:
Stored size: 1.83 KB
Contents
require "logstash/devutils/rspec/spec_helper"
require "logstash/codecs/es_bulk"
require "logstash/event"
require "insist"
describe LogStash::Codecs::ESBulk do
subject do
next LogStash::Codecs::ESBulk.new
end
context "#decode" do
it "should return 4 events from json data" do
data = <<-HERE
{ "index" : { "_index" : "test", "_type" : "type1", "_id" : "1" } }
{ "field1" : "value1" }
{ "delete" : { "_index" : "test", "_type" : "type1", "_id" : "2" } }
{ "create" : { "_index" : "test", "_type" : "type1", "_id" : "3" } }
{ "field1" : "value3" }
{ "update" : {"_id" : "1", "_type" : "type1", "_index" : "index1"} }
{ "doc" : {"field2" : "value2"} }
HERE
count = 0
subject.decode(data) do |event|
case count
when 0
insist { event.get("[@metadata][_id]") } == "1"
insist { event.get("[@metadata][action]") } == "index"
insist { event.get("field1") } == "value1"
when 1
insist { event.get("[@metadata][_id]") } == "2"
insist { event.get("[@metadata][action]") } == "delete"
when 2
insist { event.get("[@metadata][_id]") } == "3"
insist { event.get("[@metadata][action]") } == "create"
insist { event.get("field1") } == "value3"
when 3
insist { event.get("[@metadata][_id]") } == "1"
insist { event.get("[@metadata][action]") } == "update"
insist { event.get("[doc][field2]") } == "value2"
end
count += 1
end
insist { count } == 4
end
end
context "fail to process non-bulk event then continue" do
it "continues after a fail" do
decoded = false
subject.decode("something that isn't a bulk event\n") do |event|
decoded = true
end
insist { decoded } == false
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems