Sha256: 66f037bb0e4e1722a51e9c31a473110f5c2889a770618a7a0d0358769190f3ba
Contents?: true
Size: 1 KB
Versions: 57
Compression:
Stored size: 1 KB
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.register_pipeline(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
57 entries across 57 versions & 6 rubygems