Add and update test coverage for new storage adapter.

Signed-off-by: Arris Ray <arris.ray@gmail.com>

Author: arris-ray

docker-compose.yml

@@ -5,6 +5,8 @@ services:
       - php-fpm
     ports:
       - 8080:80
+    environment:
+      - REDIS_HOST=redis
 
   php-fpm:
     build: php-fpm/

examples/flush_adapter.php

@@ -16,6 +16,8 @@
     $adapter = new Prometheus\Storage\APCng();
 } elseif ($adapterName === 'in-memory') {
     $adapter = new Prometheus\Storage\InMemory();
+} elseif ($adapterName === 'redistxn') {
+    $adapter = new Prometheus\Storage\RedisTxn(['host' => $_SERVER['REDIS_HOST'] ?? '127.0.0.1']);
 }
 
 $adapter->wipeStorage();

examples/metrics.php

@@ -17,6 +17,8 @@
     $adapter = new Prometheus\Storage\APCng();
 } elseif ($adapter === 'in-memory') {
     $adapter = new Prometheus\Storage\InMemory();
+} elseif ($adapter === 'redistxn') {
+    $adapter = new Prometheus\Storage\RedisTxn(['host' => $_SERVER['REDIS_HOST'] ?? '127.0.0.1']);
 }
 $registry = new CollectorRegistry($adapter);
 $renderer = new RenderTextFormat();

examples/some_counter.php

@@ -16,6 +16,8 @@
     $adapter = new Prometheus\Storage\APCng();
 } elseif ($adapter === 'in-memory') {
     $adapter = new Prometheus\Storage\InMemory();
+} elseif ($adapter === 'redistxn') {
+    $adapter = new Prometheus\Storage\RedisTxn(['host' => $_SERVER['REDIS_HOST'] ?? '127.0.0.1']);
 }
 $registry = new CollectorRegistry($adapter);
 

examples/some_gauge.php

@@ -19,6 +19,8 @@
     $adapter = new Prometheus\Storage\APCng();
 } elseif ($adapter === 'in-memory') {
     $adapter = new Prometheus\Storage\InMemory();
+} elseif ($adapter === 'redistxn') {
+    $adapter = new Prometheus\Storage\RedisTxn(['host' => $_SERVER['REDIS_HOST'] ?? '127.0.0.1']);
 }
 $registry = new CollectorRegistry($adapter);
 

examples/some_histogram.php

@@ -18,6 +18,8 @@
     $adapter = new Prometheus\Storage\APCng();
 } elseif ($adapter === 'in-memory') {
     $adapter = new Prometheus\Storage\InMemory();
+} elseif ($adapter === 'redistxn') {
+    $adapter = new Prometheus\Storage\RedisTxn(['host' => $_SERVER['REDIS_HOST'] ?? '127.0.0.1']);
 }
 $registry = new CollectorRegistry($adapter);
 

examples/some_summary.php

@@ -18,6 +18,8 @@
     $adapter = new Prometheus\Storage\APCng();
 } elseif ($adapter === 'in-memory') {
     $adapter = new Prometheus\Storage\InMemory();
+} elseif ($adapter === 'redistxn') {
+    $adapter = new Prometheus\Storage\RedisTxn(['host' => $_SERVER['REDIS_HOST'] ?? '127.0.0.1']);
 }
 $registry = new CollectorRegistry($adapter);
 

tests/Test/Prometheus/RedisTxn/CollectorRegistryTest.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Prometheus\RedisTxn;
+
+use Prometheus\Storage\RedisTxn;
+use Test\Prometheus\AbstractCollectorRegistryTest;
+
+/**
+ * @requires extension redis
+ */
+class CollectorRegistryTest extends AbstractCollectorRegistryTest
+{
+    public function configureAdapter(): void
+    {
+        $this->adapter = new RedixTxn(['host' => REDIS_HOST]);
+        $this->adapter->wipeStorage();
+    }
+}

tests/Test/Prometheus/RedisTxn/CounterTest.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Prometheus\RedisTxn;
+
+use Prometheus\Storage\RedisTxn;
+use Test\Prometheus\AbstractCounterTest;
+
+/**
+ * See https://prometheus.io/docs/instrumenting/exposition_formats/
+ * @requires extension redis
+ */
+class CounterTest extends AbstractCounterTest
+{
+    public function configureAdapter(): void
+    {
+        $this->adapter = new RedixTxn(['host' => REDIS_HOST]);
+        $this->adapter->wipeStorage();
+    }
+}

tests/Test/Prometheus/RedisTxn/CounterWithPrefixTest.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Test\Prometheus\RedisTxn;
+
+use Prometheus\Storage\RedisTxn;
+use Test\Prometheus\AbstractCounterTest;
+
+/**
+ * See https://prometheus.io/docs/instrumenting/exposition_formats/
+ * @requires extension redis
+ */
+class CounterWithPrefixTest extends AbstractCounterTest
+{
+    public function configureAdapter(): void
+    {
+        $connection = new \Redis();
+        $connection->connect(REDIS_HOST);
+
+        $connection->setOption(\Redis::OPT_PREFIX, 'prefix:');
+
+        $this->adapter = RedixTxn::fromExistingConnection($connection);
+        $this->adapter->wipeStorage();
+    }
+}