class Sidekiq::RingBuffer
Public Class Methods
new(size, default = 0)
click to toggle 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
<<(element)
click to toggle source
# File lib/sidekiq/ring_buffer.rb, line 17 def <<(element) @buf[@index % @size] = element @index += 1 element end
buffer()
click to toggle source
# File lib/sidekiq/ring_buffer.rb, line 23 def buffer @buf end
reset(default = 0)
click to toggle source
# File lib/sidekiq/ring_buffer.rb, line 27 def reset(default = 0) @buf.fill(default) end