module InfluxDB::AsyncQueue

Constants

VERSION

Public Class Methods

config() click to toggle source
# File lib/influxdb/async_queue.rb, line 21
def self.config
  @config ||= ::InfluxDB::AsyncQueue::Config.new
end
config=(config) click to toggle source
# File lib/influxdb/async_queue.rb, line 25
def self.config=(config)
  @config = config
end
configure(file = nil) { |config| ... } click to toggle source
# File lib/influxdb/async_queue.rb, line 16
def self.configure(file = nil)
  load_config(file) if file
  yield config
end
load_config(path) click to toggle source
# File lib/influxdb/async_queue.rb, line 12
def self.load_config(path)
  @config = ::InfluxDB::AsyncQueue::Config.load_from_file! path
end
queue() click to toggle source
# File lib/influxdb/async_queue.rb, line 29
def self.queue
  @queue ||= ::InfluxDB::AsyncQueue::Queue.new(config.adapter)
end