lib/logstash/outputs/google_cloud_storage.rb
# start_uploader periodically sends flush events through the log rotater
start_uploader periodically sends flush events through the log rotater
start_uploader periodically sends flush events through the log rotater
def start_uploader
    @uploader_thread = Thread.new do
      Stud.interval(@uploader_interval_secs) do
        @log_rotater.writeln(nil)
      end
    end
  end
def start_uploader @uploader_thread = Thread . new do Stud . interval ( @uploader_interval_secs ) do @log_rotater . writeln ( nil ) end end end
start_uploader periodically sends flush events through the log rotater
start_uploader periodically sends flush events through the log rotater