Sha256: 881a7ee60b8ea39a2c0a0b028966a25e238130e85337ba3c75556629b0dda251
Contents?: true
Size: 709 Bytes
Versions: 12
Compression:
Stored size: 709 Bytes
Contents
require "logstash/devutils/rspec/spec_helper"
require "logstash/outputs/kinesis"
require "logstash/codecs/plain"
require "logstash/event"
require "json"
describe LogStash::Outputs::Kinesis do
let(:config) {{
"stream_name" => "test",
"region" => "ap-southeast-2",
"metrics_level" => "none"
}}
let(:sample_event) { LogStash::Event.new }
KPL = com.amazonaws.services.kinesis.producer
context "when receiving message" do
it "sends record to Kinesis" do
expect_any_instance_of(KPL::KinesisProducer).to receive(:addUserRecord)
output = LogStash::Outputs::Kinesis.new (config)
output.register
output.receive(sample_event)
output.teardown
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems