Module: InfluxDB::AsyncQueue
- Defined in:
- lib/influxdb/async_queue.rb,
lib/influxdb/async_queue/queue.rb,
lib/influxdb/async_queue/config.rb,
lib/influxdb/async_queue/server.rb,
lib/influxdb/async_queue/version.rb,
lib/influxdb/async_queue/adapters/redis.rb,
lib/influxdb/async_queue/adapters/test_adapter.rb
Defined Under Namespace
Modules: Adapters
Classes: Config, Queue, Server
Constant Summary
collapse
- VERSION =
"0.1.2"
Class Method Summary
collapse
Class Method Details
.config=(config) ⇒ Object
25
26
27
|
# File 'lib/influxdb/async_queue.rb', line 25
def self.config=(config)
@config = config
end
|
16
17
18
19
|
# File 'lib/influxdb/async_queue.rb', line 16
def self.configure(file = nil)
load_config(file) if file
yield config
end
|
.load_config(path) ⇒ Object
.queue ⇒ Object
29
30
31
|
# File 'lib/influxdb/async_queue.rb', line 29
def self.queue
@queue ||= ::InfluxDB::AsyncQueue::Queue.new(config.adapter)
end
|