SDeregister::deregistered() - Code Metrics - carno-php/consul - Measure and Improve Code Quality continuously with Scrutinizer

SDeregister::deregistered() A
last analyzed 2019-06-20 01:55 UTC

↳ Parent: SDeregister

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	2
dl	0
loc	5
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1

<?php
/**
 * Service deregister
 * User: moyo
 * Date: 18/09/2017
 * Time: 10:26 PM
 */

namespace Carno\Consul\Chips;

use Carno\Consul\APIs\AgentServiceDeregister;
use Carno\Consul\Contracts\Defaults;
use Carno\Consul\Types\Result;
use Carno\Consul\Types\Service;
use function Carno\Coroutine\async;
use function Carno\Coroutine\msleep;
use Carno\Promise\Promised;
use Throwable;

trait SDeregister
{
    /**
     * @return Promised
     */
    public function deregister() : Promised
    {
        return async(function (Service $service) {
            for (;;) {
                if (!$service->connected()) {
                    logger('consul')->info('Service has not been registered .. skip', ['svc' => $service->id()]);
                    return;
                }

                /**
                 * @var Result $result
                 */

                try {
                    $result = yield (new AgentServiceDeregister($service->hosting()))->service($service)->result();
                } catch (Throwable $e) {
                    logger('consul')->warning('Service deregistering error', [
                        'svc' => $service->id(),
                        'error' => sprintf('%s::%s', get_class($e), $e->getMessage()),
                    ]);
                    goto RETRYING;
                }

                if ($result->success()) {
                    return;
                }

                RETRYING:

                yield msleep($sleep = rand(Defaults::ERROR_RETRY_MIN, Defaults::ERROR_RETRY_MAX));

                logger('consul')->notice('Service deregister retrying', [
                    'svc' => $service->id(),
                    'delay' => $sleep,
                ]);
            }
        }, null, $this);
    }

    /**
     * @param Result $result
     * @return Result
     */
    public function deregistered(Result $result) : Result
    {
        $this->kaShutdown();
               kaShutdown();

        return $result;
    }
}


carno-php / consul

SDeregister::deregistered() A last analyzed 2019-06-20 01:55 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

SDeregister::deregistered() A
last analyzed 2019-06-20 01:55 UTC