class Kafka::TaggedLogger
Public Class Methods
new(logger_or_stream = nil)
click to toggle source
Calls superclass method
# File lib/kafka/tagged_logger.rb, line 54 def self.new(logger_or_stream = nil) # don't keep wrapping the same logger over and over again return logger_or_stream if logger_or_stream.is_a?(TaggedLogger) super end
new(logger_or_stream = nil)
click to toggle source
Calls superclass method
# File lib/kafka/tagged_logger.rb, line 60 def initialize(logger_or_stream = nil) logger = if %w(info debug warn error).all? { |s| logger_or_stream.respond_to?(s) } logger_or_stream elsif logger_or_stream ::Logger.new(logger_or_stream) else ::Logger.new(nil) end super(logger) end
Public Instance Methods
flush()
click to toggle source
Calls superclass method
# File lib/kafka/tagged_logger.rb, line 71 def flush clear_tags! super if defined?(super) end
tagged(*tags) { |self| ... }
click to toggle source
# File lib/kafka/tagged_logger.rb, line 20 def tagged(*tags) new_tags = push_tags(*tags) yield self ensure pop_tags(new_tags.size) end