Class: Sidekiq::RingBuffer

Inherits:

Object

• Object
• Sidekiq::RingBuffer

Extended by:

Forwardable

Includes:

Enumerable

Defined in:

lib/sidekiq/ring_buffer.rb

Instance Method Summary

• #<<(element) ⇒ Object
• #buffer ⇒ Object
• #initialize(size, default = 0) ⇒ RingBuffer constructor

  A new instance of RingBuffer.

• #reset(default = 0) ⇒ Object

Constructor Details

#initialize(size, default = 0) ⇒ RingBuffer

Returns a new instance of RingBuffer.

# File 'lib/sidekiq/ring_buffer.rb', line 9

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

Instance Method Details

#<<(element) ⇒ Object

# File 'lib/sidekiq/ring_buffer.rb', line 15

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

#buffer ⇒ Object

# File 'lib/sidekiq/ring_buffer.rb', line 21

def buffer
  @buf
end

#reset(default = 0) ⇒ Object

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

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