1 files changed, 80 insertions, 0 deletions
diff --git a/src/Metrics/Metrics.php b/src/Metrics/Metrics.php
new file mode 100644
index 00000000..d6b6e1da
--- /dev/null
+++ b/src/Metrics/Metrics.php
@@ -0,0 +1,80 @@
+<?php
+
+/**
+ * Spiral Framework.
+ *
+ * @license   MIT
+ * @author    Anton Titov (Wolfy-J)
+ */
+declare(strict_types=1);
+
+namespace Spiral\RoadRunner;
+
+use Spiral\Goridge\Exceptions\RPCException;
+use Spiral\Goridge\RPC;
+use Spiral\RoadRunner\Exception\MetricException;
+
+/**
+ * Application metrics.
+ */
+final class Metrics implements MetricsInterface
+{
+    /** @var RPC */
+    private $rpc;
+
+    /**
+     * @param RPC $rpc
+     */
+    public function __construct(RPC $rpc)
+    {
+        $this->rpc = $rpc;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function add(string $name, float $value, array $labels = []): void
+    {
+        try {
+            $this->rpc->call('metrics.Add', compact('name', 'value', 'labels'));
+        } catch (RPCException $e) {
+            throw new MetricException($e->getMessage(), $e->getCode(), $e);
+        }
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function sub(string $name, float $value, array $labels = []): void
+    {
+        try {
+            $this->rpc->call('metrics.Sub', compact('name', 'value', 'labels'));
+        } catch (RPCException $e) {
+            throw new MetricException($e->getMessage(), $e->getCode(), $e);
+        }
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function observe(string $name, float $value, array $labels = []): void
+    {
+        try {
+            $this->rpc->call('metrics.Observe', compact('name', 'value', 'labels'));
+        } catch (RPCException $e) {
+            throw new MetricException($e->getMessage(), $e->getCode(), $e);
+        }
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function set(string $name, float $value, array $labels = []): void
+    {
+        try {
+            $this->rpc->call('metrics.Set', compact('name', 'value', 'labels'));
+        } catch (RPCException $e) {
+            throw new MetricException($e->getMessage(), $e->getCode(), $e);
+        }
+    }
+}