1 files changed, 63 insertions, 0 deletions
diff --git a/vendor/gipfl/influxdb/src/DataPoint.php b/vendor/gipfl/influxdb/src/DataPoint.php
new file mode 100644
index 0000000..f272206
--- /dev/null
+++ b/vendor/gipfl/influxdb/src/DataPoint.php
@@ -0,0 +1,63 @@
+<?php
+
+namespace gipfl\InfluxDb;
+
+use InvalidArgumentException;
+use function array_key_exists;
+use function array_merge;
+use function is_array;
+use function is_object;
+use function ksort;
+
+class DataPoint
+{
+    protected $timestamp;
+
+    protected $measurement;
+
+    protected $tags = [];
+
+    protected $fields;
+
+    public function __construct($measurement, $tags = [], $fields = [], $timestamp = null)
+    {
+        $this->measurement = (string) $measurement;
+        if ($timestamp !== null) {
+            $this->timestamp = $timestamp;
+        }
+
+        if (! empty($tags)) {
+            $this->addTags($tags);
+        }
+
+        if (is_array($fields) || is_object($fields)) {
+            $this->fields = (array) $fields;
+        } else {
+            $this->fields = ['value' => $fields];
+        }
+
+        if (empty($this->fields)) {
+            throw new InvalidArgumentException('At least one field/value is required');
+        }
+    }
+
+    public function addTags($tags)
+    {
+        $this->tags = array_merge($this->tags, (array) $tags);
+        ksort($this->tags);
+    }
+
+    public function getTag($name, $default = null)
+    {
+        if (array_key_exists($name, $this->tags)) {
+            return $this->tags[$name];
+        } else {
+            return $default;
+        }
+    }
+
+    public function __toString()
+    {
+        return LineProtocol::renderMeasurement($this->measurement, $this->tags, $this->fields, $this->timestamp);
+    }
+}