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