mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
c7f6cba5c8
This PR does a few modifications for our webserver:
- Add a PortRange setting type.
- allow the --http.port option to accept a port range or a single port, when a range is provided Logstash will incrementally try this list to find a free port for the webserver.
- Logstash will report in the log which port it is using. (INFO LEVEL)
- It refactors a few methods of the webserver.
- It adds test for the binding of the ports.
Notes:
Port range can be defined in the logstash.yml or pass via the command line like this.
`bin/logstash -e 'input { generator {}} output { null {}}' --log.level verbose --http.port 2000-2005`
Fixes #5774
108 lines
2.5 KiB
Ruby
108 lines
2.5 KiB
Ruby
# encoding: utf-8
|
|
API_ROOT = File.expand_path(File.join(File.dirname(__FILE__), "..", "..", "lib", "logstash", "api"))
|
|
|
|
require "stud/task"
|
|
require "logstash/devutils/rspec/spec_helper"
|
|
$LOAD_PATH.unshift(File.expand_path(File.dirname(__FILE__)))
|
|
require "lib/api/support/resource_dsl_methods"
|
|
require 'rspec/expectations'
|
|
require "logstash/settings"
|
|
require 'rack/test'
|
|
require 'rspec'
|
|
require "json"
|
|
|
|
def read_fixture(name)
|
|
path = File.join(File.dirname(__FILE__), "fixtures", name)
|
|
File.read(path)
|
|
end
|
|
|
|
module LogStash
|
|
class DummyAgent < Agent
|
|
def start_webserver
|
|
@webserver = Struct.new(:address).new("#{Socket.gethostname}:#{::LogStash::WebServer::DEFAULT_PORTS.first}")
|
|
end
|
|
def stop_webserver; end
|
|
end
|
|
end
|
|
|
|
##
|
|
# Class used to wrap and manage the execution of an agent for test,
|
|
# this helps a lot in order to have a more integrated test for the
|
|
# web api, could be also used for other use cases if generalized enought
|
|
##
|
|
class LogStashRunner
|
|
|
|
attr_reader :config_str, :agent, :pipeline_settings
|
|
|
|
def initialize
|
|
@config_str = "input { generator {count => 100 } } output { dummyoutput {} }"
|
|
|
|
args = {
|
|
"config.reload.automatic" => false,
|
|
"metric.collect" => true,
|
|
"log.level" => "debug",
|
|
"node.name" => "test_agent",
|
|
"http.port" => rand(9600..9700),
|
|
"http.environment" => "test",
|
|
"config.string" => @config_str,
|
|
"pipeline.batch.size" => 1,
|
|
"pipeline.workers" => 1
|
|
}
|
|
@settings = ::LogStash::SETTINGS.clone.merge(args)
|
|
|
|
@agent = LogStash::DummyAgent.new(@settings)
|
|
end
|
|
|
|
def start
|
|
# We start a pipeline that will generate a finite number of events
|
|
# before starting the expectations
|
|
agent.register_pipeline("main", @settings)
|
|
@agent_task = Stud::Task.new { agent.execute }
|
|
@agent_task.wait
|
|
end
|
|
|
|
def stop
|
|
agent.shutdown
|
|
end
|
|
end
|
|
|
|
##
|
|
# Method used to wrap up a request in between of a running
|
|
# pipeline, this makes the whole execution model easier and
|
|
# more contained as some threads might go wild.
|
|
##
|
|
def do_request(&block)
|
|
runner = LogStashRunner.new
|
|
runner.start
|
|
ret_val = block.call
|
|
runner.stop
|
|
ret_val
|
|
end
|
|
|
|
RSpec::Matchers.define :be_available? do
|
|
match do |plugin|
|
|
begin
|
|
Gem::Specification.find_by_name(plugin["name"])
|
|
true
|
|
rescue
|
|
false
|
|
end
|
|
end
|
|
end
|
|
|
|
shared_context "api setup" do
|
|
before :all do
|
|
@runner = LogStashRunner.new
|
|
@runner.start
|
|
end
|
|
|
|
after :all do
|
|
@runner.stop
|
|
end
|
|
|
|
include Rack::Test::Methods
|
|
|
|
def app()
|
|
described_class.new(nil, @runner.agent)
|
|
end
|
|
end
|