Sha256: b4eb8a4bb2bacc959c78a6590321b6665357824435517e366a037a2db05dcf81
Contents?: true
Size: 780 Bytes
Versions: 16
Compression:
Stored size: 780 Bytes
Contents
# encoding: utf-8
require "logstash/inputs/beats"
require "logstash/event"
require "spec_helper"
require "thread"
describe LogStash::Inputs::Beats::CodecCallbackListener do
let(:data) { "Hello world" }
let(:map) do
{
"beat" => { "hostname" => "newhost" }
}
end
let(:path) { "/var/log/message" }
let(:transformer) { double("codec_transformer") }
let(:queue_timeout) { 1 }
let(:event) { LogStash::Event.new }
let(:queue) { Queue.new }
before do
allow(transformer).to receive(:transform).with(event, map).and_return(event)
end
subject { described_class.new(data, map, path, transformer, queue) }
it "expose the data" do
expect(subject.data).to eq(data)
end
it "expose the path" do
expect(subject.path).to eq(path)
end
end
Version data entries
16 entries across 16 versions & 1 rubygems