symfony messenger

src/Command/RrCommand.php

@@ -0,0 +1,54 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Command;
+
+use Spiral\Goridge\RPC\RPC;
+use Spiral\RoadRunner\Services\Manager;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Helper\Table;
+use Symfony\Component\Console\Output\OutputInterface;
+
+#[AsCommand(
+    name: 'app:rr',
+    description: 'Add a short description for your command',
+)]
+class RrCommand extends Command
+{
+    private Manager $manager;
+
+    public function __construct()
+    {
+        parent::__construct();
+
+        $this->manager = new Manager(RPC::create('tcp://127.0.0.1:6001'));
+    }
+
+    public function __invoke(OutputInterface $output): int
+    {
+        $result = [];
+        $table = new Table($output);
+
+        $table->setHeaders(['Command', 'Memory', 'Error']);
+
+        foreach ($this->manager->list() as $serviceGroupName) {
+            foreach ($this->manager->statuses($serviceGroupName) as $serviceInstance) {
+                $result[] = [
+                    'command' => $serviceGroupName,
+                    'memory' => $serviceInstance['memory_usage'],
+
+                    'error' => $serviceInstance['error']
+                        ? $serviceInstance['error']['message']
+                        : null,
+                ];
+            }
+        }
+
+        $table->setRows($result);
+        $table->render();
+
+        return Command::SUCCESS;
+    }
+}