Module: Kafka::TaggedLogger

Extended by:
Forwardable
Defined in:
lib/kafka/tagged_logger.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.new(logger) ⇒ Object 



53
54
55
56
57
58
59
60
 
# File 'lib/kafka/tagged_logger.rb', line 53

def self.new(logger)
  logger ||= Logger.new(nil)
  return logger if logger.respond_to?(:push_tags) # already included
  # Ensure we set a default formatter so we aren't extending nil!
  logger.formatter ||= Logger::Formatter.new
  logger.formatter.extend TaggedFormatter
  logger.extend(self)
end

Instance Method Details

#flush ⇒ Object 



66
67
68
69
 
# File 'lib/kafka/tagged_logger.rb', line 66

def flush
  clear_tags!
  super if defined?(super)
end

#tagged(*tags) ⇒ Object 



62
63
64
 
# File 'lib/kafka/tagged_logger.rb', line 62

def tagged(*tags)
  formatter.tagged(*tags) { yield self }
end