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