|
5 | 5 | context 'with a policy with a maximum number of documents' do |
6 | 6 | let (:policy) { small_max_doc_policy } |
7 | 7 | let (:ilm_policy_name) { "logstash-policy-custom"} |
8 | | - let (:settings) { super.merge("ilm_policy" => ilm_policy_name)} |
| 8 | + let (:settings) { super().merge("ilm_policy" => ilm_policy_name)} |
9 | 9 |
|
10 | 10 | it 'should rollover when the policy max docs is reached' do |
11 | 11 | put_policy(@es, ilm_policy_name, policy) |
|
54 | 54 | context 'with a policy where the maximum number of documents is not reached' do |
55 | 55 | let (:policy) { large_max_doc_policy } |
56 | 56 | let (:ilm_policy_name) { "logstash-policy-custom-policy"} |
57 | | - let (:settings) { super.merge("ilm_policy" => ilm_policy_name)} |
| 57 | + let (:settings) { super().merge("ilm_policy" => ilm_policy_name)} |
58 | 58 |
|
59 | 59 | it 'should ingest into a single index when max docs is not reached' do |
60 | 60 | put_policy(@es,ilm_policy_name, policy) |
|
119 | 119 | context 'with an existing policy that will roll over' do |
120 | 120 | let (:policy) { small_max_doc_policy } |
121 | 121 | let (:ilm_policy_name) { "logstash-policy-3_docs"} |
122 | | - let (:settings) { super.merge("ilm_policy" => ilm_policy_name)} |
| 122 | + let (:settings) { super().merge("ilm_policy" => ilm_policy_name)} |
123 | 123 |
|
124 | 124 | it 'should not roll over indices' do |
125 | 125 | subject.register |
|
155 | 155 |
|
156 | 156 | context 'with a custom template name' do |
157 | 157 | let (:template_name) { "logstash_custom_template_name" } |
158 | | - let (:settings) { super.merge('template_name' => template_name)} |
| 158 | + let (:settings) { super().merge('template_name' => template_name)} |
159 | 159 |
|
160 | 160 | it 'should not write the ILM settings into the template' do |
161 | 161 | subject.register |
|
195 | 195 | subject { LogStash::Outputs::ElasticSearch.new(settings) } |
196 | 196 |
|
197 | 197 | context 'when ilm is enabled in Logstash' do |
198 | | - let (:settings) { super.merge!({ 'ilm_enabled' => true }) } |
| 198 | + let (:settings) { super().merge!({ 'ilm_enabled' => true }) } |
199 | 199 |
|
200 | 200 | it 'should raise a configuration error' do |
201 | 201 | expect do |
|
210 | 210 | end |
211 | 211 |
|
212 | 212 | context 'when ilm is disabled in Logstash' do |
213 | | - let (:settings) { super.merge!({ 'ilm_enabled' => false }) } |
| 213 | + let (:settings) { super().merge!({ 'ilm_enabled' => false }) } |
214 | 214 |
|
215 | 215 | it_behaves_like 'an ILM disabled Logstash' |
216 | 216 | end |
217 | 217 |
|
218 | 218 | context 'when ilm is set to auto in Logstash' do |
219 | | - let (:settings) { super.merge!({ 'ilm_enabled' => 'auto' }) } |
| 219 | + let (:settings) { super().merge!({ 'ilm_enabled' => 'auto' }) } |
220 | 220 |
|
221 | 221 | it_behaves_like 'an ILM disabled Logstash' |
222 | 222 | end |
|
286 | 286 |
|
287 | 287 | context 'when using the default policy' do |
288 | 288 | context 'with a custom pattern' do |
289 | | - let (:settings) { super.merge("ilm_pattern" => "000001")} |
| 289 | + let (:settings) { super().merge("ilm_pattern" => "000001")} |
290 | 290 | it 'should create a rollover alias' do |
291 | 291 | expect(@es.indices.exists_alias(name: "logstash")).to be_falsey |
292 | 292 | subject.register |
|
346 | 346 |
|
347 | 347 | context 'when not using the default policy' do |
348 | 348 | let (:ilm_policy_name) {"logstash-policy-small"} |
349 | | - let (:settings) { super.merge("ilm_policy" => ilm_policy_name)} |
| 349 | + let (:settings) { super().merge("ilm_policy" => ilm_policy_name)} |
350 | 350 | let (:policy) { small_max_doc_policy } |
351 | 351 |
|
352 | 352 | before do |
|
363 | 363 |
|
364 | 364 | context 'when using a time based policy' do |
365 | 365 | let (:ilm_policy_name) {"logstash-policy-time"} |
366 | | - let (:settings) { super.merge("ilm_policy" => ilm_policy_name)} |
| 366 | + let (:settings) { super().merge("ilm_policy" => ilm_policy_name)} |
367 | 367 | let (:policy) { max_age_policy("1d") } |
368 | 368 |
|
369 | 369 | before do |
|
409 | 409 | let (:template) { "spec/fixtures/template-with-policy-es6x.json" } |
410 | 410 | end |
411 | 411 |
|
412 | | - let (:settings) { super.merge("template" => template, |
| 412 | + let (:settings) { super().merge("template" => template, |
413 | 413 | "index" => "overwrite-4")} |
414 | 414 |
|
415 | 415 | it 'should not overwrite the index patterns' do |
|
426 | 426 | let (:ilm_rollover_alias) { "logstash_the_cat_in_the_hat" } |
427 | 427 | let (:index) { ilm_rollover_alias } |
428 | 428 | let(:expected_index) { index } |
429 | | - let (:settings) { super.merge("ilm_policy" => ilm_policy_name, |
| 429 | + let (:settings) { super().merge("ilm_policy" => ilm_policy_name, |
430 | 430 | "template" => template, |
431 | 431 | "ilm_rollover_alias" => ilm_rollover_alias)} |
432 | 432 |
|
|
480 | 480 |
|
481 | 481 | context 'with a different template_name' do |
482 | 482 | let (:template_name) { "logstash_custom_template_name" } |
483 | | - let (:settings) { super.merge('template_name' => template_name)} |
| 483 | + let (:settings) { super().merge('template_name' => template_name)} |
484 | 484 |
|
485 | 485 | it_behaves_like 'an ILM enabled Logstash' |
486 | 486 |
|
|
514 | 514 | end |
515 | 515 |
|
516 | 516 | context 'when ilm_enabled is the default' do |
517 | | - let (:settings) { super.tap{|x|x.delete('ilm_enabled')}} |
| 517 | + let (:settings) { super().tap{|x|x.delete('ilm_enabled')}} |
518 | 518 |
|
519 | 519 | if ESHelper.es_version_satisfies?(">=7.0") |
520 | 520 | context 'when Elasticsearch is version 7 or above' do |
|
530 | 530 | end |
531 | 531 |
|
532 | 532 | context 'with ilm disabled' do |
533 | | - let (:settings) { super.merge('ilm_enabled' => false )} |
| 533 | + let (:settings) { super().merge('ilm_enabled' => false )} |
534 | 534 |
|
535 | 535 | it_behaves_like 'an ILM disabled Logstash' |
536 | 536 | end |
537 | 537 |
|
538 | 538 | context 'with ilm disabled using a string' do |
539 | | - let (:settings) { super.merge('ilm_enabled' => 'false' )} |
| 539 | + let (:settings) { super().merge('ilm_enabled' => 'false' )} |
540 | 540 |
|
541 | 541 | it_behaves_like 'an ILM disabled Logstash' |
542 | 542 | end |
|
0 commit comments