class InfluxDB::Rails::Middleware::SimpleSubscriber
Subscriber
acts as base class for different *Subscriber classes, which are intended as ActiveSupport::Notifications.subscribe consumers.
Attributes
series_name[R]
Public Class Methods
new(configuration, series_name)
click to toggle source
Calls superclass method
# File lib/influxdb/rails/middleware/simple_subscriber.rb, line 12 def initialize(configuration, series_name) super(configuration) @series_name = series_name end
Public Instance Methods
call(_name, started, finished, _unique_id, payload)
click to toggle source
# File lib/influxdb/rails/middleware/simple_subscriber.rb, line 17 def call(_name, started, finished, _unique_id, payload) return unless enabled? begin InfluxDB::Rails.client.write_point series_name, values: values(started, finished, payload), tags: tags(payload), timestamp: timestamp(finished.utc) rescue StandardError => e log :error, "[InfluxDB::Rails] Unable to write points: #{e.message}" end end
Private Instance Methods
enabled?()
click to toggle source
Calls superclass method
# File lib/influxdb/rails/middleware/simple_subscriber.rb, line 43 def enabled? super && series_name.present? end
timestamp(finished)
click to toggle source
# File lib/influxdb/rails/middleware/simple_subscriber.rb, line 39 def timestamp(finished) InfluxDB.convert_timestamp(finished.utc, configuration.time_precision) end
values(started, finished, _payload)
click to toggle source
# File lib/influxdb/rails/middleware/simple_subscriber.rb, line 32 def values(started, finished, _payload) result = { value: ((finished - started) * 1000).ceil } result.merge(InfluxDB::Rails.current.values).reject do |_, value| value.nil? || value == "" end end