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 22
def initialize(queue=[])
  @queue = queue
  @max = 1024
end

Public Instance Methods

close() click to toggle source
# File lib/fluent/logger/test_logger.rb, line 46
def close
end
post_with_time(tag, map, time) click to toggle source
# File lib/fluent/logger/test_logger.rb, line 30
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 42
def tag_queue(tag)
  @queue.find_all {|map| map.tag == tag }
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.