Class: LogStash::Filters::Sleep
- Inherits:
-
Base
- Object
- Base
- LogStash::Filters::Sleep
- Defined in:
- lib/logstash/filters/sleep.rb
Overview
Sleep a given amount of time. This will cause logstash to stall for the given amount of time. This is useful for rate limiting, etc.
Instance Method Summary collapse
Instance Method Details
#filter(event) ⇒ Object
80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 |
# File 'lib/logstash/filters/sleep.rb', line 80 def filter(event) @count += 1 case @time when Integer, Float; time = @time when nil; # nothing else; time = event.sprintf(@time).to_f end if @replay clock = event..to_f if @last_clock delay = clock - @last_clock time = delay/time if time > 0 @logger.debug? && @logger.debug("Sleeping", :delay => time) sleep(time) end end @last_clock = clock else if @count >= @every.to_f @count = 0 @logger.debug? && @logger.debug("Sleeping", :delay => time) sleep(time) end end filter_matched(event) end |
#register ⇒ Object
68 69 70 71 72 73 74 75 76 77 |
# File 'lib/logstash/filters/sleep.rb', line 68 def register if @replay && @time.nil? # Default time multiplier is 1 when replay is set. @time = 1 end if @time.nil? raise ArgumentError, "Missing required parameter 'time' for input/eventlog" end @count = 0 end |