class Sidekiq::RingBuffer
Public Class Methods
new(size, default = 0)
click to toggle source
# File lib/sidekiq/ring_buffer.rb, line 9 def initialize(size, default = 0) @size = size @buf = Array.new(size, default) @index = 0 end
Public Instance Methods
<<(element)
click to toggle source
# File lib/sidekiq/ring_buffer.rb, line 15 def <<(element) @buf[@index % @size] = element @index += 1 element end
buffer()
click to toggle source
# File lib/sidekiq/ring_buffer.rb, line 21 def buffer @buf end
reset(default = 0)
click to toggle source
# File lib/sidekiq/ring_buffer.rb, line 25 def reset(default = 0) @buf.fill(default) end