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

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-input-azureiothub-0.1.15	lib/logstash/inputs/look_back_position_provider.rb