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