Aggregator::start() - Code Metrics - carno-php/monitor - Measure and Improve Code Quality continuously with Scrutinizer

Aggregator::start() A
last analyzed 2019-04-04 10:13 UTC

↳ Parent: Aggregator

Complexity

Conditions	1
Paths	1

Size

Total Lines	20
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	13
nc	1
nop	0
dl	0
loc	20
rs	9.8333
c	0
b	0
f	0

<?php
/**
 * Metrics aggregator
 * User: moyo
 * Date: 28/12/2017
 * Time: 5:56 PM
 */

namespace Carno\Monitor\Collector;

use Carno\Monitor\Daemon;
use Carno\Promise\Promise;
use Carno\Promise\Promised;
use Carno\Timer\Timer;

class Aggregator
{
    /**
     * @var array
     */
    private $metrics = [];

    /**
     * @var Daemon
     */
    private $source = null;

    /**
     * @var string
     */
    private $timer = null;

    /**
     * @var int
     */
    private $cycled = null;

    /**
     * Aggregation constructor.
     * @param Daemon $daemon
     * @param int $cycled
     */
    public function __construct(Daemon $daemon, int $cycled = 2)
    {
        $this->source = $daemon;
        $this->cycled = $cycled;
    }

    /**
     * @return array
     */
    public function metrics() : array
    {
        return $this->metrics;
    }

    /**
     * @return static
     */
    public function start() : self
    {
        $this->timer = Timer::loop($this->cycled * 1000, function () {
            $metrics = [];

            $this->source->spouting(static function (
                string $typed,
                string $named,
                string $grouped,
                string $description,
                array $labels,
                array $data
            ) use (&$metrics) {
                $metrics[$typed][$named][$grouped] = [$data, $labels, $description];
            });

            $this->metrics = $metrics;
        });

        return $this;
    }

    /**
     * @return Promised
     */
    public function stop() : Promised
    {
        Timer::clear($this->timer);
        return Promise::resolved();
    }
}


1			<?php
2			/**
3			* Metrics aggregator
4			* User: moyo
5			* Date: 28/12/2017
6			* Time: 5:56 PM
7			*/
8
9			namespace Carno\Monitor\Collector;
10
11			use Carno\Monitor\Daemon;
12			use Carno\Promise\Promise;
13			use Carno\Promise\Promised;
14			use Carno\Timer\Timer;
15
16			class Aggregator
17			{
18			/**
19			* @var array
20			*/
21			private $metrics = [];
22
23			/**
24			* @var Daemon
25			*/
26			private $source = null;
27
28			/**
29			* @var string
30			*/
31			private $timer = null;
32
33			/**
34			* @var int
35			*/
36			private $cycled = null;
37
38			/**
39			* Aggregation constructor.
40			* @param Daemon $daemon
41			* @param int $cycled
42			*/
43			public function __construct(Daemon $daemon, int $cycled = 2)
44			{
45			$this->source = $daemon;
46			$this->cycled = $cycled;
47			}
48
49			/**
50			* @return array
51			*/
52			public function metrics() : array
53			{
54			return $this->metrics;
55			}
56
57			/**
58			* @return static
59			*/
60			public function start() : self
61			{
62			$this->timer = Timer::loop($this->cycled * 1000, function () {
63			$metrics = [];
64
65			$this->source->spouting(static function (
66			string $typed,
67			string $named,
68			string $grouped,
69			string $description,
70			array $labels,
71			array $data
72			) use (&$metrics) {
73			$metrics[$typed][$named][$grouped] = [$data, $labels, $description];
74			});
75
76			$this->metrics = $metrics;
77			});
78
79			return $this;
80			}
81
82			/**
83			* @return Promised
84			*/
85			public function stop() : Promised
86			{
87			Timer::clear($this->timer);
88			return Promise::resolved();
89			}
90			}
91

carno-php / monitor

Aggregator::start() A last analyzed 2019-04-04 10:13 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

Aggregator::start() A
last analyzed 2019-04-04 10:13 UTC