Class: Sensu::LogStream

Inherits:
Object
  • Object
show all
Defined in:
lib/sensu/logstream.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ LogStream

Returns a new instance of LogStream.



3
4
5
6
7
8
9
 
# File 'lib/sensu/logstream.rb', line 3

def initialize
  @log_stream = EM::Queue.new
  @log_level = :info
  STDOUT.sync = true
  STDERR.reopen(STDOUT)
  setup_writer
end

Instance Method Details

#add(level, *arguments) ⇒ Object 



19
20
21
22
23
24
25
26
27
28
 
# File 'lib/sensu/logstream.rb', line 19

def add(level, *arguments)
  unless level_filtered?(level)
    log_event = create_log_event(level, *arguments)
    if EM::reactor_running?
      @log_stream << log_event
    else
      puts log_event
    end
  end
end

#level=(level) ⇒ Object 



11
12
13
 
# File 'lib/sensu/logstream.rb', line 11

def level=(level)
  @log_level = level
end

#level_filtered?(level) ⇒ Boolean

Returns:

  • (Boolean) 


15
16
17
 
# File 'lib/sensu/logstream.rb', line 15

def level_filtered?(level)
  LOG_LEVELS.index(level) < LOG_LEVELS.index(@log_level)
end

#reopen(file) ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/sensu/logstream.rb', line 36

def reopen(file)
  @log_file = file
  if File.writable?(file) || !File.exist?(file) && File.writable?(File.dirname(file))
    STDOUT.reopen(file, 'a')
    STDOUT.sync = true
    STDERR.reopen(STDOUT)
  else
    error('log file is not writable', {
      :log_file => file
    })
  end
end

#setup_traps ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/sensu/logstream.rb', line 49

def setup_traps
  if Signal.list.include?('USR1')
    Signal.trap('USR1') do
      @log_level = @log_level == :info ? :debug : :info
    end
  end
  if Signal.list.include?('USR2')
    Signal.trap('USR2') do
      if @log_file
        reopen(@log_file)
      end
    end
  end
end