Sha256: ad35512a73cf1f46008cbc177c2699b72a46e7a1ed4b1320cf94fb9d011e174a
Contents?: true
Size: 1.1 KB
Versions: 47
Compression:
Stored size: 1.1 KB
Contents
# encoding: utf-8
require "spec_helper"
require_relative "../../support/helpers"
require "logstash/pipelines_registry"
require "logstash/pipeline_action/stop"
require "logstash/pipeline"
describe LogStash::PipelineAction::Stop do
let(:pipeline_config) { "input { dummyblockinginput {} } output { null {} }" }
let(:pipeline_id) { :main }
let(:pipeline) { mock_pipeline_from_string(pipeline_config) }
let(:pipelines) { chm = LogStash::PipelinesRegistry.new; chm.create_pipeline(pipeline_id, pipeline) { true }; chm }
let(:agent) { double("agent") }
subject { described_class.new(pipeline_id) }
before do
clear_data_dir
pipeline.start
end
after do
pipeline.shutdown
end
it "returns the pipeline_id" do
expect(subject.pipeline_id).to eq(:main)
end
it "shutdown the running pipeline" do
expect { subject.execute(agent, pipelines) }.to change(pipeline, :running?).from(true).to(false)
end
it "removes the pipeline from the running pipelines" do
expect { subject.execute(agent, pipelines) }.to change { pipelines.running_pipelines.keys }.from([:main]).to([])
end
end
Version data entries
47 entries across 47 versions & 1 rubygems