Sha256: 158de4cf7f8ee292f3a5d5128f9ece49bdbc87de37a71cbdf91ca166c0b41c1d
Contents?: true
Size: 693 Bytes
Versions: 11
Compression:
Stored size: 693 Bytes
Contents
# encoding: utf-8
require "logstash/util/loggable"
java_import java.util.function.Function
java_import com.microsoft.azure.eventhubs.EventPosition
java_import java.time.Instant
module LogStash
module Inputs
module Azure
class LookBackPositionProvider
include Function
include LogStash::Util::Loggable
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
def apply(t)
EventPosition.fromEnqueuedTime(@look_back);
end
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems