Sha256: 5901ea79b9306dfb1c7f5e9fc0fe0bdb7733b4d5816789af93161f9c7d5b6bd0
Contents?: true
Size: 1.85 KB
Versions: 5
Compression:
Stored size: 1.85 KB
Contents
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require 'avro'
require 'logstash/codecs/avro'
require 'logstash/event'
describe LogStash::Codecs::Avro do
let (:avro_config) {{'schema_uri' => '
{"type": "record", "name": "Test",
"fields": [{"name": "foo", "type": ["null", "string"]},
{"name": "bar", "type": "int"}]}'}}
let (:test_event) { LogStash::Event.new({"foo" => "hello", "bar" => 10}) }
subject do
allow_any_instance_of(LogStash::Codecs::Avro).to \
receive(:open_and_read).and_return(avro_config['schema_uri'])
next LogStash::Codecs::Avro.new(avro_config)
end
context "#decode" do
it "should return an LogStash::Event from avro data" do
schema = Avro::Schema.parse(avro_config['schema_uri'])
dw = Avro::IO::DatumWriter.new(schema)
buffer = StringIO.new
encoder = Avro::IO::BinaryEncoder.new(buffer)
dw.write(test_event.to_hash, encoder)
subject.decode(buffer.string) do |event|
insist { event.is_a? LogStash::Event }
insist { event["foo"] } == test_event["foo"]
insist { event["bar"] } == test_event["bar"]
end
end
end
context "#encode" do
it "should return avro data from a LogStash::Event" do
got_event = false
subject.on_event do |event, data|
schema = Avro::Schema.parse(avro_config['schema_uri'])
datum = StringIO.new(data)
decoder = Avro::IO::BinaryDecoder.new(datum)
datum_reader = Avro::IO::DatumReader.new(schema)
record = datum_reader.read(decoder)
insist { record["foo"] } == test_event["foo"]
insist { record["bar"] } == test_event["bar"]
insist { event.is_a? LogStash::Event }
got_event = true
end
subject.encode(test_event)
insist { got_event }
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems