Sha256: 357ed86de7709b3bc484ec53198260861bbca89e1ab1b8a5488821db5eb917fb
Contents?: true
Size: 1.14 KB
Versions: 4
Compression:
Stored size: 1.14 KB
Contents
# encoding: utf-8
require_relative "../spec_helper"
require "logstash/plugin"
require "logstash/event"
describe LogStash::Codecs::Fluent do
let(:properties) { {:name => "foo" } }
let(:event) { LogStash::Event.new(properties) }
it "should register without errors" do
plugin = LogStash::Plugin.lookup("codec", "fluent").new
expect { plugin.register }.to_not raise_error
end
describe "event encoding" do
it "should encode as message pack format" do
subject.on_event do |event, data|
fields = MessagePack.unpack(data)
expect(fields[0]).to eq("log")
expect(fields[2]["name"]).to eq("foo")
end
subject.encode(event)
end
end
describe "event decoding" do
let(:tag) { "mytag" }
let(:epochtime) { event.timestamp.to_i }
let(:data) { LogStash::Util.normalize(event.to_hash) }
let(:message) do
MessagePack.pack([tag, epochtime, data.merge(LogStash::Event::TIMESTAMP => event.timestamp.to_iso8601)])
end
it "should decode without errors" do
subject.decode(message) do |event|
expect(event["name"]).to eq("foo")
end
end
end
end
Version data entries
4 entries across 4 versions & 1 rubygems