lib/logstash/outputs/s3.rb
# We start a task in the background for check for stale files and make sure we rotate them to S3 if needed.
We start a task in the background for check for stale files and make sure we rotate them to S3 if needed.
We start a task in the background for check for stale files and make sure we rotate them to S3 if needed .
def start_periodic_check
    @logger.debug("Start periodic rotation check")
    @periodic_check = Concurrent::TimerTask.new(:execution_interval => PERIODIC_CHECK_INTERVAL_IN_SECONDS) do
      @logger.debug("Periodic check for stale files")
      rotate_if_needed(@file_repository.keys)
    end
    @periodic_check.execute
  end
def start_periodic_check @logger . debug ( "Start periodic rotation check" ) @periodic_check = Concurrent :: TimerTask . new ( :execution_interval => PERIODIC_CHECK_INTERVAL_IN_SECONDS ) do @logger . debug ( "Periodic check for stale files" ) rotate_if_needed ( @file_repository . keys ) end @periodic_check . execute end
We start a task in the background for check for stale files and make sure we rotate them to S3 if needed.
We start a task in the background for check for stale files and make sure we rotate them to S3 if needed .