class InfluxDB::AsyncQueue::Adapters::TestAdapter

Attributes

array[R]

Public Class Methods

new() click to toggle source
# File lib/influxdb/async_queue/adapters/test_adapter.rb, line 6
def initialize
  @array = []
end

Public Instance Methods

pop(batch_size) click to toggle source
# File lib/influxdb/async_queue/adapters/test_adapter.rb, line 15
def pop(batch_size)
  array.shift(batch_size)
end
push(*points) click to toggle source
# File lib/influxdb/async_queue/adapters/test_adapter.rb, line 11
def push(*points)
  array.push(*points)
end