Starts working on metrics

issue #147

Author: butschster

app/modules/Metrics/Application/CollectorRegistryInterface.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Modules\Metrics\Application;
+
+use Spiral\RoadRunner\Metrics\CollectorInterface;
+
+interface CollectorRegistryInterface
+{
+    public function register(string $name, CollectorInterface $collector): void;
+}

app/modules/Metrics/Application/CollectorRepositoryInterface.php

@@ -0,0 +1,15 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Modules\Metrics\Application;
+
+use Spiral\RoadRunner\Metrics\CollectorInterface;
+
+interface CollectorRepositoryInterface
+{
+    /**
+     * @return iterable<non-empty-string, CollectorInterface>
+     */
+    public function findAll(): iterable;
+}

app/modules/Metrics/Application/MetricsBootloader.php

@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Modules\Metrics\Application;
+
+use Modules\Metrics\Infrastructure\RoadRunner\Collector;
+use Spiral\Boot\Bootloader\Bootloader;
+use Spiral\Console\Bootloader\ConsoleBootloader;
+use Spiral\Goridge\RPC\RPCInterface;
+use Spiral\RoadRunner\Metrics\MetricsFactory;
+use Spiral\RoadRunner\Metrics\MetricsInterface;
+use Spiral\RoadRunner\Metrics\MetricsOptions;
+use Spiral\RoadRunnerBridge\Bootloader\RoadRunnerBootloader;
+
+final class MetricsBootloader extends Bootloader
+{
+    public function defineDependencies(): array
+    {
+        return [
+            RoadRunnerBootloader::class,
+            MetricsBootloader::class,
+        ];
+    }
+
+    public function defineSingletons(): array
+    {
+        return [
+            MetricsInterface::class => static function (
+                RPCInterface $rpc,
+            ) {
+                $factory = new MetricsFactory();
+
+                return $factory->create(
+                    $rpc,
+                    new MetricsOptions(
+                        retryAttempts: 2,
+                        retrySleepMicroseconds: 300,
+                        suppressExceptions: true,
+                    ),
+                );
+            },
+
+            CollectorRepositoryInterface::class => Collector::class,
+            CollectorRegistryInterface::class => Collector::class,
+            Collector::class => Collector::class,
+        ];
+    }
+
+    public function init(ConsoleBootloader $console): void
+    {
+        $console->addConfigureSequence(
+            sequence: 'metrics:declare',
+            header: 'Declare metrics',
+        );
+    }
+}

app/modules/Metrics/Infrastructure/RoadRunner/Collector.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Modules\Metrics\Infrastructure\RoadRunner;
+
+use Modules\Metrics\Application\CollectorRegistryInterface;
+use Modules\Metrics\Application\CollectorRepositoryInterface;
+use Spiral\Core\Attribute\Singleton;
+use Spiral\RoadRunner\Metrics\CollectorInterface;
+
+#[Singleton]
+final class Collector implements CollectorRepositoryInterface, CollectorRegistryInterface
+{
+    /** @var array<non-empty-string, CollectorInterface> */
+    private array $collectors = [];
+
+    public function register(string $name, CollectorInterface $collector): void
+    {
+        $this->collectors[$name] = $collector;
+    }
+
+    public function findAll(): iterable
+    {
+        return $this->collectors;
+    }
+}

app/modules/Metrics/Interfaces/Console/Command/DeclareCommand.php

@@ -0,0 +1,34 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Modules\Metrics\Interfaces\Console\Command;
+
+use Modules\Metrics\Application\CollectorRepositoryInterface;
+use Spiral\Console\Attribute\AsCommand;
+use Spiral\Console\Command;
+use Spiral\RoadRunner\Metrics\MetricsInterface;
+
+#[AsCommand(
+    name: 'metrics:declare',
+    description: 'Declare metrics'
+)]
+final class DeclareCommand extends Command
+{
+    public function __invoke(
+        MetricsInterface $metrics,
+        CollectorRepositoryInterface $repository,
+    ): int {
+        foreach ($repository->findAll() as $name => $collector) {
+            $this->info("Declaring metric: {$name}");
+
+            try {
+                $metrics->declare($name, $collector);
+            } catch (\Throwable $e) {
+                $this->error("Failed to declare metric: {$name}. Reason: {$e->getMessage()}");
+            }
+        }
+
+        return self::SUCCESS;
+    }
+}