carno-php / cluster

src/Managed/Router.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
             $this->routing ??
             $this->routing = (new Routing(
                 sprintf('%s:%s', $this->type, $this->server),
-                function (int $evk, Endpoint $endpoint) {
+                function(int $evk, Endpoint $endpoint) {
                     $this->changed($evk, $endpoint);
                 }
             ))->strictly($this->strict)->accepts(...$this->tags)

src/Routing.php

Spacing +2 added lines, -2 removed lines

@@ -91,7 +91,7 @@ 
     {
         if (!$this->strict || $this->inTags($endpoint->getTags())) {
             $this->selector->classify($endpoint);
-            logger('cluster')->info('Discovered new service', ['node' => (string)$endpoint]);
+            logger('cluster')->info('Discovered new service', ['node' => (string) $endpoint]);
             ($this->watcher)(self::JOINING, $endpoint);
         } else {
             $this->nmWarning($endpoint, 'route.join');
@@ -105,7 +105,7 @@ 
     {
         if (!$this->strict || $this->inTags($endpoint->getTags())) {
             $this->selector->release($endpoint);
-            logger('cluster')->info('Service is gone', ['node' => (string)$endpoint]);
+            logger('cluster')->info('Service is gone', ['node' => (string) $endpoint]);
             ($this->watcher)(self::LEAVING, $endpoint);
         } else {
             $this->nmWarning($endpoint, 'route.leave');

src/Chips/InitializeTips.php

Spacing +2 added lines, -2 removed lines

@@ -26,11 +26,11 @@
     {
         $oid = spl_object_id($managed);
 
-        $this->checker[$oid] = Timer::loop(30000, function () use ($sk) {
+        $this->checker[$oid] = Timer::loop(30000, function() use ($sk) {
             logger('cluster')->notice('Now is waiting', ['resource' => $sk]);
         });
 
-        $managed->joined(function () use ($oid) {
+        $managed->joined(function() use ($oid) {
             Timer::clear($this->checker[$oid]);
         });
     }

src/Resources.php

Spacing +1 added lines, -1 removed lines

@@ -84,7 +84,7 @@
 
         $this->waits[$sk] = $wait = $this->classify->discovery($scene)->attach($group, $server, $managed);
 
-        $wait->then(function () use ($sk) {
+        $wait->then(function() use ($sk) {
             unset($this->waits[$sk]);
         });
 

src/Discovery/Adaptors/Config.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
 
         $this->managed[$named = $this->named($group, $server)] = $managed;
 
-        $this->source->watching($named, static function (string $dsn = null) use ($table, $named, $managed) {
+        $this->source->watching($named, static function(string $dsn = null) use ($table, $named, $managed) {
             foreach ($table->reset(...self::endpoints($dsn ?? '', $named)) as $op) {
                 $op->joined() && $managed->routing()->join($op->target());
                 $op->leaved() && $managed->routing()->leave($op->target());

src/Discovery/Adaptors/DNS.php

Spacing +2 added lines, -2 removed lines

@@ -49,7 +49,7 @@ 
     {
         $this->managed[$domain = $this->domain($server)] = $managed;
 
-        go(static function () use ($domain, $managed) {
+        go(static function() use ($domain, $managed) {
             try {
                 /**
                  * @var Result $resolved
@@ -86,6 +86,6 @@ 
      */
     private function domain(string $server) : string
     {
-        return $server . $this->suffix;
+        return $server.$this->suffix;
     }
 }

src/Discovery/Adaptors/Consul.php

Spacing +2 added lines, -2 removed lines

@@ -61,7 +61,7 @@ 
             )
         ;
 
-        new Worker($notify, function (array $routes) use ($named, $managed) {
+        new Worker($notify, function(array $routes) use ($named, $managed) {
             /**
              * @var Router[] $routes
              */
@@ -77,7 +77,7 @@ 
             $managed->ready(true);
         });
 
-        return $managed->ready(function () use ($named, $managed) {
+        return $managed->ready(function() use ($named, $managed) {
             $this->instances[$named] = $managed;
         });
     }