Method: InfluxDB::Writer::Async#write

Defined in:
lib/influxdb/writer/async.rb

#write(data, precision = nil, retention_policy = nil, database = nil) ⇒ Object



14
15
16
17
# File 'lib/influxdb/writer/async.rb', line 14

def write(data, precision = nil, retention_policy = nil, database = nil)
  data = data.is_a?(Array) ? data : [data]
  data.map { |payload| worker.push(payload, precision, retention_policy, database) }
end