|
393 | 393 | expect(subject.send(:event_action_tuple, event)[1]).to include(:_index => "index_from_settings") |
394 | 394 | end |
395 | 395 | end |
396 | | - |
397 | | - context "when plugin's index is NOT specified" do |
398 | | - let(:options) { super().merge("index" => nil)} |
399 | | - |
400 | | - context "when the event contains an integration metadata index" do |
401 | | - let(:event_fields) { super().merge({"@metadata" => {"_ingest_document" => {"index" => "meta-document-index"}}}) } |
402 | | - |
403 | | - it "event's metadata index is used" do |
404 | | - expect(subject.send(:event_action_tuple, event)[1]).to include(:_index => "meta-document-index") |
405 | | - end |
406 | | - |
407 | | - context "when datastream settings are NOT configured" do |
408 | | - it "event's metadata index is used" do |
409 | | - expect(subject.send(:event_action_tuple, event)[1]).to include(:_index => "meta-document-index") |
410 | | - end |
411 | | - end |
412 | | - |
413 | | - context "when datastream settings are configured" do |
414 | | - let(:event_fields) { super().merge({"data_stream" => {"type" => "logs", "dataset" => "generic", "namespace" => "default"}}) } |
415 | | - |
416 | | - it "event's metadata index is used" do |
417 | | - expect(subject.send(:event_action_tuple, event)[1]).to include(:_index => "meta-document-index") |
418 | | - end |
419 | | - end |
420 | | - end |
421 | | - |
422 | | - context "when the event DOESN'T contain integration metadata index" do |
423 | | - let(:default_index_resolved) { event.sprintf(subject.default_index) } |
424 | | - |
425 | | - it "default index is used" do |
426 | | - expect(subject.send(:event_action_tuple, event)[1]).to include(:_index => default_index_resolved) |
427 | | - end |
428 | | - |
429 | | - context "when datastream settings are NOT configured" do |
430 | | - it "default index is used" do |
431 | | - expect(subject.send(:event_action_tuple, event)[1]).to include(:_index => default_index_resolved) |
432 | | - end |
433 | | - end |
434 | | - |
435 | | - context "when datastream settings are configured" do |
436 | | - let(:event_fields) { super().merge({"data_stream" => {"type" => "logs", "dataset" => "generic", "namespace" => "default"}}) } |
437 | | - |
438 | | - it "default index is used" do |
439 | | - expect(subject.send(:event_action_tuple, event)[1]).to include(:_index => default_index_resolved) |
440 | | - end |
441 | | - end |
442 | | - end |
443 | 396 | end |
444 | 397 |
|
445 | 398 | context "when plugin's index is NOT specified" do |
|
0 commit comments