class Fluent::Logger::TestLogger
Attributes
max[RW]
queue[R]
Public Class Methods
new(queue=[])
click to toggle source
# File lib/fluent/logger/test_logger.rb, line 21 def initialize(queue=[]) @queue = queue @max = 1024 end
Public Instance Methods
close()
click to toggle source
# File lib/fluent/logger/test_logger.rb, line 45 def close end
post_with_time(tag, map, time)
click to toggle source
# File lib/fluent/logger/test_logger.rb, line 29 def post_with_time(tag, map, time) while @queue.size > @max-1 @queue.shift end (class<<map;self;end).module_eval do define_method(:tag) { tag } define_method(:time) { time } end @queue << map true end
tag_queue(tag)
click to toggle source
# File lib/fluent/logger/test_logger.rb, line 41 def tag_queue(tag) @queue.find_all {|map| map.tag == tag } end