github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

reformatting for style guide

Browse source
This commit is contained in:
John E. Vincent 2011-09-11 00:57:20 -04:00
parent 0c8f6fa91f
commit 08eadcba05
1 changed files with 6 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

15
lib/logstash/inputs/gelf.rb
View file

@ -24,13 +24,13 @@ class LogStash::Inputs::Gelf < LogStash::Inputs::Base
# Whether or not to remap the gelf message fields # Whether or not to remap the gelf message fields
# to logstash event fields or leave them # to logstash event fields or leave them
# intact. # intact.
#
# Default is true
#
# Remapping converts the following: # Remapping converts the following:
# full_message => event.message # full_message => event.message
# timestamp => event.timestamp # timestamp => event.timestamp
# host => event.source_host ##NYI as event.source_host cannot be set here # host + file => event.source
# file => event.source_path ##NYI as event.source_path cannot be set here
#
# Original message is parsed properly into event.fields
config :remap, :validate => :boolean, :default => true config :remap, :validate => :boolean, :default => true
public public
@ -101,11 +101,8 @@ class LogStash::Inputs::Gelf < LogStash::Inputs::Base
private private
def remap_gelf(event) def remap_gelf(event)
event.message = event.fields["full_message"] event.message = event.fields["full_message"]
event.timestamp = LogStash::Time.to_iso8601(DateTime.strptime(event.fields["timestamp"].to_s, "%s.%L" )) event.timestamp = LogStash::Time.to_iso8601(
DateTime.strptime(event.fields["timestamp"].to_s, "%s.%L" ))
event.source = "gelf://#{event.fields["host"]}#{event.fields["file"]}" event.source = "gelf://#{event.fields["host"]}#{event.fields["file"]}"
# Neither event.data, event.source_host or event.source_path are expose with setters
# For now, we'll just remap the full_message
##event.data["@source_host"] = event.fields["host"]
##event.data["@source_path"] = event.fields["file"]
end # def remap_gelf end # def remap_gelf
end # class LogStash::Inputs::Gelf end # class LogStash::Inputs::Gelf