class Sidekiq::RingBuffer
Public Class Methods
Source
# File lib/sidekiq/ring_buffer.rb, line 11 def initialize(size, default = 0) @size = size @buf = Array.new(size, default) @index = 0 end
Public Instance Methods
Source
# File lib/sidekiq/ring_buffer.rb, line 17 def <<(element) @buf[@index % @size] = element @index += 1 element end
Source
# File lib/sidekiq/ring_buffer.rb, line 27 def reset(default = 0) @buf.fill(default) end