class LogStash::Inputs::Azure::LookBackPositionProvider
Public Class Methods
new(look_back_seconds)
click to toggle source
# File lib/logstash/inputs/look_back_position_provider.rb, line 15 def initialize(look_back_seconds) @logger = self.logger @look_back = Instant.ofEpochSecond(Instant.now.getEpochSecond - look_back_seconds.to_i) @logger.debug("Look back date/time: #{@look_back}") end
Public Instance Methods
apply(t)
click to toggle source
# File lib/logstash/inputs/look_back_position_provider.rb, line 21 def apply(t) EventPosition.fromEnqueuedTime(@look_back); end