class Fluent::Plugin::FileServiceDiscovery::StatWatcher

Public Class Methods

new(path, log, &callback) click to toggle source
Calls superclass method
# File lib/fluent/plugin/sd_file.rb, line 141
def initialize(path, log, &callback)
  @path = path
  @log = log
  @callback = callback
  super(@path)
end

Public Instance Methods

on_change(prev_stat, cur_stat) click to toggle source
# File lib/fluent/plugin/sd_file.rb, line 148
def on_change(prev_stat, cur_stat)
  @callback.call(prev_stat, cur_stat)
rescue => e
  @log.error(e)
end