Class: LogStash::Inputs::Azure::LookBackPositionProvider

Inherits:

Object

Object
LogStash::Inputs::Azure::LookBackPositionProvider

Includes:: Util::Loggable

Defined in:: lib/logstash/inputs/look_back_position_provider.rb

Instance Method Summary collapse

#apply(t) ⇒ Object
#initialize(look_back_seconds) ⇒ LookBackPositionProvider constructor

A new instance of LookBackPositionProvider.

Constructor Details

#initialize(look_back_seconds) ⇒ `LookBackPositionProvider`

Returns a new instance of LookBackPositionProvider.

# 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

Instance Method Details

#apply(t) ⇒ `Object`



21
22
23

# File 'lib/logstash/inputs/look_back_position_provider.rb', line 21

def apply(t)
  EventPosition.fromEnqueuedTime(@look_back);
end