Class: Sidekiq::RingBuffer

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Includes:
Enumerable
Defined in:
lib/sidekiq/ring_buffer.rb

Instance Method Summary collapse

Constructor Details

#initialize(size, default = 0) ⇒ RingBuffer

Returns a new instance of RingBuffer.



12
13
14
15
16
 
# File 'lib/sidekiq/ring_buffer.rb', line 12

def initialize(size, default = 0)
  @size = size
  @buf = Array.new(size, default)
  @index = 0
end

Instance Method Details

#<<(element) ⇒ Object 



18
19
20
21
22
 
# File 'lib/sidekiq/ring_buffer.rb', line 18

def <<(element)
  @buf[@index % @size] = element
  @index += 1
  element
end

#buffer ⇒ Object 



24
25
26
 
# File 'lib/sidekiq/ring_buffer.rb', line 24

def buffer
  @buf
end

#reset(default = 0) ⇒ Object 



28
29
30
 
# File 'lib/sidekiq/ring_buffer.rb', line 28

def reset(default = 0)
  @buf.fill(default)
end