Merge pull request #18 from logicmonitor/Adding_resourceType_metatada_in_logs

Adding resource type metatada in logs

Author: prakalp05

lib/logstash/outputs/lmlogs.rb

@@ -308,6 +308,7 @@ def processEvent(event)
     if @include_metadata
       lmlogs_event = event_json
       lmlogs_event.delete("@timestamp")  # remove redundant timestamp field
+      lmlogs_event["_resource.type"]="Logstash"
       if lmlogs_event.dig("event", "original") != nil
         lmlogs_event["event"].delete("original") # remove redundant log field
       end
@@ -355,4 +356,4 @@ def isValidPayloadSize(documents,lmlogs_event,max_payload_size)
     documents.push(lmlogs_event)
     return documents
   end
-end # class LogStash::Outputs::LMLogs
+end # class LogStash::Outputs::LMLogs

lib/logstash/outputs/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module LmLogsLogstashPlugin
-  VERSION = '2.0.3'
+  VERSION = '2.0.4'
 end

spec/outputs/metadata_spec.rb

@@ -44,8 +44,7 @@ def check_same_hash(h1,h2)
       expected_event = {
         "message" => "hello this is log 1",
         "timestamp" => logstash_event.timestamp,
-        "_lm.resourceId" => {"system.hostname" => "host1"},
-
+        "_lm.resourceId" => {"system.hostname" => "host1"}
       }
       puts " actual : #{constructed_event} \n expected : #{expected_event}"
 
@@ -77,7 +76,8 @@ def check_same_hash(h1,h2)
         "nested" => {"nested2" => {"nested3" => "value",
                                 "nested3b" => "value"},
                     "nested_ignored" => "somevalue"
-                  }
+                  },
+        "_resource.type"=>"Logstash"
       }
       puts " actual : #{constructed_event} \n expected : #{expected_event}"
       puts " hash diff : #{Hashdiff.diff(constructed_event,expected_event)}"