Sha256: fdc5f400a4210e3afb0722b52d41b3f2036a69554949db9fb12f53873d163936
Contents?: true
Size: 967 Bytes
Versions: 57
Compression:
Stored size: 967 Bytes
Contents
# encoding: utf-8
require "spec_helper"
require "logstash/util/dead_letter_queue_manager"
require "logstash/execution_context"
describe LogStash::ExecutionContext do
let(:pipeline) { double("pipeline") }
let(:pipeline_id) { :main }
let(:plugin_id) { "plugin_id" }
let(:plugin_type) { "plugin_type" }
let(:dlq_writer) { LogStash::Util::DummyDeadLetterQueueWriter.new }
before do
allow(pipeline).to receive(:pipeline_id).and_return(pipeline_id)
end
subject { described_class.new(pipeline, plugin_id, plugin_type, dlq_writer) }
it "returns the `pipeline_id`" do
expect(subject.pipeline_id).to eq(pipeline_id)
end
it "returns the pipeline" do
expect(subject.pipeline).to eq(pipeline)
end
it "returns the plugin-specific dlq writer" do
expect(subject.dlq_writer.plugin_type).to eq(plugin_type)
expect(subject.dlq_writer.plugin_id).to eq(plugin_id)
expect(subject.dlq_writer.inner_writer).to eq(dlq_writer)
end
end
Version data entries
57 entries across 57 versions & 6 rubygems