Class: SemanticLogger::Appenders
- Inherits:
-
Concurrent::Array
- Object
- Concurrent::Array
- SemanticLogger::Appenders
- Defined in:
- lib/semantic_logger/appenders.rb
Overview
Manage a collection of appenders.
Instance Attribute Summary collapse
-
#logger ⇒ Object
Returns the value of attribute logger.
Instance Method Summary collapse
- #add(**args, &block) ⇒ Object
- #close ⇒ Object
-
#console_output? ⇒ Boolean
Whether any of the existing appenders already output to the console? I.e.
- #flush ⇒ Object
-
#initialize(logger = Processor.logger.dup) ⇒ Appenders
constructor
A new instance of Appenders.
- #log(log) ⇒ Object
-
#reopen ⇒ Object
After a fork the appender thread is not running, start it if it is not running.
Constructor Details
Instance Attribute Details
#logger ⇒ Object
Returns the value of attribute logger.
4 5 6 |
# File 'lib/semantic_logger/appenders.rb', line 4 def logger @logger end |
Instance Method Details
#add(**args, &block) ⇒ Object
11 12 13 14 15 16 17 18 19 20 21 |
# File 'lib/semantic_logger/appenders.rb', line 11 def add(**args, &block) appender = SemanticLogger::Appender.factory(**args, &block) if appender.respond_to?(:console_output?) && appender.console_output? && console_output? logger.warn "Ignoring attempt to add a second console appender: #{appender.class.name} since it would result in duplicate console output." return end self << appender appender end |
#close ⇒ Object
47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/semantic_logger/appenders.rb', line 47 def close to_a.each do |appender| logger.trace "Closing appender: #{appender.name}" delete(appender) appender.flush appender.close rescue Exception => e logger.error "Failed to close appender: #{appender.name}", e end logger.trace "All appenders closed and removed from appender list" end |
#console_output? ⇒ Boolean
Whether any of the existing appenders already output to the console? I.e. Writes to stdout or stderr.
25 26 27 |
# File 'lib/semantic_logger/appenders.rb', line 25 def console_output? any? { |appender| appender.respond_to?(:console_output?) && appender.console_output? } end |
#flush ⇒ Object
37 38 39 40 41 42 43 44 45 |
# File 'lib/semantic_logger/appenders.rb', line 37 def flush each do |appender| logger.trace "Flushing appender: #{appender.name}" appender.flush rescue Exception => e logger.error "Failed to flush appender: #{appender.name}", e end logger.trace "All appenders flushed" end |
#log(log) ⇒ Object
29 30 31 32 33 34 35 |
# File 'lib/semantic_logger/appenders.rb', line 29 def log(log) each do |appender| appender.log(log) if appender.should_log?(log) rescue Exception => e logger.error "Failed to log to appender: #{appender.name}", e end end |
#reopen ⇒ Object
After a fork the appender thread is not running, start it if it is not running.
60 61 62 63 64 65 66 67 68 69 70 |
# File 'lib/semantic_logger/appenders.rb', line 60 def reopen each do |appender| next unless appender.respond_to?(:reopen) logger.trace "Reopening appender: #{appender.name}" appender.reopen rescue Exception => e logger.error "Failed to re-open appender: #{appender.name}", e end logger.trace "All appenders re-opened" end |