Class: LogStash::Outputs::AzureLogAnalytics

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/outputs/microsoft-logstash-output-azure-loganalytics.rb

Instance Method Summary collapse

Instance Method Details

#multi_receive(events) ⇒ Object

def register



77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/logstash/outputs/microsoft-logstash-output-azure-loganalytics.rb', line 77

def multi_receive(events)
  events.each do |event|
    # creating document from event
    document = create_event_document(event)
    # Skip if document doesn't contain any items  
    next if (document.keys).length < 1
    
    @logger.trace("Adding event document - " + event.to_s)
    @logstash_resizable_event_buffer.add_event_document(document)

  end
end

#register ⇒ Object 



64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/logstash/outputs/microsoft-logstash-output-azure-loganalytics.rb', line 64

def register
  @logstash_configuration= build_logstash_configuration()
  # Validate configuration correctness 
  @logstash_configuration.validate_configuration()
  @logger.info("Logstash Azure Loganalytics output plugin configuration was found valid")

  # Initialize the logstash resizable buffer
  # This buffer will increase and decrease size according to the amount of messages inserted.
  # If the buffer reached the max amount of messages the amount will be increased until the limit
  @logstash_resizable_event_buffer=LogStashAutoResizeBuffer::new(@logstash_configuration)

end