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