Class: DTK::State::Component::Attribute::Influxdb::Measurement::Errors

Inherits:
DTK::State::Component::Attribute::Influxdb::Measurement show all
Defined in:
lib/state/component/providers/influxdb/measurement/errors.rb

Instance Method Summary collapse

Methods inherited from DTK::State::Component::Attribute::Influxdb::Measurement

#flux_filter, #get_last_point, #get_required_tags, #initialize

Constructor Details

This class inherits a constructor from DTK::State::Component::Attribute::Influxdb::Measurement

Instance Method Details

#get_correlator_type(entrypoint) ⇒ Object



11
12
13
14
15
# File 'lib/state/component/providers/influxdb/measurement/errors.rb', line 11

def get_correlator_type(entrypoint)
  {
    correlator_type: entrypoint.split('/').last.split('.')[0]
  }
end

#write(value, params_hash = {}, timestamp) ⇒ Object



6
7
8
9
# File 'lib/state/component/providers/influxdb/measurement/errors.rb', line 6

def write(value, params_hash = {}, timestamp)
  checked_params_hash = check_params_hash(params_hash)
  write_point(value, checked_params_hash, timestamp)
end