mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
Refactor to match newer event methods
This commit is contained in:
parent
800cafcf9f
commit
0f306d0012
1 changed files with 3 additions and 3 deletions
|
@ -49,8 +49,8 @@ class LogStash::Filters::Metaevent < LogStash::Filters::Base
|
|||
@logger.debug(["metaevent", @add_tag, "trigger", event])
|
||||
|
||||
event = LogStash::Event.new
|
||||
event.source_host = Socket.gethostname
|
||||
event.tags = @add_tag
|
||||
event["source"] = Socket.gethostname
|
||||
event["tags"] = [@add_tag
|
||||
|
||||
@metaevents << event
|
||||
@start_event = nil
|
||||
|
@ -61,7 +61,7 @@ class LogStash::Filters::Metaevent < LogStash::Filters::Base
|
|||
end
|
||||
|
||||
def within_period(event)
|
||||
time_delta = event.ruby_timestamp - @start_event.ruby_timestamp
|
||||
time_delta = event["@timestamp"] - @start_event["@timestamp"]
|
||||
time_delta >= 0 && time_delta <= @period
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue