Class: LogStash::Outputs::Kinetica::RetryTimerTask

Inherits:

Object

• Object
• LogStash::Outputs::Kinetica::RetryTimerTask

Defined in:

lib/logstash/outputs/kinetica.rb

Instance Method Summary

• #initialize(pending, event, attempt) ⇒ RetryTimerTask constructor

  A new instance of RetryTimerTask.

• #run ⇒ Object

Constructor Details

#initialize(pending, event, attempt) ⇒ RetryTimerTask

Returns a new instance of RetryTimerTask.

# File 'lib/logstash/outputs/kinetica.rb', line 127

def initialize(pending, event, attempt)
  @pending = pending
  @event = event
  @attempt = attempt
  super()
end

Instance Method Details

#run ⇒ Object

# File 'lib/logstash/outputs/kinetica.rb', line 134

def run
  @pending << [@event, @attempt]
end