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