PrometheusExporter::observeRequest() - Code Metrics - Inspection of "add memory metics for prometheus" - hhxsv5/laravel-s - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 918514...b89e50 )

by Biao
created 2021-11-14 14:07 UTC
PrometheusExporter::observeRequest() A

↳ Parent: PrometheusExporter
Complexity

Conditions	3
Paths	3
Size

Total Lines	23
Code Lines	14
Duplication

Lines	0
Ratio	0 %
Importance

Changes	6
Bugs	1	Features	0
Metric	Value
cc	3
eloc	14
c	6
b	1
f	0
nc	3
nop	2
dl	0
loc	23
rs	9.7998
<?php


namespace Hhxsv5\LaravelS\Components\Prometheus;

class PrometheusExporter

{
    const REDNER_MIME_TYPE = 'text/plain; version=0.0.4';

    private $config;


    public function __construct(array $config)

    {
        $this->config = $config;
    }

    public function getSystemLoadAvgMetrics()

    {
        $load = sys_getloadavg();
        return [
            [
                'name'  => 'system_load_average_1m',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $load[0],
            ],
            [
                'name'  => 'system_load_average_5m',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $load[1],
            ],
            [
                'name'  => 'system_load_average_15m',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $load[2],
            ],
        ];
    }

    public function getSwooleMetrics()

    {
        /**@var \Swoole\Http\Server $swoole */

        $swoole = app('swoole');
        $swoole = /** @scrutinizer ignore-call */ app('swoole');
        $stats = $swoole->stats();
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
$object = $a->getObject();
        // Get worker_num/task_worker_num from setting for the old Swoole.
        $setting = $swoole->setting;
        if (!isset($stats['worker_num'])) {
            $stats['worker_num'] = $setting['worker_num'];
        }
        if (!isset($stats['task_worker_num'])) {
            $stats['task_worker_num'] = isset($setting['task_worker_num']) ? $setting['task_worker_num'] : 0;
        }
        return [
            [
                'name'  => 'swoole_cpu_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => swoole_cpu_num(),
            ],
            [
                'name'  => 'swoole_start_time',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $stats['start_time'],
            ],
            [
                'name'  => 'swoole_connection_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $stats['connection_num'],
            ],
            [
                'name'  => 'swoole_request_count',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $stats['request_count'],
            ],
            [
                'name'  => 'swoole_worker_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $stats['worker_num'],
            ],
            [
                'name'  => 'swoole_idle_worker_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => isset($stats['idle_worker_num']) ? $stats['idle_worker_num'] : 0,
            ],
            [
                'name'  => 'swoole_task_worker_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $stats['task_worker_num'],
            ],
            [
                'name'  => 'swoole_task_idle_worker_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => isset($stats['task_idle_worker_num']) ? $stats['task_idle_worker_num'] : 0,
            ],
            [
                'name'  => 'swoole_tasking_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $stats['tasking_num'],
            ],
            [
                'name'  => 'swoole_coroutine_num',
                'help'  => '',
                'type'  => 'gauge',
                'value' => isset($stats['coroutine_num']) ? $stats['coroutine_num'] : 0,
            ],
        ];
    }

    public function getApcuMetrics()

    {
        $apcSmaInfo = apcu_sma_info(true);
        $metrics = [
            [
                'name'  => 'apcu_seg_size',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $apcSmaInfo['seg_size'],
            ],
            [
                'name'  => 'apcu_avail_mem',
                'help'  => '',
                'type'  => 'gauge',
                'value' => $apcSmaInfo['avail_mem'],
            ],
        ];
        foreach (new \APCuIterator('/^' . $this->config['apcu_key_prefix'] . $this->config['apcu_key_separator'] . '/') as $item) {
            $value = apcu_fetch($item['key'], $success);
            if (!$success) {
                continue;
            }

            $parts = explode($this->config['apcu_key_separator'], $item['key']);
            parse_str($parts[3], $labels);
            $metrics[] = [
                'name'   => $parts[1],
                'help'   => '',
                'type'   => $parts[2],
                'value'  => $value,
                'labels' => $labels,
            ];
        }
        return $metrics;

    }

    public function render()

    {
        $defaultLabels = ['application' => $this->config['application']];
        $metrics = array_merge($this->getSystemLoadAvgMetrics(), $this->getSwooleMetrics(), $this->getApcuMetrics());
        $lines = [];
        foreach ($metrics as $metric) {
            $lines[] = "# HELP " . $metric['name'] . " {$metric['help']}";
            $lines[] = "# TYPE " . $metric['name'] . " {$metric['type']}";

            $metricLabels = isset($metric['labels']) ? $metric['labels'] : [];
            $labels = ['{'];
            $allLabels = array_merge($defaultLabels, $metricLabels);
            foreach ($allLabels as $key => $value) {
                $value = addslashes($value);
                $labels[] = "{$key}=\"{$value}\",";
            }
            $labels[] = '}';
            $labelStr = implode('', $labels);
            $lines[] = $metric['name'] . "$labelStr {$metric['value']}";
        }
        return implode("\n", $lines);
    }
}
hhxsv5 / laravel-s

Push — master ( 918514...b89e50 )

PrometheusExporter::observeRequest() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
