Added UDP/IP integration tests

2026-07-27 16:08:55 +02:00 · 2015-06-23 19:28:14 +02:00
parent 20a64e724b
commit 03ade4c600
1 changed files with 53 additions and 0 deletions
@@ -0,0 +1,53 @@
+<?php
+namespace InfluxDB\Integration\Adapter;
+
+use InfluxDB\Integration\Framework\TestCase as InfluxDBTestCase;
+use InfluxDB\Adapter\UdpAdapter;
+use InfluxDB\Options;
+
+class UdpAdapterTest extends InfluxDBTestCase
+{
+    public function testWriteSimplePointsUsingDirectWrite()
+    {
+        $options = (new Options())
+            ->setPort(4444);
+        $adapter = new UdpAdapter($options);
+
+        $this->getClient()->createDatabase("udp.test");
+
+        $adapter->write("cpu value=12.33 " . (int)(microtime(true)*1e9));
+
+        sleep(2);
+
+        $this->assertSerieExists("udp.test", "cpu");
+        $this->assertSerieCount("udp.test", "cpu", 1);
+        $this->assertValueExistsInSerie("udp.test", "cpu", "value", 12.33);
+    }
+
+    public function testWriteSimplePointsUsingSendMethod()
+    {
+        $options = (new Options())
+            ->setPort(4444);
+        $adapter = new UdpAdapter($options);
+
+        $this->getClient()->createDatabase("udp.test");
+
+        $adapter->send([
+            "retentionPolicy" => "default",
+            "points" => [
+                [
+                    "measurement" => "mem",
+                    "fields" => [
+                        "value" => 1233,
+                    ],
+                ],
+            ],
+        ]);
+
+        sleep(2);
+
+        $this->assertSerieExists("udp.test", "mem");
+        $this->assertSerieCount("udp.test", "mem", 1);
+        $this->assertValueExistsInSerie("udp.test", "mem", "value", 1233);
+    }
+}