Hhxsv5\LaravelS\Components\Prometheus\PrometheusCollectorProcess

Complexity

Total Complexity

5

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	onStop()	0	3	1
A	callback()	0	16	3
A	onReload()	0	3	1

<?php

Missing file doc comment

namespace Hhxsv5\LaravelS\Components\Prometheus;

use Hhxsv5\LaravelS\Components\Prometheus\Collectors\SwooleWorkerCollector;
use Hhxsv5\LaravelS\Swoole\Process\CustomProcessInterface;
use Swoole\Http\Server;
use Swoole\Process;
use Swoole\Timer;

class PrometheusCollectorProcess implements CustomProcessInterface

Missing doc comment for class PrometheusCollectorProcess

{
    private static $timerId;

Private member variable "timerId" must be prefixed with an underscore

    public static function callback(Server $swoole, Process $process)

Missing doc comment for function callback()

    {
        /**@var \Hhxsv5\LaravelS\Components\Prometheus\PrometheusCollector $collector */

Missing short description in doc comment

The close comment tag must be the only content on the line

The open comment tag must be the only content on the line

        $collector = app(SwooleWorkerCollector::class);

The function app was not found. Maybe you did not declare it correctly or list all dependencies?

        $workerNum = $swoole->setting['worker_num'];
        $taskWorkerNum = isset($swoole->setting['task_worker_num']) ? $swoole->setting['task_worker_num'] : 0;
        $totalNum = $workerNum + $taskWorkerNum - 1;
        $workerIds = range(0, $totalNum);
        $runJob = function () use ($swoole, $workerIds, $collector) {
            foreach ($workerIds as $workerId) {
                $swoole->sendMessage($collector, $workerId);
            }
        };

        $interval = config('prometheus.collect_metrics_interval', 10) * 1000;

The function config was not found. Maybe you did not declare it correctly or list all dependencies?

        self::$timerId = Timer::tick($interval, $runJob);
    }

    public static function onReload(Server $swoole, Process $process)

Missing doc comment for function onReload()

    {
        Timer::clear(self::$timerId);
    }

    public static function onStop(Server $swoole, Process $process)

The parameter $swoole is not used and could be removed.

Missing doc comment for function onStop()

The parameter $process is not used and could be removed.

    {
        Timer::clear(self::$timerId);
    }
}