class LogStash::Outputs::Kinetica::RetryTimerTask
Public Class Methods
new(pending, event, attempt)
click to toggle source
Calls superclass method
# File lib/logstash/outputs/kinetica.rb, line 127 def initialize(pending, event, attempt) @pending = pending @event = event @attempt = attempt super() end
Public Instance Methods
run()
click to toggle source
# File lib/logstash/outputs/kinetica.rb, line 134 def run @pending << [@event, @attempt] end