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
- #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 |
# File 'lib/semantic_logger/appenders.rb', line 11 def add(**args, &block) appender = SemanticLogger::Appender.factory(**args, &block) self << appender appender end |
#close ⇒ Object
39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/semantic_logger/appenders.rb', line 39 def close each do |appender| begin logger.trace "Closing appender: #{appender.name}" appender.flush appender.close delete(appender) rescue Exception => exc logger.error "Failed to close appender: #{appender.inspect}", exc end end logger.trace 'All appenders closed and removed from appender list' end |
#flush ⇒ Object
27 28 29 30 31 32 33 34 35 36 37 |
# File 'lib/semantic_logger/appenders.rb', line 27 def flush each do |appender| begin logger.trace "Flushing appender: #{appender.name}" appender.flush rescue Exception => exc logger.error "Failed to flush appender: #{appender.inspect}", exc end end logger.trace 'All appenders flushed' end |
#log(log) ⇒ Object
17 18 19 20 21 22 23 24 25 |
# File 'lib/semantic_logger/appenders.rb', line 17 def log(log) each do |appender| begin appender.log(log) if appender.should_log?(log) rescue Exception => exc logger.error "Failed to log to appender: #{appender.inspect}", exc end end end |
#reopen ⇒ Object
After a fork the appender thread is not running, start it if it is not running.
54 55 56 57 58 59 60 61 62 63 64 65 66 |
# File 'lib/semantic_logger/appenders.rb', line 54 def reopen each do |appender| begin next unless appender.respond_to?(:reopen) logger.trace "Reopening appender: #{appender.name}" appender.reopen rescue Exception => exc logger.error "Failed to re-open appender: #{appender.inspect}", exc end end logger.trace 'All appenders re-opened' end |