mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
parent
a8d622b1b4
commit
e0eec78244
3 changed files with 7 additions and 7 deletions
|
@ -6,8 +6,8 @@ require "logstash/util"
|
|||
module LogStash module Util class WorkerThreadsDefaultPrinter
|
||||
|
||||
def initialize(settings)
|
||||
@setting = settings.fetch('pipeline-workers', 0)
|
||||
@default = settings.fetch('default-pipeline-workers', 0)
|
||||
@setting = settings.fetch(:pipeline_workers, 0)
|
||||
@default = settings.fetch(:default_pipeline_workers, 0)
|
||||
end
|
||||
|
||||
def visit(collector)
|
||||
|
|
|
@ -25,7 +25,7 @@ describe LogStash::Util::DefaultsPrinter do
|
|||
|
||||
context 'when the settings hash has content' do
|
||||
let(:worker_queue) { 42 }
|
||||
let(:settings) { {'pipeline-workers' => workers} }
|
||||
let(:settings) { {:pipeline_workers => workers} }
|
||||
it_behaves_like "a defaults printer"
|
||||
end
|
||||
end
|
||||
|
@ -42,7 +42,7 @@ describe LogStash::Util::DefaultsPrinter do
|
|||
|
||||
context 'when the settings hash has content' do
|
||||
let(:workers) { 13 }
|
||||
let(:settings) { {'pipeline-workers' => workers} }
|
||||
let(:settings) { {:pipeline_workers => workers} }
|
||||
|
||||
it_behaves_like "a defaults printer"
|
||||
end
|
||||
|
|
|
@ -19,7 +19,7 @@ describe LogStash::Util::WorkerThreadsDefaultPrinter do
|
|||
end
|
||||
|
||||
context 'when the settings hash has both user and default content' do
|
||||
let(:settings) { {'pipeline-workers' => 42, 'default-pipeline-workers' => 5} }
|
||||
let(:settings) { {:pipeline_workers => 42, :default_pipeline_workers => 5} }
|
||||
|
||||
it 'adds two strings' do
|
||||
expect(collector).to eq(["User set pipeline workers: 42", "Default pipeline workers: 5"])
|
||||
|
@ -27,7 +27,7 @@ describe LogStash::Util::WorkerThreadsDefaultPrinter do
|
|||
end
|
||||
|
||||
context 'when the settings hash has only user content' do
|
||||
let(:settings) { {'pipeline-workers' => 42} }
|
||||
let(:settings) { {:pipeline_workers => 42} }
|
||||
|
||||
it 'adds a string with user set pipeline workers' do
|
||||
expect(collector.first).to eq("User set pipeline workers: 42")
|
||||
|
@ -35,7 +35,7 @@ describe LogStash::Util::WorkerThreadsDefaultPrinter do
|
|||
end
|
||||
|
||||
context 'when the settings hash has only default content' do
|
||||
let(:settings) { {'default-pipeline-workers' => 5} }
|
||||
let(:settings) { {:default_pipeline_workers => 5} }
|
||||
|
||||
it 'adds a string with default pipeline workers' do
|
||||
expect(collector.first).to eq("Default pipeline workers: 5")
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue