Module: Nark
- Defined in:
- lib/nark.rb,
lib/nark/version.rb,
lib/nark/influxdb_emitter.rb
Defined Under Namespace
Modules: ClassMethods
Classes: InfluxDBEmitter
Constant Summary
collapse
- VERSION =
'0.1.0'
Class Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
Class Attribute Details
.emitter ⇒ Object
53
54
55
56
57
58
59
60
61
62
|
# File 'lib/nark.rb', line 53
def emitter
@emitter ||= InfluxDBEmitter.new(
ENV['INFLUXDB_DATABASE'],
username: ENV['INFLUXDB_USERNAME'],
password: ENV['INFLUXDB_PASSWORD'],
hosts: ENV['INFLUXDB_HOST'],
port: ENV['INFLUXDB_PORT'],
use_ssl: ENV['INFLUXDB_USE_SSL']
)
end
|
Class Method Details
49
50
51
|
# File 'lib/nark.rb', line 49
def configure(&block)
block.call self
end
|
.included(klass) ⇒ Object
5
6
7
|
# File 'lib/nark.rb', line 5
def self.included(klass)
klass.extend ClassMethods
end
|
Instance Method Details
#collection_name(name = nil) ⇒ Object
21
22
23
24
25
26
|
# File 'lib/nark.rb', line 21
def collection_name(name = nil)
@collection_name = name if name
@collection_name ||= self.class.collection_name
@collection_name
end
|
#emit(timestamp: nil) ⇒ Object
14
15
16
17
18
19
|
# File 'lib/nark.rb', line 14
def emit(timestamp: nil)
hash = serializable_hash.clone
Nark.emitter.emit(collection_name, hash, timestamp)
self
end
|
#serializable_hash(value = nil) ⇒ Object
9
10
11
12
|
# File 'lib/nark.rb', line 9
def serializable_hash(value = nil)
@serializable_hash = value if value
@serializable_hash
end
|