Class: Fluent::DelayedEvent

Inherits:

Coolio::TimerWatcher

• Object
• Coolio::TimerWatcher
• Fluent::DelayedEvent

Defined in:

lib/fluent/plugin/out_delayed.rb

Instance Method Summary

• #initialize(tag, event, chain, output, delay) ⇒ DelayedEvent constructor

  A new instance of DelayedEvent.

• #on_timer ⇒ Object

Constructor Details

#initialize(tag, event, chain, output, delay) ⇒ DelayedEvent

Returns a new instance of DelayedEvent.

# File 'lib/fluent/plugin/out_delayed.rb', line 21

def initialize(tag, event, chain,output, delay)
  super(delay, false)
  @tag = tag
  @event = event
  @output = output
  @chain = chain
end

Instance Method Details

#on_timer ⇒ Object

# File 'lib/fluent/plugin/out_delayed.rb', line 29

def on_timer
  @output.emit(@tag, @event, @chain)
  detach
end