Class: Fluent::DiskUsage

Inherits:
Input
  • Object
show all
Defined in:
lib/fluent/plugin/in_diskusage.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



14
15
16
17
 
# File 'lib/fluent/plugin/in_diskusage.rb', line 14

def configure(conf)
  super
  require 'sys/filesystem'
end

#output ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/fluent/plugin/in_diskusage.rb', line 31

def output
  filestats = Sys::Filesystem.stat(@mountpoint)
  total_bytes = filestats.block_size * filestats.blocks
  free_bytes = filestats.block_size * filestats.blocks_available
  used_bytes = total_bytes - free_bytes
  used_percent = 0
  free_percent = 0
  if total_bytes.nonzero?  
    used_percent = used_bytes / total_bytes.to_f
    free_percent = free_bytes / total_bytes.to_f
  end
  record = {"label"=>@label,"total_bytes"=>total_bytes,"free_bytes"=>free_bytes,"used_bytes"=>used_bytes,"used_percent"=>used_percent,"free_percent"=>free_percent}

  time = Fluent::Engine.now
  router.emit(tag,time,record)
end

#run ⇒ Object 



24
25
26
27
28
29
 
# File 'lib/fluent/plugin/in_diskusage.rb', line 24

def run
  while true
    output
  sleep @refresh_interval
  end
end

#shutdown ⇒ Object 



48
49
50
51
52
 
# File 'lib/fluent/plugin/in_diskusage.rb', line 48

def shutdown
  @watcher.terminate
  @watcher.join

end

#start ⇒ Object 



19
20
21
22
 
# File 'lib/fluent/plugin/in_diskusage.rb', line 19

def start
  super
  @watcher = Thread.new(&method(:run))
end