Sha256: 421c2705fad0979a471af1f6ad75578825ea1e72b360871a3c057647769eaca2
Contents?: true
Size: 987 Bytes
Versions: 3
Compression:
Stored size: 987 Bytes
Contents
shared_context "execution_context" do
let(:pipeline) { double("pipeline") }
let(:pipeline_id) { :main }
let(:agent) { double("agent") }
let(:plugin_id) { :plugin_id }
let(:plugin_type) { :plugin_type }
let(:dlq_writer) { double("dlq_writer") }
let(:execution_context) do
::LogStash::ExecutionContext.new(pipeline, agent, plugin_id, plugin_type, dlq_writer)
end
before do
allow(pipeline).to receive(:pipeline_id).and_return(pipeline_id)
allow(pipeline).to receive(:agent).and_return(agent)
end
end
shared_context "api setup" do
before :all do
clear_data_dir
settings = mock_settings
config_string = "input { generator {id => 'api-generator-pipeline' count => 100 } } output { dummyoutput {} }"
settings.set("config.string", config_string)
@agent = make_test_agent(settings)
@agent.execute
end
after :all do
@agent.shutdown
end
include Rack::Test::Methods
def app()
described_class.new(nil, @agent)
end
end
Version data entries
3 entries across 3 versions & 1 rubygems