Class: Fluent::PingMessageInput

Inherits:
Input
  • Object
show all
Includes:
Mixin::ConfigPlaceholders
Defined in:
lib/fluent/plugin/in_ping_message.rb

Instance Method Summary collapse

Instance Method Details

#pingloop ⇒ Object 



32
33
34
35
36
37
38
39
40
41
 
# File 'lib/fluent/plugin/in_ping_message.rb', line 32

def pingloop
  @last_checked = Fluent::Engine.now
  loop do
    sleep 0.5
    if Fluent::Engine.now - @last_checked >= @interval
      @last_checked = Fluent::Engine.now
      Fluent::Engine.emit(@tag, Fluent::Engine.now, {'data' => @data})
    end
  end
end

#shutdown ⇒ Object 



22
23
24
25
26
 
# File 'lib/fluent/plugin/in_ping_message.rb', line 22

def shutdown
  super
  @loop.terminate
  @loop.join
end

#start ⇒ Object 



17
18
19
20
 
# File 'lib/fluent/plugin/in_ping_message.rb', line 17

def start
  super
  start_pingloop
end

#start_pingloop ⇒ Object 



28
29
30
 
# File 'lib/fluent/plugin/in_ping_message.rb', line 28

def start_pingloop
  @loop = Thread.new(&method(:pingloop))
end