class Fluent::Plugin::TailInput::TailWatcher::RotateHandler
Public Class Methods
new(log, &on_rotate)
click to toggle source
# File lib/fluent/plugin/in_tail.rb, line 1163 def initialize(log, &on_rotate) @log = log @inode = nil @fsize = -1 # first @on_rotate = on_rotate end
Public Instance Methods
on_notify(stat)
click to toggle source
# File lib/fluent/plugin/in_tail.rb, line 1170 def on_notify(stat) if stat.nil? inode = nil fsize = 0 else inode = stat.ino fsize = stat.size end if @inode != inode || fsize < @fsize @on_rotate.call(stat) end @inode = inode @fsize = fsize rescue @log.error $!.to_s @log.error_backtrace end