carno-php / traced

src/Chips/TransportSync.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
         string $protocol,
         Closure $setter
     ) : void {
-        config()->watching($conf, static function (string $dsn) use ($scheme, $transport, $protocol, $setter) {
+        config()->watching($conf, static function(string $dsn) use ($scheme, $transport, $protocol, $setter) {
             // parsing dsn
             $parsed = parse_url($dsn);
 

src/Transport/ZipkinHAV2.php

Spacing +7 added lines, -7 removed lines

@@ -72,7 +72,7 @@ 
             $endpoint
         );
 
-        $this->daemon = Timer::loop(self::BATCH_INV, function () {
+        $this->daemon = Timer::loop(self::BATCH_INV, function() {
             $this->submitting();
         });
     }
@@ -84,7 +84,7 @@ 
     {
         Timer::clear($this->daemon);
 
-        $closing = function () {
+        $closing = function() {
             $this->client->closed()->pended() && $this->client->close();
         };
 
@@ -117,7 +117,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(), self::API),
@@ -135,9 +135,9 @@ 
                     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]',
                         ]
                     );
                 }
@@ -145,7 +145,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 +1 added lines, -1 removed lines

@@ -62,7 +62,7 @@
             'zipkin',
             ZipkinHAV2::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;

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 +1 added lines, -1 removed lines

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