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