Sha256: 14e77f2988cddec5baa68f136d61e564a4a718d5c1f601ee05af89b718e47ba3

Contents?: true

Size: 1.02 KB

Versions: 17

Compression:

Stored size: 1.02 KB

Contents

# encoding: utf-8
require "spec_helper"
require_relative "../../support/helpers"
require "logstash/pipeline_action/stop"
require "logstash/pipeline"
require "logstash/instrument/null_metric"

describe LogStash::PipelineAction::Stop do
  let(:pipeline_config) { "input { generator {} } output { null {} }" }
  let(:pipeline_id) { :main }
  let(:pipeline) { mock_pipeline_from_string(pipeline_config) }
  let(:pipelines) { { :main => pipeline } }
  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.include?(pipeline_id) }.from(true).to(false)
  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version Path
logstash-core-6.2.4-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.2.3-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.1.4-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.2.2-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.2.1-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.2.0-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.1.3-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.1.2-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.1.1-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.1.0-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.0.1-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.0.0-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.0.0.rc2-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.0.0.rc1-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.0.0.beta2-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.0.0.beta1-java spec/logstash/pipeline_action/stop_spec.rb
logstash-core-6.0.0.alpha2-java spec/logstash/pipeline_action/stop_spec.rb