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

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

Instance Method Summary collapse

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

#flux_filter, #get_last_point, #initialize

Constructor Details

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

Instance Method Details

#get_required_tags(event_id, pod_name, pod_namespace, component_name, attribute_name, task_id) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
 
# File 'lib/state/component/providers/influxdb/measurement/events.rb', line 11

def get_required_tags(event_id, pod_name, pod_namespace, component_name, attribute_name, task_id)
  {
    event_id: event_id,
    pod_name: pod_name,
    pod_namespace: pod_namespace,
    component_name: component_name,
    attribute_name: attribute_name,
    task_id: task_id
  }
end

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



6
7
8
9
 
# File 'lib/state/component/providers/influxdb/measurement/events.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