carno-php / monitor

src/Ticker.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
      */
     public static function new(array $metrics, callable $worker, int $period = 5) : string
     {
-        $idg = sprintf('tw-%d', self::$idg ++);
+        $idg = sprintf('tw-%d', self::$idg++);
 
         (self::$worker ?? self::$worker = new TWorker)
             ->adding($idg, $metrics, $worker, $period)

src/Metrics/Histogram.php

Spacing +2 added lines, -2 removed lines

@@ -43,12 +43,12 @@
     {
         foreach ($this->bounds as $idx => $bound) {
             if ($v < $bound) {
-                $this->buckets[$idx] ++;
+                $this->buckets[$idx]++;
                 break;
             }
         }
 
-        $this->count ++;
+        $this->count++;
         $this->sum += $v;
     }
 }

src/Metrics/Summary.php

Spacing +3 added lines, -3 removed lines

@@ -71,7 +71,7 @@ 
 
         count($this->samples) > $this->threshold && $this->compress();
 
-        $this->count ++;
+        $this->count++;
         $this->sum += $v;
     }
 
@@ -85,7 +85,7 @@ 
 
         $desired = intval($quantile * $this->count);
 
-        for ($i = 1; $i < count($this->samples); $i ++) {
+        for ($i = 1; $i < count($this->samples); $i++) {
             $sp = $this->samples[$i - 1];
             $sc = $this->samples[$i];
 
@@ -101,7 +101,7 @@ 
      */
     private function compress() : void
     {
-        for ($i = 0; $i < count($this->samples) - 1; $i ++) {
+        for ($i = 0; $i < count($this->samples) - 1; $i++) {
             $sa = $this->samples[$i];
             $sb = $this->samples[$i + 1];
 

src/Chips/Timers.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
             return $ik;
         }
 
-        $this->timers[$ik] = Timer::loop($period * 1000, static function () use ($ik, $do) {
+        $this->timers[$ik] = Timer::loop($period * 1000, static function() use ($ik, $do) {
             call_user_func($do, $ik);
         });
 

src/Chips/Metrical/HBuckets.php

Spacing +2 added lines, -2 removed lines

@@ -34,7 +34,7 @@ 
     {
         $bounds = [];
 
-        for ($i = 0; $i < $count; $i ++) {
+        for ($i = 0; $i < $count; $i++) {
             $bounds[] = $start;
             $start += $width;
         }
@@ -52,7 +52,7 @@ 
     {
         $bounds = [];
 
-        for ($i = 0; $i < $count; $i ++) {
+        for ($i = 0; $i < $count; $i++) {
             $bounds[] = $start;
             $start *= $factor;
         }

src/Output/Prometheus.php

Spacing +5 added lines, -5 removed lines

@@ -83,7 +83,7 @@ 
         try {
             ($this->httpd = Server::httpd(
                 $listen,
-                function (Connection $conn) {
+                function(Connection $conn) {
                     switch ($conn->request()->getUri()->getPath()) {
                         case '/metrics':
                             $conn->reply(new Response(
@@ -112,7 +112,7 @@ 
             goto END;
         }
 
-        $this->pushd = Timer::loop(self::ACT_PUSH_INV, co(function () use ($listen, $push) {
+        $this->pushd = Timer::loop(self::ACT_PUSH_INV, co(function() use ($listen, $push) {
             yield $this->pushing(Client::post(
                 $this->gate = sprintf(
                     'http://%s:%d/metrics/job/%s/instance/%s',
@@ -138,7 +138,7 @@ 
     public function stop() : void
     {
         $this->httpd && $this->httpd->shutdown();
-        $this->pushd && Timer::clear($this->pushd) && co(function () {
+        $this->pushd && Timer::clear($this->pushd) && co(function() {
             $this->gate && yield $this->pushing(Client::delete($this->gate), 'removing');
         })();
     }
@@ -168,7 +168,7 @@ 
      */
     private function exporting(bool $push = false) : string
     {
-        $now = $push ? 0 : (int)(microtime(true) * 1000);
+        $now = $push ? 0 : (int) (microtime(true) * 1000);
 
         $lines = $types = [];
 
@@ -238,7 +238,7 @@ 
 
         $labeling = [];
 
-        array_walk($merged, function (string $v, string $k) use (&$labeling) {
+        array_walk($merged, function(string $v, string $k) use (&$labeling) {
             $labeling[] = sprintf('%s="%s"', $k, $v);
         });
 

src/Builtin/ProgramStatus.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
      */
     public function __construct()
     {
-        Ticker::new([Metrics::gauge()->named('memory.usage.bytes')], static function (Gauge $memory) {
+        Ticker::new([Metrics::gauge()->named('memory.usage.bytes')], static function(Gauge $memory) {
             $memory->set(memory_get_usage());
         });
     }

src/Builtin/PoolStatsExporter.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
                 Metrics::gauge()->named('pool.conn.busy')->labels($labels),
                 Metrics::gauge()->named('pool.select.wait')->labels($labels),
             ],
-            static function (Gauge $idle, Gauge $busy, Gauge $wait) use ($pool) {
+            static function(Gauge $idle, Gauge $busy, Gauge $wait) use ($pool) {
                 $idle->set($pool->stats()->cIdling());
                 $busy->set($pool->stats()->cBusying());
                 $wait->set($pool->stats()->sPending());

src/Collector/Cleaner.php

Spacing +1 added lines, -1 removed lines

@@ -107,7 +107,7 @@
             'system',
             '',
             [],
-            ['value' => ++ $this->crashed]
+            ['value' => ++$this->crashed]
         );
     }
 }