carno-php / traced

src/Protocol/ZipkinJFV2.php

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
         $this->extractEndpoint(EXT::LOCAL_ENDPOINT, 'localEndpoint', $tags, $data);
         $this->extractEndpoint(EXT::REMOTE_ENDPOINT, 'remoteEndpoint', $tags, $data);
 
-        array_walk($tags, function (string &$v) {
+        array_walk($tags, function(string &$v) {
             // values type convert .. do nothing
         });
 
@@ -57,7 +57,7 @@ 
                 list($timestamp, $fields) = $log;
 
                 $items = [];
-                array_walk($fields, function ($v, $k) use (&$items) {
+                array_walk($fields, function($v, $k) use (&$items) {
                     $items[] = "{$k}={$v}";
                 });
 

src/Components/Platforms.php

Spacing +2 added lines, -2 removed lines

@@ -28,11 +28,11 @@
         DI::set(Platform::class, $zpk);
         DI::set(Observer::class, $zpk);
 
-        $app->starting()->add(static function () use ($zpk) {
+        $app->starting()->add(static function() use ($zpk) {
             return $zpk->init();
         });
 
-        $app->stopping()->add(static function () use ($zpk) {
+        $app->stopping()->add(static function() use ($zpk) {
             return $zpk->leave();
         });
     }

src/Transport/ZipkinHAV2.php

Spacing +8 added lines, -8 removed lines

@@ -75,7 +75,7 @@ 
             $this->endpoint
         );
 
-        $this->daemon = Timer::loop(self::BATCH_INV, function () {
+        $this->daemon = Timer::loop(self::BATCH_INV, function() {
             $this->submitting();
         });
     }
@@ -87,7 +87,7 @@ 
     {
         Timer::clear($this->daemon);
 
-        $closing = function () {
+        $closing = function() {
             $this->client->closed()->pended() && $this->client->close();
         };
 
@@ -120,7 +120,7 @@ 
      */
     private function submitting(Closure $then = null) : void
     {
-        $this->spouting(co(function (array $spans) use ($then) {
+        $this->spouting(co(function(array $spans) use ($then) {
             $request = new Request(
                 'POST',
                 new Uri('http', $this->endpoint->host(), $this->endpoint->port(), $this->path),
@@ -134,13 +134,13 @@ 
                  * @var Response $response
                  */
                 $response = yield $this->client->perform($request);
-                if ((int)($response->getStatusCode() / 100) !== 2) {
+                if ((int) ($response->getStatusCode() / 100) !== 2) {
                     logger('traced')->notice(
                         'Server not accepting',
                         [
-                            'endpoint' => (string)$request->getUri(),
-                            'error' => sprintf('#%d->%s', $response->getStatusCode(), (string)$response->getBody()),
-                            'payload' => debug() ? (string)$request->getBody() : '[IGNORED]',
+                            'endpoint' => (string) $request->getUri(),
+                            'error' => sprintf('#%d->%s', $response->getStatusCode(), (string) $response->getBody()),
+                            'payload' => debug() ? (string) $request->getBody() : '[IGNORED]',
                         ]
                     );
                 }
@@ -148,7 +148,7 @@ 
                 logger('traced')->notice(
                     'Posting failed',
                     [
-                        'endpoint' => (string)$request->getUri(),
+                        'endpoint' => (string) $request->getUri(),
                         'error' => sprintf('%s::%s', get_class($e), $e->getMessage()),
                     ]
                 );

src/Platform/Zipkin.php

Spacing +2 added lines, -2 removed lines

@@ -82,13 +82,13 @@
                 'zipkin' => [ZipkinHAV2::class, ZipkinJFV2::class],
                 'udp' => [UDPRelays::class, ZipkinJFV2::class],
             ],
-            function (Transport $transport = null, Protocol $protocol = null) {
+            function(Transport $transport = null, Protocol $protocol = null) {
                 $this->transport && $this->transport->disconnect();
                 $this->transport = $transport;
                 $this->protocol = $protocol;
                 $this->changed($transport);
             },
-            static function (Throwable $e) {
+            static function(Throwable $e) {
                 logger('traced')->warning('Transport initialize failed', [
                     'p' => 'zipkin',
                     'ec' => get_class($e),

src/Transport/UDPRelays.php

Spacing +6 added lines, -6 removed lines

@@ -58,7 +58,7 @@ 
             PHP_SAPI === 'cli' ? SWOOLE_SOCK_ASYNC : SWOOLE_SOCK_SYNC
         );
         $this->client->connect($this->endpoint->host(), $this->endpoint->port());
-        $this->sender = function (string $data) {
+        $this->sender = function(string $data) {
             @$this->client->send($data);
         };
     }
@@ -72,7 +72,7 @@ 
             SOCK_DGRAM,
             $this->uxdomain ? IPPROTO_IP : SOL_UDP
         );
-        $this->sender = function (string $data) {
+        $this->sender = function(string $data) {
             @socket_sendto(
                 $this->socket,
                 $data,
@@ -142,10 +142,10 @@ 
     private function packing(string $payload) : string
     {
         return
-            self::MAGIC .
-            pack('N', strlen($this->identify)) .
-            $this->identify .
-            pack('N', strlen($payload)) .
+            self::MAGIC.
+            pack('N', strlen($this->identify)).
+            $this->identify.
+            pack('N', strlen($payload)).
             $payload
         ;
     }

src/Chips/TransportSync.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
         Closure $setter,
         Closure $failure = null
     ) : void {
-        $source->watching($conf, static function (string $dsn) use ($schemes, $setter, $failure) {
+        $source->watching($conf, static function(string $dsn) use ($schemes, $setter, $failure) {
             // parsing dsn
             $parsed = parse_url($dsn) ?: [];